use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{
core::{
api_req::ApiRequest,
api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
config::Config,
constants::AccessTokenType,
endpoints::{EndpointBuilder, LINGO_FILE_DOWNLOAD, LINGO_FILE_UPLOAD},
http::Transport,
req_option::RequestOption,
SDKResult,
},
service::lingo::models::FileInfo,
};
pub struct FileService {
pub config: Config,
}
impl FileService {
pub fn new(config: Config) -> Self {
Self { config }
}
pub async fn upload_image(
&self,
request: FileUploadRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<FileUploadResponse>> {
let api_req = ApiRequest {
http_method: Method::POST,
api_path: LINGO_FILE_UPLOAD.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
body: serde_json::to_vec(&request)?,
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn download_image(
&self,
file_token: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<FileDownloadResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: EndpointBuilder::replace_param(
LINGO_FILE_DOWNLOAD,
"{file_token}",
file_token,
),
supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct FileUploadRequest {
pub file_name: String,
pub file_content: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub file_type: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct FileUploadResponse {
pub file: FileInfo,
}
impl ApiResponseTrait for FileUploadResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct FileDownloadResponse {
pub content: Vec<u8>,
#[serde(skip_serializing_if = "Option::is_none")]
pub content_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub content_length: Option<i64>,
}
impl ApiResponseTrait for FileDownloadResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}