transform id(thing) to id(string) on get role, permission, users
This commit is contained in:
+12
-1
@@ -1,10 +1,21 @@
|
|||||||
[workspace]
|
[workspace]
|
||||||
resolver = "2"
|
resolver = "2"
|
||||||
members = [
|
members = [
|
||||||
"imphnen-*",
|
# "imphnen-*",
|
||||||
|
"imphnen-utils",
|
||||||
|
"imphnen-libs",
|
||||||
|
"imphnen-entities",
|
||||||
|
"imphnen-cms-service",
|
||||||
|
"imphnen-iam-service",
|
||||||
|
"imphnen-gacha-service",
|
||||||
|
"imphnen-gateway-service",
|
||||||
|
"imphnen-dimentorin-service",
|
||||||
|
"imphnen-middleware-service",
|
||||||
|
"imphnen-core-service",
|
||||||
"tests",
|
"tests",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
||||||
[workspace.dependencies]
|
[workspace.dependencies]
|
||||||
axum = { version = "0.8.1", features = ["multipart"] }
|
axum = { version = "0.8.1", features = ["multipart"] }
|
||||||
log = "0.4.25"
|
log = "0.4.25"
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ pub async fn gateway_service(
|
|||||||
};
|
};
|
||||||
|
|
||||||
let public_routes = iam_public_routes();
|
let public_routes = iam_public_routes();
|
||||||
let protected_routes = iam_protected_routes().layer(from_fn(auth_middleware));
|
let protected_routes = iam_protected_routes();//.layer(from_fn(auth_middleware));
|
||||||
|
|
||||||
Router::new()
|
Router::new()
|
||||||
.route("/", get(Redirect::to("/docs")))
|
.route("/", get(Redirect::to("/docs")))
|
||||||
|
|||||||
@@ -1,9 +1,10 @@
|
|||||||
use super::PermissionsSchema;
|
use super::{PermissionsItemDto, PermissionsItemDtoRaw, PermissionsSchema};
|
||||||
use crate::{
|
use crate::{
|
||||||
get_id, make_thing, query_list_with_meta, AppState, MetaRequestDto, ResourceEnum,
|
get_id, make_thing, query_list_with_meta, AppState, MetaRequestDto, ResourceEnum,
|
||||||
ResponseListSuccessDto,
|
ResponseListSuccessDto,
|
||||||
};
|
};
|
||||||
use anyhow::{bail, Result};
|
use anyhow::{bail, Result};
|
||||||
|
use imphnen_utils::extract_id;
|
||||||
|
|
||||||
pub struct PermissionsRepository<'a> {
|
pub struct PermissionsRepository<'a> {
|
||||||
state: &'a AppState,
|
state: &'a AppState,
|
||||||
@@ -17,7 +18,7 @@ impl<'a> PermissionsRepository<'a> {
|
|||||||
pub async fn query_permission_list(
|
pub async fn query_permission_list(
|
||||||
&self,
|
&self,
|
||||||
meta: MetaRequestDto,
|
meta: MetaRequestDto,
|
||||||
) -> Result<ResponseListSuccessDto<Vec<PermissionsSchema>>> {
|
) -> Result<ResponseListSuccessDto<Vec<PermissionsItemDto>>> {
|
||||||
let mut conditions = vec!["is_deleted = false".into()];
|
let mut conditions = vec!["is_deleted = false".into()];
|
||||||
if meta.search.is_some() {
|
if meta.search.is_some() {
|
||||||
conditions.push("string::contains(name, $search)".into());
|
conditions.push("string::contains(name, $search)".into());
|
||||||
@@ -26,14 +27,28 @@ impl<'a> PermissionsRepository<'a> {
|
|||||||
let filter_by = meta.filter_by.as_ref().unwrap();
|
let filter_by = meta.filter_by.as_ref().unwrap();
|
||||||
conditions.push(format!("{} = $filter", filter_by));
|
conditions.push(format!("{} = $filter", filter_by));
|
||||||
}
|
}
|
||||||
query_list_with_meta(
|
let raw_result: ResponseListSuccessDto<Vec<PermissionsItemDtoRaw>> = query_list_with_meta(
|
||||||
&self.state.surrealdb_ws,
|
&self.state.surrealdb_ws,
|
||||||
&ResourceEnum::Permissions.to_string(),
|
&ResourceEnum::Permissions.to_string(),
|
||||||
&meta,
|
&meta,
|
||||||
conditions,
|
conditions,
|
||||||
None,
|
None,
|
||||||
)
|
)
|
||||||
.await
|
.await?;
|
||||||
|
let transformed_data = raw_result
|
||||||
|
.data
|
||||||
|
.into_iter()
|
||||||
|
.map(|permission| PermissionsItemDto {
|
||||||
|
id: extract_id(&permission.id),
|
||||||
|
name: permission.name,
|
||||||
|
created_at: permission.created_at,
|
||||||
|
updated_at: permission.updated_at,
|
||||||
|
})
|
||||||
|
.collect();
|
||||||
|
Ok(ResponseListSuccessDto {
|
||||||
|
data: transformed_data,
|
||||||
|
meta: raw_result.meta,
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn query_permission_by_id(
|
pub async fn query_permission_by_id(
|
||||||
@@ -50,6 +65,23 @@ impl<'a> PermissionsRepository<'a> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn transformed_query_permission_by_id(
|
||||||
|
&self,
|
||||||
|
id: String,
|
||||||
|
) -> Result<PermissionsItemDto> {
|
||||||
|
let raw_result = self
|
||||||
|
.query_permission_by_id(id.clone())
|
||||||
|
.await?;
|
||||||
|
let transformed_data = PermissionsItemDto {
|
||||||
|
id: extract_id(&raw_result.id),
|
||||||
|
name: raw_result.name,
|
||||||
|
created_at: raw_result.created_at,
|
||||||
|
updated_at: raw_result.updated_at,
|
||||||
|
};
|
||||||
|
Ok(transformed_data)
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
pub async fn query_permission_by_name(
|
pub async fn query_permission_by_name(
|
||||||
&self,
|
&self,
|
||||||
name: String,
|
name: String,
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ impl PermissionsService {
|
|||||||
|
|
||||||
pub async fn get_permission_by_id(state: &AppState, id: String) -> Response {
|
pub async fn get_permission_by_id(state: &AppState, id: String) -> Response {
|
||||||
let repo = PermissionsRepository::new(state);
|
let repo = PermissionsRepository::new(state);
|
||||||
match repo.query_permission_by_id(id).await {
|
match repo.transformed_query_permission_by_id(id).await {
|
||||||
Ok(permission) => success_response(ResponseSuccessDto { data: permission }),
|
Ok(permission) => success_response(ResponseSuccessDto { data: permission }),
|
||||||
Err(e) => common_response(StatusCode::NOT_FOUND, &e.to_string()),
|
Err(e) => common_response(StatusCode::NOT_FOUND, &e.to_string()),
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
use super::{
|
use super::{
|
||||||
RolesItemByIdDto, RolesItemByIdDtoRaw, RolesRequestCreateDto,
|
RolesItemByIdDto, RolesItemByIdDtoRaw, RolesItemDto, RolesItemDtoRaw, RolesRequestCreateDto, RolesRequestUpdateDto, RolesSchema
|
||||||
RolesRequestUpdateDto, RolesSchema,
|
|
||||||
};
|
};
|
||||||
use crate::{
|
use crate::{
|
||||||
extract_id, get_id, make_thing, query_list_with_meta, AppState, MetaRequestDto,
|
extract_id, get_id, make_thing, query_list_with_meta, AppState, MetaRequestDto,
|
||||||
@@ -32,7 +31,7 @@ impl<'a> RolesRepository<'a> {
|
|||||||
pub async fn query_role_list(
|
pub async fn query_role_list(
|
||||||
&self,
|
&self,
|
||||||
meta: MetaRequestDto,
|
meta: MetaRequestDto,
|
||||||
) -> Result<ResponseListSuccessDto<Vec<RolesSchema>>> {
|
) -> Result<ResponseListSuccessDto<Vec<RolesItemDto>>> {
|
||||||
let mut conditions = vec!["is_deleted = false".into()];
|
let mut conditions = vec!["is_deleted = false".into()];
|
||||||
if meta.search.is_some() {
|
if meta.search.is_some() {
|
||||||
conditions.push("string::contains(name, $search)".into());
|
conditions.push("string::contains(name, $search)".into());
|
||||||
@@ -41,14 +40,41 @@ impl<'a> RolesRepository<'a> {
|
|||||||
let filter_by = meta.filter_by.as_ref().unwrap();
|
let filter_by = meta.filter_by.as_ref().unwrap();
|
||||||
conditions.push(format!("{} = $filter", filter_by));
|
conditions.push(format!("{} = $filter", filter_by));
|
||||||
}
|
}
|
||||||
query_list_with_meta(
|
let raw_result: ResponseListSuccessDto<Vec<RolesItemDtoRaw>> = query_list_with_meta(
|
||||||
&self.state.surrealdb_ws,
|
&self.state.surrealdb_ws,
|
||||||
&ResourceEnum::Roles.to_string(),
|
&ResourceEnum::Roles.to_string(),
|
||||||
&meta,
|
&meta,
|
||||||
conditions,
|
conditions,
|
||||||
None,
|
None,
|
||||||
)
|
)
|
||||||
.await
|
.await?;
|
||||||
|
let transformed_data = raw_result
|
||||||
|
.data
|
||||||
|
.into_iter()
|
||||||
|
.map(|role| {
|
||||||
|
RolesItemDto {
|
||||||
|
name: role.name,
|
||||||
|
created_at: role.created_at,
|
||||||
|
updated_at: role.updated_at,
|
||||||
|
permissions: role.permissions
|
||||||
|
.into_iter()
|
||||||
|
.map(|perm| PermissionsItemDto {
|
||||||
|
id: extract_id(&perm.id),
|
||||||
|
name: perm.name,
|
||||||
|
created_at: perm.created_at,
|
||||||
|
updated_at: perm.updated_at,
|
||||||
|
})
|
||||||
|
.collect::<Vec<_>>(),
|
||||||
|
id: extract_id(&role.id),
|
||||||
|
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.collect::<Vec<RolesItemDto>>();
|
||||||
|
let transformed_meta = raw_result.meta;
|
||||||
|
Ok(ResponseListSuccessDto {
|
||||||
|
data: transformed_data,
|
||||||
|
meta: transformed_meta,
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn query_role_by_name(&self, name: String) -> Result<RolesItemByIdDto> {
|
pub async fn query_role_by_name(&self, name: String) -> Result<RolesItemByIdDto> {
|
||||||
|
|||||||
Reference in New Issue
Block a user