92 lines
3.6 KiB
Rust
92 lines
3.6 KiB
Rust
use async_trait::async_trait;
|
|
use sqlx::Executor;
|
|
use sqlx::postgres::PgQueryResult;
|
|
use cove_net_common::id::SnowflakeID;
|
|
use crate::{CoveDB, CoveDBImpl, CoveDbError};
|
|
use crate::part::{BindQueryBuilder, SqlPart};
|
|
use crate::query::{PartialQueryResult, QueryResult};
|
|
use crate::rows::{DeletableRow, InsertableRow, SelectableRow, TableRow, WhereRow};
|
|
use crate::rows::user::{PartialUserRow, UserRow};
|
|
|
|
#[async_trait]
|
|
pub trait UserQueries: CoveDBImpl {
|
|
|
|
async fn create_user(&self, user_row: UserRow) -> Result<QueryResult<UserRow>, CoveDbError> {
|
|
let mut query_builder = BindQueryBuilder::new();
|
|
user_row.insert().encode(&mut query_builder)?;
|
|
|
|
let query = query_builder.to_query();
|
|
let query = user_row.bind(query)?;
|
|
|
|
let res = self.run_query::<PgQueryResult>(query.sql_query).await?;
|
|
|
|
Ok(QueryResult::new(user_row, Some(res)))
|
|
}
|
|
|
|
async fn get_user_by_name_and_discrim(&self, name: impl Into<String> + Send, discriminator: impl Into<String> + Send) -> Result<PartialQueryResult<PartialUserRow>, CoveDbError> {
|
|
let user_request_row = PartialUserRow {
|
|
username: Some(name.into()),
|
|
discriminator: Some(discriminator.into()),
|
|
..Default::default()
|
|
};
|
|
|
|
let mut query_builder = BindQueryBuilder::new();
|
|
user_request_row.select(vec!["id", "username", "discriminator"]).encode(&mut query_builder)?;
|
|
let sql_where = user_request_row.where_all();
|
|
sql_where.encode(&mut query_builder)?;
|
|
|
|
let query = user_request_row.bind(sql_where, query_builder.to_query())?;
|
|
|
|
let out_partial_row: <UserRow as TableRow>::PartialRow = self.get_pool().fetch_one(query.sql_query).await?.into();
|
|
|
|
Ok(PartialQueryResult::new(out_partial_row, None))
|
|
}
|
|
|
|
async fn get_user_by_id(&self, user_id: SnowflakeID) -> Result<PartialQueryResult<PartialUserRow>, CoveDbError> {
|
|
let user_request_row = PartialUserRow {
|
|
id: Some(user_id),
|
|
..Default::default()
|
|
};
|
|
|
|
let mut query_builder = BindQueryBuilder::new();
|
|
user_request_row.select(vec!["id", "username", "discriminator"]).encode(&mut query_builder)?;
|
|
let sql_where = user_request_row.where_all();
|
|
sql_where.encode(&mut query_builder)?;
|
|
|
|
let query = user_request_row.bind(sql_where, query_builder.to_query())?;
|
|
|
|
let out_partial_row: <UserRow as TableRow>::PartialRow = self.get_pool().fetch_one(query.sql_query).await?.into();
|
|
|
|
Ok(PartialQueryResult::new(out_partial_row, None))
|
|
}
|
|
|
|
async fn delete_user_by_id(&self, user_id: SnowflakeID) -> Result<QueryResult<UserRow>, CoveDbError> {
|
|
let user_delete_row = PartialUserRow {
|
|
id: Some(user_id),
|
|
..Default::default()
|
|
};
|
|
|
|
let mut query_builder = BindQueryBuilder::new();
|
|
user_delete_row.select(vec!["*"]).encode(&mut query_builder)?;
|
|
let sql_where = user_delete_row.where_all();
|
|
sql_where.encode(&mut query_builder)?;
|
|
let query = user_delete_row.bind(sql_where, query_builder.to_query())?;
|
|
|
|
let out_val: UserRow = self.get_pool().fetch_one(query.sql_query).await?.try_into()?;
|
|
|
|
let mut query_builder = BindQueryBuilder::new();
|
|
|
|
user_delete_row.delete().encode(&mut query_builder)?;
|
|
let sql_where = user_delete_row.where_all();
|
|
sql_where.encode(&mut query_builder)?;
|
|
|
|
let query = user_delete_row.bind(sql_where, query_builder.to_query())?;
|
|
|
|
let res = self.run_query::<PgQueryResult>(query.sql_query).await?;
|
|
|
|
Ok(QueryResult::new(out_val, Some(res)))
|
|
}
|
|
}
|
|
|
|
#[async_trait]
|
|
impl UserQueries for CoveDB {} |