openlark_workflow/v2/task/subtask/
list.rs1use crate::common::api_endpoints::TaskApiV2;
6use crate::v2::task::models::TaskItem;
7use openlark_core::{
8 SDKResult,
9 api::{ApiRequest, ApiResponseTrait, ResponseFormat},
10 config::Config,
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 {
51 Self {
52 config,
53 task_guid: task_guid.into(),
54 page_size: None,
55 page_token: None,
56 }
57 }
58
59 pub fn page_size(mut self, page_size: i32) -> Self {
61 self.page_size = Some(page_size);
62 self
63 }
64
65 pub fn page_token(mut self, page_token: impl Into<String>) -> Self {
67 self.page_token = Some(page_token.into());
68 self
69 }
70
71 pub async fn execute(self) -> SDKResult<ListSubtasksResponse> {
73 self.execute_with_options(openlark_core::req_option::RequestOption::default())
74 .await
75 }
76
77 pub async fn execute_with_options(
79 self,
80 option: openlark_core::req_option::RequestOption,
81 ) -> SDKResult<ListSubtasksResponse> {
82 let api_endpoint = TaskApiV2::SubtaskList(self.task_guid.clone());
83 let mut request = ApiRequest::<ListSubtasksResponse>::get(api_endpoint.to_url());
84
85 if let Some(page_size) = self.page_size {
87 request = request.query("page_size", page_size.to_string());
88 }
89 if let Some(page_token) = &self.page_token {
90 request = request.query("page_token", page_token);
91 }
92
93 openlark_core::http::Transport::request_typed(
94 request,
95 &self.config,
96 Some(option),
97 "获取子任务列表",
98 )
99 .await
100 }
101}
102
103impl ApiResponseTrait for ListSubtasksResponse {
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_list_subtasks_request() {
118 let config = openlark_core::config::Config::builder()
119 .app_id("test")
120 .app_secret("test")
121 .build();
122
123 let request = ListSubtasksRequest::new(Arc::new(config), "parent_task_123")
124 .page_size(20)
125 .page_token("next_page_token");
126
127 assert_eq!(request.task_guid, "parent_task_123");
128 assert_eq!(request.page_size, Some(20));
129 assert_eq!(request.page_token, Some("next_page_token".to_string()));
130 }
131
132 #[test]
133 fn test_list_subtasks_api_v2_url() {
134 let endpoint = TaskApiV2::SubtaskList("task_123".to_string());
135 assert_eq!(
136 endpoint.to_url(),
137 "/open-apis/task/v2/tasks/task_123/subtasks"
138 );
139 }
140}