use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{
core::{
api_req::ApiRequest,
api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
config::Config,
constants::AccessTokenType,
endpoints::hire::*,
endpoints::EndpointBuilder,
http::Transport,
req_option::RequestOption,
SDKResult,
},
service::hire::models::{PageResponse, Role, RoleListRequest, UserRole},
};
pub struct AuthService {
pub config: Config,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct RoleDetailResponse {
pub role: Role,
}
impl ApiResponseTrait for RoleDetailResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct RoleListResponse {
#[serde(flatten)]
pub roles: PageResponse<Role>,
}
impl ApiResponseTrait for RoleListResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct UserRoleListResponse {
#[serde(flatten)]
pub user_roles: PageResponse<UserRole>,
}
impl ApiResponseTrait for UserRoleListResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
impl AuthService {
pub fn new(config: Config) -> Self {
Self { config }
}
pub async fn get_role_detail(
&self,
role_id: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<RoleDetailResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: EndpointBuilder::replace_param(HIRE_V1_ROLE_GET, "role_id", role_id),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn list_roles(
&self,
request: RoleListRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<RoleListResponse>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: HIRE_V1_ROLES.to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant],
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_user_roles(
&self,
user_id: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<UserRoleListResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: EndpointBuilder::replace_param(HIRE_V1_USER_ROLES, "user_id", user_id),
supported_access_token_types: vec![AccessTokenType::Tenant],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
}