openlark_workflow/v2/task/subtask/
list.rs1use crate::common::{api_endpoints::TaskApiV2, api_utils::*};
6use crate::v2::task::models::TaskItem;
7use openlark_core::{
8 api::{ApiRequest, ApiResponseTrait, ResponseFormat},
9 config::Config,
10 SDKResult,
11};
12use serde::{Deserialize, Serialize};
13use std::sync::Arc;
14
15#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
17pub struct ListSubtasksResponse {
18 #[serde(default)]
20 pub has_more: bool,
21
22 #[serde(skip_serializing_if = "Option::is_none")]
24 pub page_token: Option<String>,
25
26 #[serde(skip_serializing_if = "Option::is_none")]
28 pub total: Option<i32>,
29
30 #[serde(default)]
32 pub items: Vec<TaskItem>,
33}
34
35#[derive(Debug, Clone)]
37pub struct ListSubtasksRequest {
38 config: Arc<Config>,
40 task_guid: String,
42 page_size: Option<i32>,
44 page_token: Option<String>,
46}
47
48impl ListSubtasksRequest {
49 pub fn new(config: Arc<Config>, task_guid: impl Into<String>) -> Self {
50 Self {
51 config,
52 task_guid: task_guid.into(),
53 page_size: None,
54 page_token: None,
55 }
56 }
57
58 pub fn page_size(mut self, page_size: i32) -> Self {
60 self.page_size = Some(page_size);
61 self
62 }
63
64 pub fn page_token(mut self, page_token: impl Into<String>) -> Self {
66 self.page_token = Some(page_token.into());
67 self
68 }
69
70 pub async fn execute(self) -> SDKResult<ListSubtasksResponse> {
72 self.execute_with_options(openlark_core::req_option::RequestOption::default())
73 .await
74 }
75
76 pub async fn execute_with_options(
78 self,
79 option: openlark_core::req_option::RequestOption,
80 ) -> SDKResult<ListSubtasksResponse> {
81 let api_endpoint = TaskApiV2::SubtaskList(self.task_guid.clone());
82 let mut request = ApiRequest::<ListSubtasksResponse>::get(api_endpoint.to_url());
83
84 if let Some(page_size) = self.page_size {
86 request = request.query("page_size", page_size.to_string());
87 }
88 if let Some(page_token) = &self.page_token {
89 request = request.query("page_token", page_token);
90 }
91
92 let response =
93 openlark_core::http::Transport::request(request, &self.config, Some(option)).await?;
94 extract_response_data(response, "获取子任务列表")
95 }
96}
97
98impl ApiResponseTrait for ListSubtasksResponse {
99 fn data_format() -> ResponseFormat {
100 ResponseFormat::Data
101 }
102}
103
104#[cfg(test)]
105#[allow(unused_imports)]
106mod tests {
107 use std::sync::Arc;
108
109 use super::*;
110
111 #[test]
112 fn test_list_subtasks_request() {
113 let config = openlark_core::config::Config::builder()
114 .app_id("test")
115 .app_secret("test")
116 .build();
117
118 let request = ListSubtasksRequest::new(Arc::new(config), "parent_task_123")
119 .page_size(20)
120 .page_token("next_page_token");
121
122 assert_eq!(request.task_guid, "parent_task_123");
123 assert_eq!(request.page_size, Some(20));
124 assert_eq!(request.page_token, Some("next_page_token".to_string()));
125 }
126
127 #[test]
128 fn test_list_subtasks_api_v2_url() {
129 let endpoint = TaskApiV2::SubtaskList("task_123".to_string());
130 assert_eq!(
131 endpoint.to_url(),
132 "/open-apis/task/v2/tasks/task_123/subtasks"
133 );
134 }
135}