openlark_workflow/v2/tasklist/activity_subscription/
delete.rs1use crate::common::api_endpoints::TaskApiV2;
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 openlark_core::http::Transport::request_typed(
63 request,
64 &self.config,
65 Some(option),
66 "删除动态订阅",
67 )
68 .await
69 }
70}
71
72impl ApiResponseTrait for DeleteActivitySubscriptionResponse {
73 fn data_format() -> ResponseFormat {
74 ResponseFormat::Data
75 }
76}
77
78#[cfg(test)]
79#[allow(unused_imports)]
80mod tests {
81 use std::sync::Arc;
82
83 use super::*;
84
85 #[test]
86 fn test_delete_activity_subscription_request() {
87 let config = openlark_core::config::Config::builder()
88 .app_id("test")
89 .app_secret("test")
90 .build();
91
92 let request = DeleteActivitySubscriptionRequest::new(
93 Arc::new(config),
94 "tasklist_123",
95 "subscription_456",
96 );
97
98 assert_eq!(request.tasklist_guid, "tasklist_123");
99 assert_eq!(request.subscription_guid, "subscription_456");
100 }
101
102 #[test]
103 fn test_activity_subscription_delete_api_v2_url() {
104 let endpoint = TaskApiV2::ActivitySubscriptionDelete(
105 "tasklist_123".to_string(),
106 "subscription_456".to_string(),
107 );
108 assert_eq!(
109 endpoint.to_url(),
110 "/open-apis/task/v2/tasklists/tasklist_123/activity_subscriptions/subscription_456"
111 );
112 }
113}