use openlark_core::{
api::{ApiRequest, ApiResponseTrait, ResponseFormat},
config::Config,
http::Transport,
req_option::RequestOption,
validate_required, SDKResult,
};
use crate::common::{api_endpoints::CcmSheetApiOld, api_utils::*};
#[derive(Debug, Clone)]
pub struct SheetApi {
config: Config,
}
impl SheetApi {
pub fn new(config: Config) -> Self {
Self { config }
}
pub fn config(&self) -> &Config {
&self.config
}
}
pub mod models;
pub use models::{
AddSheetParams, AddSheetResponse, AddSheetResult, DeleteSheetParams, DeleteSheetResponse,
DeleteSheetResult, GetSheetParams, GetSheetResponse, SheetDetailInfo, UpdateSheetParams,
UpdateSheetResponse, UpdateSheetResult,
};
impl ApiResponseTrait for AddSheetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl ApiResponseTrait for GetSheetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl ApiResponseTrait for UpdateSheetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl ApiResponseTrait for DeleteSheetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
pub async fn add_sheet(
config: &Config,
spreadsheet_token: &str,
params: AddSheetParams,
) -> SDKResult<AddSheetResponse> {
add_sheet_with_options(config, spreadsheet_token, params, RequestOption::default()).await
}
pub async fn add_sheet_with_options(
config: &Config,
spreadsheet_token: &str,
params: AddSheetParams,
option: RequestOption,
) -> SDKResult<AddSheetResponse> {
validate_required!(spreadsheet_token.trim(), "表格Token不能为空");
validate_required!(params.title.trim(), "工作表标题不能为空");
let api_endpoint = CcmSheetApiOld::AddSheet(spreadsheet_token.to_string());
let api_request: ApiRequest<AddSheetResponse> =
ApiRequest::post(&api_endpoint.to_url()).body(serialize_params(¶ms, "添加工作表")?);
let response = Transport::request(api_request, config, Some(option)).await?;
extract_response_data(response, "添加工作表")
}
pub async fn get_sheet(
config: &Config,
spreadsheet_token: &str,
params: GetSheetParams,
) -> SDKResult<GetSheetResponse> {
get_sheet_with_options(config, spreadsheet_token, params, RequestOption::default()).await
}
pub async fn get_sheet_with_options(
config: &Config,
spreadsheet_token: &str,
params: GetSheetParams,
option: RequestOption,
) -> SDKResult<GetSheetResponse> {
validate_required!(spreadsheet_token.trim(), "表格Token不能为空");
validate_required!(params.sheet_id.trim(), "工作表ID不能为空");
let api_endpoint = CcmSheetApiOld::GetSheet(spreadsheet_token.to_string());
let api_request: ApiRequest<GetSheetResponse> =
ApiRequest::post(&api_endpoint.to_url()).body(serialize_params(¶ms, "获取工作表信息")?);
let response = Transport::request(api_request, config, Some(option)).await?;
extract_response_data(response, "获取工作表信息")
}
pub async fn update_sheet(
config: &Config,
spreadsheet_token: &str,
params: UpdateSheetParams,
) -> SDKResult<UpdateSheetResponse> {
update_sheet_with_options(config, spreadsheet_token, params, RequestOption::default()).await
}
pub async fn update_sheet_with_options(
config: &Config,
spreadsheet_token: &str,
params: UpdateSheetParams,
option: RequestOption,
) -> SDKResult<UpdateSheetResponse> {
validate_required!(spreadsheet_token.trim(), "表格Token不能为空");
validate_required!(params.sheet_id.trim(), "工作表ID不能为空");
let api_endpoint = CcmSheetApiOld::UpdateSheet(spreadsheet_token.to_string());
let api_request: ApiRequest<UpdateSheetResponse> =
ApiRequest::post(&api_endpoint.to_url()).body(serialize_params(¶ms, "更新工作表")?);
let response = Transport::request(api_request, config, Some(option)).await?;
extract_response_data(response, "更新工作表")
}
pub async fn delete_sheet(
config: &Config,
spreadsheet_token: &str,
params: DeleteSheetParams,
) -> SDKResult<DeleteSheetResponse> {
delete_sheet_with_options(config, spreadsheet_token, params, RequestOption::default()).await
}
pub async fn delete_sheet_with_options(
config: &Config,
spreadsheet_token: &str,
params: DeleteSheetParams,
option: RequestOption,
) -> SDKResult<DeleteSheetResponse> {
validate_required!(spreadsheet_token.trim(), "表格Token不能为空");
validate_required!(params.sheet_id.trim(), "工作表ID不能为空");
let api_endpoint = CcmSheetApiOld::DeleteSheet(spreadsheet_token.to_string());
let api_request: ApiRequest<DeleteSheetResponse> =
ApiRequest::post(&api_endpoint.to_url()).body(serialize_params(¶ms, "删除工作表")?);
let response = Transport::request(api_request, config, Some(option)).await?;
extract_response_data(response, "删除工作表")
}
#[cfg(test)]
mod tests {
use serde_json;
#[test]
fn test_serialization_roundtrip() {
let json = r#"{"test": "value"}"#;
assert!(serde_json::from_str::<serde_json::Value>(json).is_ok());
}
#[test]
fn test_deserialization_from_json() {
let json = r#"{"field": "data"}"#;
let value: serde_json::Value = serde_json::from_str(json).unwrap();
assert_eq!(value["field"], "data");
}
}