538d47b
use crate::AuthSvc;
use crate::internal::context::RequestMeta;
use tonic::{Request, Response, Status};
use crate::internal::authority::AuthorityApi;
use crate::protos::auth::internal::v1::authority_service_server::AuthorityService;
pub struct AuthorityClient {
api: AuthorityApi,
}
impl AuthorityClient {
pub fn new(service: AuthSvc) -> Self {
Self {
api: AuthorityApi::new(service),
}
}
pub async fn redeem_socket_ticket(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::RedeemSocketTicketRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::RedeemSocketTicketResponse>, Status>
{
request.extensions_mut().insert(RequestMeta::internal());
self.api.redeem_socket_ticket(request).await
}
pub async fn validate(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::ValidateRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::ValidateResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.validate(request).await
}
pub async fn get_user(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::GetUserRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::GetUserResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.get_user(request).await
}
pub async fn batch_get_user(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::BatchGetUserRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::BatchGetUserResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.batch_get_user(request).await
}
pub async fn get_session(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::GetSessionRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::GetSessionResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.get_session(request).await
}
pub async fn update_user(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::UpdateUserRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::UpdateUserResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.update_user(request).await
}
pub async fn delete_account(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::DeleteAccountRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::DeleteAccountResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.delete_account(request).await
}
pub async fn cancel_account_deletion(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::CancelAccountDeletionRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::CancelAccountDeletionResponse>, Status>
{
request.extensions_mut().insert(RequestMeta::internal());
self.api.cancel_account_deletion(request).await
}
pub async fn purge_account(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::PurgeAccountRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::PurgeAccountResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.purge_account(request).await
}
pub async fn list_users(
&mut self,
mut request: Request<crate::protos::auth::internal::v1::ListUsersRequest>,
) -> Result<Response<crate::protos::auth::internal::v1::ListUsersResponse>, Status> {
request.extensions_mut().insert(RequestMeta::internal());
self.api.list_users(request).await
}
}