use crate::common::api_endpoints::TaskApiV2;
use crate::v2::attachment::models::AttachmentInfo;
use openlark_core::{
SDKResult,
api::{ApiRequest, ApiResponseTrait, ResponseFormat},
config::Config,
validate_required,
};
use serde::Deserialize;
use std::sync::Arc;
pub type AttachmentListItem = AttachmentInfo;
#[derive(Debug, Clone, Deserialize)]
pub struct ListAttachmentsResponse {
#[serde(default)]
pub has_more: bool,
#[serde(default)]
pub page_token: Option<String>,
#[serde(default)]
pub items: Vec<AttachmentListItem>,
}
#[derive(Debug, Clone)]
pub struct ListAttachmentsRequest {
config: Arc<Config>,
page_size: Option<i32>,
page_token: Option<String>,
resource_type: Option<String>,
resource_id: Option<String>,
user_id_type: Option<String>,
}
impl ListAttachmentsRequest {
pub fn new(config: Arc<Config>) -> Self {
Self {
config,
page_size: None,
page_token: None,
resource_type: None,
resource_id: None,
user_id_type: None,
}
}
pub fn page_size(mut self, page_size: i32) -> Self {
self.page_size = Some(page_size);
self
}
pub fn page_token(mut self, page_token: impl Into<String>) -> Self {
self.page_token = Some(page_token.into());
self
}
pub fn task_guid(mut self, task_guid: impl Into<String>) -> Self {
self.resource_id = Some(task_guid.into());
self
}
pub fn resource_type(mut self, resource_type: impl Into<String>) -> Self {
self.resource_type = Some(resource_type.into());
self
}
pub fn resource_id(mut self, resource_id: impl Into<String>) -> Self {
self.resource_id = Some(resource_id.into());
self
}
pub fn user_id_type(mut self, user_id_type: impl Into<String>) -> Self {
self.user_id_type = Some(user_id_type.into());
self
}
pub async fn execute(self) -> SDKResult<ListAttachmentsResponse> {
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<ListAttachmentsResponse> {
let resource_id = self.resource_id.as_deref().unwrap_or_default();
validate_required!(resource_id.trim(), "资源ID不能为空");
let api_endpoint = TaskApiV2::AttachmentList;
let mut request = ApiRequest::<ListAttachmentsResponse>::get(api_endpoint.to_url());
if let Some(page_size) = self.page_size {
request = request.query("page_size", page_size.to_string());
}
if let Some(page_token) = &self.page_token {
request = request.query("page_token", page_token);
}
request = request.query("resource_id", resource_id);
request = request.query(
"resource_type",
self.resource_type.as_deref().unwrap_or("task"),
);
if let Some(user_id_type) = &self.user_id_type {
request = request.query("user_id_type", user_id_type);
}
openlark_core::http::Transport::request_typed(
request,
&self.config,
Some(option),
"列取附件",
)
.await
}
}
impl ApiResponseTrait for ListAttachmentsResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[cfg(test)]
#[allow(unused_imports)]
mod tests {
use std::sync::Arc;
use super::*;
#[test]
fn test_list_attachments_request() {
let config = openlark_core::config::Config::builder()
.app_id("test")
.app_secret("test")
.build();
let request = ListAttachmentsRequest::new(Arc::new(config))
.page_size(20)
.page_token("next_page_token")
.task_guid("task_123");
assert_eq!(request.page_size, Some(20));
assert_eq!(request.page_token, Some("next_page_token".to_string()));
assert_eq!(request.resource_id, Some("task_123".to_string()));
}
#[test]
fn test_attachment_list_api_v2_url() {
let endpoint = TaskApiV2::AttachmentList;
assert_eq!(endpoint.to_url(), "/open-apis/task/v2/attachments");
}
}