use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{
core::{
api_req::ApiRequest,
api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
config::Config,
constants::AccessTokenType,
endpoints::{admin, EndpointBuilder},
http::Transport,
req_option::RequestOption,
SDKResult,
},
impl_full_service,
service::admin::models::{
BadgeGrant, BadgeGrantCreateRequest, BadgeGrantDeleteRequest, BadgeGrantGetRequest,
BadgeGrantListRequest, BadgeGrantUpdateRequest, PageResponse,
},
};
pub struct BadgeGrantService {
pub config: Config,
}
impl_full_service!(BadgeGrantService, "admin.badge_grant", "v1");
#[derive(Debug, Serialize, Deserialize)]
pub struct BadgeGrantCreateResponse {
#[serde(flatten)]
pub grant: BadgeGrant,
}
impl ApiResponseTrait for BadgeGrantCreateResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BadgeGrantDeleteResponse {
#[serde(skip_serializing_if = "Option::is_none")]
pub success: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub delete_time: Option<String>,
}
impl ApiResponseTrait for BadgeGrantDeleteResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BadgeGrantUpdateResponse {
#[serde(flatten)]
pub grant: BadgeGrant,
}
impl ApiResponseTrait for BadgeGrantUpdateResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BadgeGrantListResponse {
#[serde(flatten)]
pub page_response: PageResponse<BadgeGrant>,
}
impl ApiResponseTrait for BadgeGrantListResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct BadgeGrantGetResponse {
#[serde(flatten)]
pub grant: BadgeGrant,
}
impl ApiResponseTrait for BadgeGrantGetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl BadgeGrantService {
pub fn new(config: Config) -> Self {
Self { config }
}
pub async fn create_badge_grant(
&self,
request: BadgeGrantCreateRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<BadgeGrantCreateResponse>> {
let api_req = ApiRequest {
http_method: Method::POST,
api_path: admin::ADMIN_V1_BADGE_GRANTS_CREATE.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: serde_json::to_vec(&request)?,
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn delete_badge_grant(
&self,
request: BadgeGrantDeleteRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<BadgeGrantDeleteResponse>> {
let api_req = ApiRequest {
http_method: Method::DELETE,
api_path: EndpointBuilder::replace_param(
admin::ADMIN_V1_BADGE_GRANTS_OPERATION,
"grant_id",
&request.grant_id,
),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn update_badge_grant(
&self,
request: BadgeGrantUpdateRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<BadgeGrantUpdateResponse>> {
let api_req = ApiRequest {
http_method: Method::PUT,
api_path: EndpointBuilder::replace_param(
admin::ADMIN_V1_BADGE_GRANTS_OPERATION,
"grant_id",
&request.grant_id,
),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: serde_json::to_vec(&serde_json::json!({
"name": request.name,
"description": request.description,
"user_list": request.user_list,
"effective_time": request.effective_time,
"expiry_time": request.expiry_time,
"time_zone": request.time_zone
}))?,
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn list_badge_grants(
&self,
request: BadgeGrantListRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<BadgeGrantListResponse>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: admin::ADMIN_V1_BADGE_GRANTS_LIST.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
if let Some(badge_id) = request.badge_id {
api_req.query_params.insert("badge_id", badge_id);
}
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);
}
if let Some(name) = request.name {
api_req.query_params.insert("name", name);
}
Transport::request(api_req, &self.config, option).await
}
pub async fn get_badge_grant(
&self,
request: BadgeGrantGetRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<BadgeGrantGetResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: EndpointBuilder::replace_param(
admin::ADMIN_V1_BADGE_GRANTS_OPERATION,
"grant_id",
&request.grant_id,
),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
}