126 lines
2.9 KiB
Rust
126 lines
2.9 KiB
Rust
use async_graphql::{Context, EmptySubscription, Object, Schema};
|
|
|
|
use como_domain::{
|
|
item::{
|
|
queries::{GetItemQuery, GetItemsQuery},
|
|
requests::CreateItemDto,
|
|
},
|
|
projects::{
|
|
queries::{GetProjectQuery, GetProjectsQuery},
|
|
ProjectDto,
|
|
},
|
|
};
|
|
use como_infrastructure::register::ServiceRegister;
|
|
|
|
use crate::items::{CreatedItem, Item};
|
|
|
|
pub type ComoSchema = Schema<QueryRoot, MutationRoot, EmptySubscription>;
|
|
|
|
pub struct MutationRoot;
|
|
|
|
#[Object]
|
|
impl MutationRoot {
|
|
async fn login(
|
|
&self,
|
|
ctx: &Context<'_>,
|
|
username: String,
|
|
password: String,
|
|
) -> anyhow::Result<bool> {
|
|
let service_register = ctx.data_unchecked::<ServiceRegister>();
|
|
|
|
let valid = service_register
|
|
.user_service
|
|
.validate_user(username, password)
|
|
.await?;
|
|
let returnvalid = match valid {
|
|
Some(..) => true,
|
|
None => false,
|
|
};
|
|
|
|
Ok(returnvalid)
|
|
}
|
|
|
|
async fn register(
|
|
&self,
|
|
ctx: &Context<'_>,
|
|
username: String,
|
|
password: String,
|
|
) -> anyhow::Result<String> {
|
|
let service_register = ctx.data_unchecked::<ServiceRegister>();
|
|
|
|
let user_id = service_register
|
|
.user_service
|
|
.add_user(username, password)
|
|
.await?;
|
|
|
|
Ok(user_id)
|
|
}
|
|
|
|
async fn create_item(
|
|
&self,
|
|
ctx: &Context<'_>,
|
|
item: CreateItemDto,
|
|
) -> anyhow::Result<CreatedItem> {
|
|
let services_register = ctx.data_unchecked::<ServiceRegister>();
|
|
|
|
let created_item = services_register.item_service.add_item(item).await?;
|
|
|
|
Ok(CreatedItem {
|
|
id: created_item.id,
|
|
})
|
|
}
|
|
}
|
|
|
|
pub struct QueryRoot;
|
|
|
|
#[Object]
|
|
impl QueryRoot {
|
|
// Items
|
|
async fn get_item(&self, ctx: &Context<'_>, query: GetItemQuery) -> anyhow::Result<Item> {
|
|
let item = ctx
|
|
.data_unchecked::<ServiceRegister>()
|
|
.item_service
|
|
.get_item(query)
|
|
.await?;
|
|
|
|
Ok(Item::from(item))
|
|
}
|
|
|
|
async fn get_items(
|
|
&self,
|
|
ctx: &Context<'_>,
|
|
query: GetItemsQuery,
|
|
) -> anyhow::Result<Vec<Item>> {
|
|
let items = ctx
|
|
.data_unchecked::<ServiceRegister>()
|
|
.item_service
|
|
.get_items(query)
|
|
.await?;
|
|
|
|
Ok(items.iter().map(|i| Item::from(i.clone())).collect())
|
|
}
|
|
|
|
// Projects
|
|
async fn get_project(
|
|
&self,
|
|
ctx: &Context<'_>,
|
|
query: GetProjectQuery,
|
|
) -> anyhow::Result<ProjectDto> {
|
|
ctx.data_unchecked::<ServiceRegister>()
|
|
.project_service
|
|
.get_project(query)
|
|
.await
|
|
}
|
|
|
|
async fn get_projects(
|
|
&self,
|
|
ctx: &Context<'_>,
|
|
query: GetProjectsQuery,
|
|
) -> anyhow::Result<Vec<ProjectDto>> {
|
|
ctx.data_unchecked::<ServiceRegister>()
|
|
.project_service
|
|
.get_projects(query)
|
|
.await
|
|
}
|
|
}
|