openlark_workflow/v2/tasklist/
add_members.rs1use crate::common::{api_endpoints::TaskApiV2, api_utils::*};
6use openlark_core::{
7 SDKResult,
8 api::{ApiRequest, ApiResponseTrait, ResponseFormat},
9 config::Config,
10 validate_required,
11};
12use serde::{Deserialize, Serialize};
13use std::sync::Arc;
14
15#[derive(Debug, Clone, Serialize, Default)]
17pub struct AddTasklistMembersBody {
18 pub members: Vec<String>,
20}
21
22#[derive(Debug, Clone, Deserialize)]
24pub struct TasklistMember {
25 pub member_id: String,
27 pub member_type: String,
29 pub added_at: String,
31}
32
33#[derive(Debug, Clone, Deserialize)]
35pub struct AddTasklistMembersResponse {
36 pub tasklist_guid: String,
38 #[serde(default)]
40 pub members: Vec<TasklistMember>,
41}
42
43#[derive(Debug, Clone)]
45pub struct AddTasklistMembersRequest {
46 config: Arc<Config>,
48 tasklist_guid: String,
50 body: AddTasklistMembersBody,
52}
53
54impl AddTasklistMembersRequest {
55 pub fn new(config: Arc<Config>, tasklist_guid: impl Into<String>) -> Self {
57 Self {
58 config,
59 tasklist_guid: tasklist_guid.into(),
60 body: AddTasklistMembersBody::default(),
61 }
62 }
63
64 pub fn members(mut self, members: Vec<String>) -> Self {
66 self.body.members = members;
67 self
68 }
69
70 pub fn add_member(mut self, member: impl Into<String>) -> Self {
72 self.body.members.push(member.into());
73 self
74 }
75
76 pub async fn execute(self) -> SDKResult<AddTasklistMembersResponse> {
78 self.execute_with_options(openlark_core::req_option::RequestOption::default())
79 .await
80 }
81
82 pub async fn execute_with_options(
84 self,
85 option: openlark_core::req_option::RequestOption,
86 ) -> SDKResult<AddTasklistMembersResponse> {
87 validate_required!(self.tasklist_guid.trim(), "任务清单GUID不能为空");
89 validate_required!(self.body.members, "成员列表不能为空");
90
91 let api_endpoint = TaskApiV2::TasklistAddMembers(self.tasklist_guid.clone());
92 let mut request = ApiRequest::<AddTasklistMembersResponse>::post(api_endpoint.to_url());
93
94 let request_body = &self.body;
95 request = request.body(serialize_params(request_body, "添加清单成员")?);
96
97 let response =
98 openlark_core::http::Transport::request(request, &self.config, Some(option)).await?;
99 extract_response_data(response, "添加清单成员")
100 }
101}
102
103impl ApiResponseTrait for AddTasklistMembersResponse {
104 fn data_format() -> ResponseFormat {
105 ResponseFormat::Data
106 }
107}
108
109#[cfg(test)]
110#[allow(unused_imports)]
111mod tests {
112 use std::sync::Arc;
113
114 use super::*;
115
116 #[test]
117 fn test_add_tasklist_members_builder() {
118 let config = Arc::new(
119 openlark_core::config::Config::builder()
120 .app_id("test")
121 .app_secret("test")
122 .build(),
123 );
124
125 let request = AddTasklistMembersRequest::new(config, "tasklist_123")
126 .members(vec!["user_1".to_string(), "user_2".to_string()]);
127
128 assert_eq!(request.tasklist_guid, "tasklist_123");
129 assert_eq!(request.body.members, vec!["user_1", "user_2"]);
130 }
131
132 #[test]
133 fn test_add_tasklist_member_single() {
134 let config = Arc::new(
135 openlark_core::config::Config::builder()
136 .app_id("test")
137 .app_secret("test")
138 .build(),
139 );
140
141 let request = AddTasklistMembersRequest::new(config, "tasklist_123")
142 .add_member("user_1")
143 .add_member("user_2");
144
145 assert_eq!(request.body.members, vec!["user_1", "user_2"]);
146 }
147
148 #[test]
149 fn test_tasklist_add_members_api_v2_url() {
150 let endpoint = TaskApiV2::TasklistAddMembers("tasklist_123".to_string());
151 assert_eq!(
152 endpoint.to_url(),
153 "/open-apis/task/v2/tasklists/tasklist_123/add_members"
154 );
155 }
156}