casdoor_sdk_rust/authz/
mod.rs1mod 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}