use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{
core::{
api_req::ApiRequest,
api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
config::Config,
constants::AccessTokenType,
endpoints::{EndpointBuilder, Endpoints},
http::Transport,
req_option::RequestOption,
SDKResult,
},
service::apass::models::{
EnvironmentVariable, EnvironmentVariableGetRequest, EnvironmentVariableQueryRequest,
PageResponse,
},
};
pub struct EnvironmentVariableService {
pub config: Config,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct EnvironmentVariableQueryResponse {
#[serde(flatten)]
pub page_response: PageResponse<EnvironmentVariable>,
}
impl ApiResponseTrait for EnvironmentVariableQueryResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct EnvironmentVariableGetResponse {
#[serde(flatten)]
pub environment_variable: EnvironmentVariable,
}
impl ApiResponseTrait for EnvironmentVariableGetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl EnvironmentVariableService {
pub fn new(config: Config) -> Self {
Self { config }
}
pub async fn query_environment_variables(
&self,
request: EnvironmentVariableQueryRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<EnvironmentVariableQueryResponse>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: EndpointBuilder::replace_param(
Endpoints::APASS_V1_ENVIRONMENT_VARIABLE_QUERY,
"app_id",
&request.app_id,
),
supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
body: vec![],
..Default::default()
};
if let Some(page_size) = request.page_size {
api_req
.query_params
.insert("page_size", page_size.to_string());
}
if let Some(page_token) = request.page_token {
api_req.query_params.insert("page_token", page_token);
}
Transport::request(api_req, &self.config, option).await
}
pub async fn get_environment_variable(
&self,
request: EnvironmentVariableGetRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<EnvironmentVariableGetResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: EndpointBuilder::replace_params_from_array(
Endpoints::APASS_V1_ENVIRONMENT_VARIABLE_GET,
&[
("app_id", &request.app_id),
("variable_name", &request.variable_name),
],
),
supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
}