1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use super::schemas::ChallengeWithProposals;
use crate::db::{models::challenges::Challenge, queries::challenges as challenges_queries};
use crate::v0::context::SharedContext;
use crate::v0::errors::HandleError;

pub async fn get_all_challenges(context: SharedContext) -> Result<Vec<Challenge>, HandleError> {
    let pool = &context.read().await.db_connection_pool;
    challenges_queries::query_all_challenges(pool).await
}

pub async fn get_challenge_by_id(
    id: i32,
    context: SharedContext,
) -> Result<ChallengeWithProposals, HandleError> {
    let pool = &context.read().await.db_connection_pool;
    let challenge = challenges_queries::query_challenge_by_id(id, pool).await?;
    let proposals = challenges_queries::query_challenge_proposals_by_id(id, pool).await?;
    Ok(ChallengeWithProposals {
        challenge,
        proposals,
    })
}

pub async fn get_challenge_by_id_and_group_id(
    id: i32,
    voter_group_id: String,
    context: SharedContext,
) -> Result<ChallengeWithProposals, HandleError> {
    let pool = &context.read().await.db_connection_pool;
    let challenge = challenges_queries::query_challenge_by_id(id, pool).await?;
    let proposals =
        challenges_queries::query_challenge_proposals_by_id_and_group_id(id, voter_group_id, pool)
            .await?;
    Ok(ChallengeWithProposals {
        challenge,
        proposals,
    })
}