use std::collections::HashMap;
use serde::{Deserialize, Serialize};
use crate::client::{get_owner, Client, Response};
use crate::error::Result;
use crate::serde_util::null_to_default;
#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "camelCase", default)]
pub struct Enforcer {
pub owner: String,
pub name: String,
pub created_time: String,
pub updated_time: String,
pub display_name: String,
pub description: String,
pub model: String,
pub adapter: String,
#[serde(deserialize_with = "null_to_default")]
pub model_cfg: HashMap<String, String>,
}
impl Client {
pub async fn get_enforcers(&self) -> Result<Vec<Enforcer>> {
self.get_list(
"get-enforcers",
&[("owner", &self.config.organization_name)],
)
.await
}
pub async fn get_pagination_enforcers(
&self,
p: i32,
page_size: i32,
query: &[(&str, &str)],
) -> Result<(Vec<Enforcer>, i32)> {
self.get_pagination(
"get-enforcers",
&self.config.organization_name,
p,
page_size,
query,
)
.await
}
pub async fn get_enforcer(&self, name: &str) -> Result<Option<Enforcer>> {
self.get_object("get-enforcer", &[("id", &self.get_id(name))])
.await
}
pub async fn add_enforcer(&self, enforcer: &Enforcer) -> Result<bool> {
Ok(self.modify_enforcer("add-enforcer", enforcer, &[]).await?.1)
}
pub async fn update_enforcer(&self, enforcer: &Enforcer) -> Result<bool> {
Ok(self
.modify_enforcer("update-enforcer", enforcer, &[])
.await?
.1)
}
pub async fn delete_enforcer(&self, enforcer: &Enforcer) -> Result<bool> {
Ok(self
.modify_enforcer("delete-enforcer", enforcer, &[])
.await?
.1)
}
async fn modify_enforcer(
&self,
action: &str,
enforcer: &Enforcer,
columns: &[&str],
) -> Result<(Response, bool)> {
let mut enforcer = enforcer.clone();
enforcer.owner = get_owner(&enforcer.owner, &self.config.organization_name);
let id = format!("{}/{}", enforcer.owner, enforcer.name);
self.modify_object(action, &id, &enforcer, columns).await
}
}