109 lines
2.9 KiB
Rust
109 lines
2.9 KiB
Rust
use super::PermissionsSchema;
|
|
use crate::{
|
|
get_id, make_thing, query_list_with_meta, AppState, MetaRequestDto, ResourceEnum,
|
|
ResponseListSuccessDto,
|
|
};
|
|
use anyhow::{bail, Result};
|
|
|
|
pub struct PermissionsRepository<'a> {
|
|
state: &'a AppState,
|
|
}
|
|
|
|
impl<'a> PermissionsRepository<'a> {
|
|
pub fn new(state: &'a AppState) -> Self {
|
|
Self { state }
|
|
}
|
|
|
|
pub async fn query_permission_list(
|
|
&self,
|
|
meta: MetaRequestDto,
|
|
) -> Result<ResponseListSuccessDto<Vec<PermissionsSchema>>> {
|
|
let mut conditions = vec!["is_deleted = false".into()];
|
|
if meta.search.is_some() {
|
|
conditions.push("string::contains(name, $search)".into());
|
|
}
|
|
if meta.filter_by.is_some() && meta.filter.is_some() {
|
|
let filter_by = meta.filter_by.as_ref().unwrap();
|
|
conditions.push(format!("{} = $filter", filter_by));
|
|
}
|
|
query_list_with_meta(
|
|
&self.state.surrealdb_ws,
|
|
&ResourceEnum::Permissions.to_string(),
|
|
&meta,
|
|
conditions,
|
|
)
|
|
.await
|
|
}
|
|
|
|
pub async fn query_permission_by_id(
|
|
&self,
|
|
id: String,
|
|
) -> Result<PermissionsSchema> {
|
|
let db = &self.state.surrealdb_ws;
|
|
let result: Option<PermissionsSchema> = db
|
|
.select((ResourceEnum::Permissions.to_string(), id.clone()))
|
|
.await?;
|
|
match result {
|
|
Some(permission) if !permission.is_deleted => Ok(permission),
|
|
_ => bail!("Permission not found"),
|
|
}
|
|
}
|
|
|
|
pub async fn query_create_permission(
|
|
&self,
|
|
data: PermissionsSchema,
|
|
) -> Result<String> {
|
|
let db = &self.state.surrealdb_ws;
|
|
let record: Option<PermissionsSchema> = db
|
|
.create(ResourceEnum::Permissions.to_string())
|
|
.content(data)
|
|
.await?;
|
|
match record {
|
|
Some(_) => Ok("Success create permission".into()),
|
|
None => bail!("Failed to create permission"),
|
|
}
|
|
}
|
|
|
|
pub async fn query_update_permission(
|
|
&self,
|
|
data: PermissionsSchema,
|
|
) -> Result<String> {
|
|
let db = &self.state.surrealdb_ws;
|
|
let record_key = get_id(&data.id)?;
|
|
let existing = self.query_permission_by_id(data.id.id.to_raw()).await?;
|
|
if existing.is_deleted {
|
|
bail!("Permission already deleted");
|
|
}
|
|
let merged = PermissionsSchema {
|
|
created_at: existing.created_at,
|
|
..data.clone()
|
|
};
|
|
let record: Option<PermissionsSchema> =
|
|
db.update(record_key).merge(merged).await?;
|
|
match record {
|
|
Some(_) => Ok("Success update permission".into()),
|
|
None => bail!("Failed to update permission"),
|
|
}
|
|
}
|
|
|
|
pub async fn query_delete_permission(&self, id: String) -> Result<String> {
|
|
let db = &self.state.surrealdb_ws;
|
|
let permission_id = make_thing(&ResourceEnum::Permissions.to_string(), &id);
|
|
let permission = self
|
|
.query_permission_by_id(permission_id.id.to_raw())
|
|
.await?;
|
|
if permission.is_deleted {
|
|
bail!("Permission already deleted");
|
|
}
|
|
let record_key = get_id(&permission.id)?;
|
|
let record: Option<PermissionsSchema> = db
|
|
.update(record_key)
|
|
.merge(serde_json::json!({ "is_deleted": true }))
|
|
.await?;
|
|
match record {
|
|
Some(_) => Ok("Success delete permission".into()),
|
|
None => bail!("Failed to delete permission"),
|
|
}
|
|
}
|
|
}
|