pub struct QueryRoot;

#[graphql_object(context = Context)]
impl QueryRoot {
    async fn api_version() -> &str {
        "0.1"
    }
}

use juniper::{graphql_object, FieldError, FieldResult};

use crate::graphql::schema::Context;
use crate::graphql::query::QueryRoot;
use crate::graphql::users::schema::User;


#[graphql_object(context = Context)]
impl QueryRoot {
    pub async fn get_user_by_id(context: &Context, id: i32) -> FieldResult<User> {
        let sql = r#"
            select
                id::int4,
                email,
                documento
            from
                auth_users
            where
                id = $1
        "#;
        let data = sqlx::query_as::<_, User>(sql)
            .bind(id)
            .fetch_one(&context.pool)
            .await;

        match data {
            Ok(user) => Ok(user),
            _ => Err(FieldError::from("no se encontró el usuario")),
        }
    }

    pub async fn get_all_user(context: &Context, page: i32, page_size: i32) -> FieldResult<Vec<User>> {
        let sql = r#"
            select
                id::int4,
                email,
                documento
            from
                auth_users
            order by
                id
            OFFSET $1*$2 LIMIT $2;
        "#;
        let data = sqlx::query_as::<_, User>(sql)
            .bind(page)
            .bind(page_size)
            .fetch_all(&context.pool)
            .await.unwrap();

        Ok(data)
    }
}

pub struct QueryRoot;


#[graphql_object(context = Context)]
impl QueryRoot {
    async fn api_version() -> &str {
        "0.1"
    }
    async fn get_user_by_id(context: &Context, id: i32) -> FieldResult<User> {
        get_user_by_id(context, id).await
    }

    async fn get_all_user(context: &Context, page: i32, page_size: i32) -> FieldResult<Vec<User>> {
       get_all_user(context, page, page_size).await
    }
}