use crate::common::{api_endpoints::TaskApiV2, api_utils::*};
use crate::v2::task::models::CompleteTaskResponse;
use openlark_core::{
SDKResult,
api::{ApiRequest, ApiResponseTrait, ResponseFormat},
config::Config,
validate_required,
};
use std::sync::Arc;
#[derive(Debug, Clone)]
pub struct CompleteTaskRequest {
config: Arc<Config>,
task_guid: String,
}
impl CompleteTaskRequest {
pub fn new(config: Arc<Config>, task_guid: String) -> Self {
Self { config, task_guid }
}
pub async fn execute(self) -> SDKResult<CompleteTaskResponse> {
self.execute_with_options(openlark_core::req_option::RequestOption::default())
.await
}
pub async fn execute_with_options(
self,
option: openlark_core::req_option::RequestOption,
) -> SDKResult<CompleteTaskResponse> {
validate_required!(self.task_guid.trim(), "任务GUID不能为空");
let api_endpoint = TaskApiV2::TaskComplete(self.task_guid.clone());
let request = ApiRequest::<CompleteTaskResponse>::post(api_endpoint.to_url());
let response =
openlark_core::http::Transport::request(request, &self.config, Some(option)).await?;
extract_response_data(response, "完成任务")
}
}
impl ApiResponseTrait for CompleteTaskResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[cfg(test)]
#[allow(unused_imports)]
mod tests {
use std::sync::Arc;
use super::*;
#[test]
fn test_complete_task_request() {
let config = openlark_core::config::Config::builder()
.app_id("test")
.app_secret("test")
.build();
let request = CompleteTaskRequest::new(Arc::new(config), "task_123".to_string());
assert_eq!(request.task_guid, "task_123");
}
}