use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{
core::{
api_req::ApiRequest,
api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
config::Config,
constants::AccessTokenType,
http::Transport,
req_option::RequestOption,
SDKResult,
},
service::acs::models::{AcsUser, FaceImage, PageResponse, UserStatus, UserType},
};
pub struct UserService {
pub config: Config,
}
impl UserService {
pub fn new(config: Config) -> Self {
Self { config }
}
pub async fn patch_user(
&self,
user_id: &str,
request: UserPatchRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<UserPatchResponse>> {
let api_req = ApiRequest {
http_method: Method::PATCH,
api_path: format!("/open-apis/acs/v1/users/{user_id}"),
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 get_user(
&self,
user_id: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<UserGetResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: format!("/open-apis/acs/v1/users/{user_id}"),
supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
body: vec![],
..Default::default()
};
Transport::request(api_req, &self.config, option).await
}
pub async fn list_users(
&self,
request: UserListRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<UserListResponse>> {
let mut api_req = ApiRequest {
http_method: Method::GET,
api_path: "/open-apis/acs/v1/users".to_string(),
supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
body: vec![],
..Default::default()
};
if let Some(page_token) = request.page_token {
api_req
.query_params
.insert("page_token".to_string(), page_token);
}
if let Some(page_size) = request.page_size {
api_req
.query_params
.insert("page_size".to_string(), page_size.to_string());
}
if let Some(user_type) = request.user_type {
api_req
.query_params
.insert("user_type".to_string(), serde_json::to_string(&user_type)?);
}
if let Some(status) = request.status {
api_req
.query_params
.insert("status".to_string(), serde_json::to_string(&status)?);
}
if let Some(department) = request.department {
api_req
.query_params
.insert("department".to_string(), department);
}
Transport::request(api_req, &self.config, option).await
}
pub async fn upload_face_image(
&self,
user_id: &str,
request: FaceImageUploadRequest,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<FaceImageUploadResponse>> {
let api_req = ApiRequest {
http_method: Method::PUT,
api_path: format!("/open-apis/acs/v1/users/{user_id}/face_image"),
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_face_image(
&self,
user_id: &str,
option: Option<RequestOption>,
) -> SDKResult<BaseResponse<FaceImageDownloadResponse>> {
let api_req = ApiRequest {
http_method: Method::GET,
api_path: format!("/open-apis/acs/v1/users/{user_id}/face_image"),
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, Default)]
pub struct UserPatchRequest {
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub user_type: Option<UserType>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<UserStatus>,
#[serde(skip_serializing_if = "Option::is_none")]
pub department: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub phone: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub email: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct UserPatchResponse {
pub user: AcsUser,
}
impl ApiResponseTrait for UserPatchResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct UserGetResponse {
pub user: AcsUser,
}
impl ApiResponseTrait for UserGetResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct UserListRequest {
#[serde(skip_serializing_if = "Option::is_none")]
pub page_token: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub page_size: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub user_type: Option<UserType>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<UserStatus>,
#[serde(skip_serializing_if = "Option::is_none")]
pub department: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct UserListResponse {
#[serde(flatten)]
pub users: PageResponse<AcsUser>,
}
impl ApiResponseTrait for UserListResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct FaceImageUploadRequest {
pub image_content: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub image_format: Option<String>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct FaceImageUploadResponse {
pub success: bool,
#[serde(skip_serializing_if = "Option::is_none")]
pub image_id: Option<String>,
}
impl ApiResponseTrait for FaceImageUploadResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct FaceImageDownloadResponse {
pub face_image: FaceImage,
}
impl ApiResponseTrait for FaceImageDownloadResponse {
fn data_format() -> ResponseFormat {
ResponseFormat::Data
}
}