Skip to main content

openlark_workflow/v2/task/subtask/
list.rs

1//! 获取任务的子任务列表
2//!
3//! docPath: https://open.feishu.cn/document/server-docs/docs/task-v2/task-subtask/list
4
5use 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/// 获取子任务列表响应
16#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
17pub struct ListSubtasksResponse {
18    /// 是否还有更多项
19    #[serde(default)]
20    pub has_more: bool,
21
22    /// 分页标记
23    #[serde(skip_serializing_if = "Option::is_none")]
24    pub page_token: Option<String>,
25
26    /// 总数
27    #[serde(skip_serializing_if = "Option::is_none")]
28    pub total: Option<i32>,
29
30    /// 子任务列表
31    #[serde(default)]
32    pub items: Vec<TaskItem>,
33}
34
35/// 获取子任务列表请求
36#[derive(Debug, Clone)]
37pub struct ListSubtasksRequest {
38    /// 配置信息
39    config: Arc<Config>,
40    /// 父任务 GUID
41    task_guid: String,
42    /// 分页大小
43    page_size: Option<i32>,
44    /// 分页标记
45    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    /// 设置分页大小
59    pub fn page_size(mut self, page_size: i32) -> Self {
60        self.page_size = Some(page_size);
61        self
62    }
63
64    /// 设置分页标记
65    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    /// 执行请求
71    pub async fn execute(self) -> SDKResult<ListSubtasksResponse> {
72        self.execute_with_options(openlark_core::req_option::RequestOption::default())
73            .await
74    }
75
76    /// 执行请求(带选项)
77    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        // 构建查询参数
85        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}