use crate::error::Result;
use crate::domain::model::RolePermission;
use crate::intern::rbac::RbacService;
impl RbacService {
#[tracing::instrument(
name = "auth.insert_role_permission",
skip(self, role_id, permission_id)
)]
pub async fn insert_role_permission(&self, role_id: &str, permission_id: &str) -> Result<()> {
let role_permission = RolePermission::new(role_id, permission_id);
self.role_permission_repository
.insert(role_permission)
.await
}
#[tracing::instrument(
name = "auth.insert_role_permissions",
skip(self, role_id, permission_ids)
)]
pub async fn upsert_role_permissions(
&self,
role_id: &str,
permission_ids: Vec<String>,
) -> Result<()> {
let role_permissions: Vec<RolePermission> = permission_ids
.iter()
.map(|p_id| RolePermission::new(role_id, p_id))
.collect();
self.role_permission_repository
.upsert_many(role_permissions)
.await
}
#[tracing::instrument(
name = "auth.find_role_permission", skip(self), fields(user.id = user_id)
)]
pub async fn find_role_permissions(&self, user_id: &str) -> Result<RolePermission> {
self.role_permission_repository.find(user_id).await
}
}