openlark_workflow/v2/tasklist/activity_subscription/
delete.rs1use crate::common::{api_endpoints::TaskApiV2, api_utils::*};
6use crate::v2::tasklist::activity_subscription::models::DeleteActivitySubscriptionResponse;
7use openlark_core::{
8 api::{ApiRequest, ApiResponseTrait, ResponseFormat},
9 config::Config,
10 validate_required, SDKResult,
11};
12use std::sync::Arc;
13
14#[derive(Debug, Clone)]
16pub struct DeleteActivitySubscriptionRequest {
17 config: Arc<Config>,
19 tasklist_guid: String,
21 subscription_guid: String,
23}
24
25impl DeleteActivitySubscriptionRequest {
26 pub fn new(
27 config: Arc<Config>,
28 tasklist_guid: impl Into<String>,
29 subscription_guid: impl Into<String>,
30 ) -> Self {
31 Self {
32 config,
33 tasklist_guid: tasklist_guid.into(),
34 subscription_guid: subscription_guid.into(),
35 }
36 }
37
38 pub async fn execute(self) -> SDKResult<DeleteActivitySubscriptionResponse> {
40 self.execute_with_options(openlark_core::req_option::RequestOption::default())
41 .await
42 }
43
44 pub async fn execute_with_options(
46 self,
47 option: openlark_core::req_option::RequestOption,
48 ) -> SDKResult<DeleteActivitySubscriptionResponse> {
49 validate_required!(self.tasklist_guid.trim(), "任务清单GUID不能为空");
51 validate_required!(self.subscription_guid.trim(), "订阅GUID不能为空");
52
53 let api_endpoint = TaskApiV2::ActivitySubscriptionDelete(
54 self.tasklist_guid.clone(),
55 self.subscription_guid.clone(),
56 );
57 let request =
58 ApiRequest::<DeleteActivitySubscriptionResponse>::delete(api_endpoint.to_url());
59
60 let response =
61 openlark_core::http::Transport::request(request, &self.config, Some(option)).await?;
62 extract_response_data(response, "删除动态订阅")
63 }
64}
65
66impl ApiResponseTrait for DeleteActivitySubscriptionResponse {
67 fn data_format() -> ResponseFormat {
68 ResponseFormat::Data
69 }
70}
71
72#[cfg(test)]
73#[allow(unused_imports)]
74mod tests {
75 use std::sync::Arc;
76
77 use super::*;
78
79 #[test]
80 fn test_delete_activity_subscription_request() {
81 let config = openlark_core::config::Config::builder()
82 .app_id("test")
83 .app_secret("test")
84 .build();
85
86 let request = DeleteActivitySubscriptionRequest::new(
87 Arc::new(config),
88 "tasklist_123",
89 "subscription_456",
90 );
91
92 assert_eq!(request.tasklist_guid, "tasklist_123");
93 assert_eq!(request.subscription_guid, "subscription_456");
94 }
95
96 #[test]
97 fn test_activity_subscription_delete_api_v2_url() {
98 let endpoint = TaskApiV2::ActivitySubscriptionDelete(
99 "tasklist_123".to_string(),
100 "subscription_456".to_string(),
101 );
102 assert_eq!(
103 endpoint.to_url(),
104 "/open-apis/task/v2/tasklists/tasklist_123/activity_subscriptions/subscription_456"
105 );
106 }
107}