Skip to content
Clone
538d47b
67 lines 2.7 KB Rust
use crate::AuthSvc;
use crate::internal::context::RequestMeta;
use tonic::{Request, Response, Status};
use crate::internal::identity::IdentityApi;
use crate::protos::auth::v1::identity_service_server::IdentityService;
pub struct IdentityClient {
api: IdentityApi,
}
impl IdentityClient {
pub fn new(service: AuthSvc) -> Self {
Self {
api: IdentityApi::new(service),
}
}
pub async fn authenticate(
&mut self,
mut request: Request<crate::protos::auth::v1::AuthenticateRequest>,
) -> Result<Response<crate::protos::auth::v1::AuthenticateResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.authenticate(request).await
}
pub async fn verify_credential(
&mut self,
mut request: Request<crate::protos::auth::v1::VerifyCredentialRequest>,
) -> Result<Response<crate::protos::auth::v1::VerifyCredentialResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.verify_credential(request).await
}
pub async fn get_user_public(
&mut self,
mut request: Request<crate::protos::auth::v1::GetUserPublicRequest>,
) -> Result<Response<crate::protos::auth::v1::GetUserPublicResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.get_user_public(request).await
}
pub async fn batch_get_user_public(
&mut self,
mut request: Request<crate::protos::auth::v1::BatchGetUserPublicRequest>,
) -> Result<Response<crate::protos::auth::v1::BatchGetUserPublicResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.batch_get_user_public(request).await
}
pub async fn get_user_status(
&mut self,
mut request: Request<crate::protos::auth::v1::GetUserStatusRequest>,
) -> Result<Response<crate::protos::auth::v1::GetUserStatusResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.get_user_status(request).await
}
pub async fn ensure_bot_user(
&mut self,
mut request: Request<crate::protos::auth::v1::EnsureBotUserRequest>,
) -> Result<Response<crate::protos::auth::v1::EnsureBotUserResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.ensure_bot_user(request).await
}
pub async fn change_password(
&mut self,
mut request: Request<crate::protos::auth::v1::ChangePasswordRequest>,
) -> Result<Response<crate::protos::auth::v1::ChangePasswordResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.change_password(request).await
}
}