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