use openlark_core::{
SDKResult,
api::{ApiRequest, ApiResponseTrait, ResponseFormat},
config::Config,
http::Transport,
req_option::RequestOption,
};
use serde::{Deserialize, Serialize};
#[derive(Debug, Clone)]
pub struct CollaborationRuleUpdateRequestBuilder {
config: Config,
collaboration_rule_id: String,
name: Option<String>,
search_visible_scope_type: Option<String>,
search_visible_scope_user_ids: Vec<String>,
search_visible_scope_department_ids: Vec<String>,
}
impl CollaborationRuleUpdateRequestBuilder {
pub fn new(config: Config, collaboration_rule_id: impl Into<String>) -> Self {
Self {
config,
collaboration_rule_id: collaboration_rule_id.into(),
name: None,
search_visible_scope_type: None,
search_visible_scope_user_ids: Vec::new(),
search_visible_scope_department_ids: Vec::new(),
}
}
pub fn name(mut self, name: impl Into<String>) -> Self {
self.name = Some(name.into());
self
}
pub fn search_visible_scope_type(mut self, scope_type: impl Into<String>) -> Self {
self.search_visible_scope_type = Some(scope_type.into());
self
}
pub fn search_visible_scope_user_id(mut self, user_id: impl Into<String>) -> Self {
self.search_visible_scope_user_ids.push(user_id.into());
self
}
pub fn search_visible_scope_department_id(mut self, department_id: impl Into<String>) -> Self {
self.search_visible_scope_department_ids
.push(department_id.into());
self
}
pub async fn execute(self) -> SDKResult<CollaborationRuleUpdateResponse> {
self.execute_with_options(RequestOption::default()).await
}
pub async fn execute_with_options(
self,
option: RequestOption,
) -> SDKResult<CollaborationRuleUpdateResponse> {
let url = format!(
"/open-apis/directory/v1/collaboration_rules/{}",
self.collaboration_rule_id
);
use serde_json::json;
let request = json!({
"name": self.name,
"search_visible_scope_type": self.search_visible_scope_type,
"search_visible_scope_user_ids": self.search_visible_scope_user_ids,
"search_visible_scope_department_ids": self.search_visible_scope_department_ids,
});
let mut api_request = ApiRequest::<CollaborationRuleUpdateResponse>::put(&url);
api_request = api_request.body(request);
let resp = Transport::request(api_request, &self.config, Some(option)).await?;
resp.data.ok_or_else(|| {
openlark_core::error::validation_error("更新可搜可见规则", "响应数据为空")
})
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
pub struct CollaborationRuleUpdateResponse {
#[serde(rename = "collaboration_rule_id")]
pub collaboration_rule_id: String,
#[serde(rename = "name")]
pub name: String,
#[serde(rename = "updated_at")]
pub updated_at: i64,
}
impl ApiResponseTrait for CollaborationRuleUpdateResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[deprecated(
note = "renamed to CollaborationRuleUpdateRequestBuilder, will be removed in v1.0 (#271)"
)]
pub type CollaborationRuleUpdateBuilder = CollaborationRuleUpdateRequestBuilder;
#[cfg(test)]
mod tests {
use super::*;
#[tokio::test]
async fn test_update_collaboration_rule_returns_data_on_success() {
use serde_json::json;
use wiremock::MockServer;
use wiremock::matchers::{method, path};
use wiremock::{Mock, ResponseTemplate};
let server = MockServer::start().await;
Mock::given(method("PUT"))
.and(path("/open-apis/directory/v1/collaboration_rules/rule_001"))
.respond_with(ResponseTemplate::new(200).set_body_json(json!({
"code": 0,
"msg": "success",
"data": {
"collaboration_rule_id": "rule_001",
"name": "All Visible",
"updated_at": 1700000000
}
})))
.mount(&server)
.await;
let config = Config::builder()
.app_id("ci_app_id")
.app_secret("ci_app_secret")
.base_url(server.uri())
.enable_token_cache(false)
.build();
let resp = CollaborationRuleUpdateRequestBuilder::new(config, "rule_001")
.name("All Visible")
.search_visible_scope_type("all")
.execute()
.await
.expect("更新可搜可见规则应成功");
assert_eq!(resp.collaboration_rule_id, "rule_001");
assert_eq!(resp.name, "All Visible");
assert_eq!(resp.updated_at, 1700000000);
let received = server.received_requests().await.unwrap_or_default();
assert_eq!(received.len(), 1);
assert_eq!(
received[0].url.path(),
"/open-apis/directory/v1/collaboration_rules/rule_001"
);
assert_eq!(received[0].method, "PUT");
}
}