casdoor_sdk_rust/authz/
mod.rs

1mod models;
2
3pub use models::*;
4
5use crate::{Body, Method, QueryArgs, QueryResult, Sdk, SdkResult, NO_BODY};
6
7impl Sdk {
8    pub async fn get_enforcers(&self, query_args: QueryArgs) -> SdkResult<QueryResult<Enforcer>> {
9        self.get_models(None, query_args).await
10    }
11    pub async fn enforce(&self, args: EnforceArgs) -> SdkResult<EnforceResult> {
12        let allow_list = self
13            .request::<Vec<bool>, Vec<String>>(
14                Method::POST,
15                self.get_url_path("enforce", true, args.query)?,
16                Body::Json(&args.casbin_request),
17            )
18            .await?
19            .into_data_default()?;
20        Ok(EnforceResult {
21            allow: allow_list.contains(&true),
22        })
23    }
24    pub async fn batch_enforce(&self, args: BatchEnforceArgs) -> SdkResult<BatchEnforceResult> {
25        let allow_lists = self
26            .request::<Vec<Vec<bool>>, Vec<String>>(
27                Method::POST,
28                self.get_url_path("batch-enforce", true, args.query)?,
29                Body::Json(&args.casbin_requests),
30            )
31            .await?
32            .into_data_default()?;
33        Ok(BatchEnforceResult {
34            allow_list: allow_lists.into_iter().map(|list| list.contains(&true)).collect(),
35        })
36    }
37    pub async fn get_policies(&self, enforcer_name: String) -> SdkResult<Vec<CasbinRule>> {
38        self.request_data(
39            Method::GET,
40            self.get_url_path("get-policies", false, [("id", self.id(&enforcer_name))])?,
41            NO_BODY,
42        )
43        .await?
44        .into_data_default()
45    }
46    pub async fn add_policy(&self, enforcer_name: String, policy: &CasbinRule) -> SdkResult<bool> {
47        self.request_data(
48            Method::POST,
49            self.get_url_path("add-policy", false, [("id", self.id(&enforcer_name))])?,
50            Body::Json(policy),
51        )
52        .await?
53        .into_data_default()
54    }
55    pub async fn remove_policy(&self, enforcer_name: String, policy: &CasbinRule) -> SdkResult<bool> {
56        self.request_data(
57            Method::POST,
58            self.get_url_path("remove-policy", false, [("id", self.id(&enforcer_name))])?,
59            Body::Json(policy),
60        )
61        .await?
62        .into_data_default()
63    }
64    pub async fn update_policy(&self, enforcer_name: String, old_policy: &CasbinRule, new_policy: &CasbinRule) -> SdkResult<bool> {
65        self.request_data(
66            Method::POST,
67            self.get_url_path("update-policy", false, [("id", self.id(&enforcer_name))])?,
68            Body::Json(&[old_policy, new_policy]),
69        )
70        .await?
71        .into_data_default()
72    }
73    pub async fn get_permissions(&self, query_args: QueryArgs) -> SdkResult<QueryResult<Permission>> {
74        self.get_models(None, query_args).await
75    }
76    pub async fn get_permissions_by_submitter(&self) -> SdkResult<QueryResult<Permission>> {
77        self.request(Method::GET, self.get_url_path("get-permissions-by-submitter", false, ())?, NO_BODY)
78            .await?
79            .into_result_default()
80            .map(Into::into)
81    }
82    pub async fn get_permissions_by_role(&self, role_name: &str) -> SdkResult<QueryResult<Permission>> {
83        self.request(
84            Method::GET,
85            self.get_url_path("get-permissions-by-role", false, [("id", self.id(role_name))])?,
86            NO_BODY,
87        )
88        .await?
89        .into_result_default()
90        .map(Into::into)
91    }
92    pub async fn get_roles(&self, query_args: QueryArgs) -> SdkResult<QueryResult<Role>> {
93        self.get_models(None, query_args).await
94    }
95    pub async fn get_roles_by_user(&self, user_id: &str) -> SdkResult<Vec<String>> {
96        self.request_data(Method::GET, self.get_url_path("get-all-roles", false, [("userId", user_id)])?, NO_BODY)
97            .await?
98            .into_data_default()
99    }
100}