Changeset View
Changeset View
Standalone View
Standalone View
keyserver/addons/rust-node-addon/src/identity_client/compare_users.rs
| use super::*; | use super::*; | ||||
| #[napi] | #[napi] | ||||
| #[instrument(skip_all)] | #[instrument(skip_all)] | ||||
| async fn compare_users( | async fn compare_users( | ||||
| users: Vec<String>, | users: Vec<String>, | ||||
| ) -> Result<HashMap<String, Vec<String>>> { | ) -> Result<HashMap<String, Vec<String>>> { | ||||
| let channel = get_identity_service_channel().await?; | let channel = get_identity_service_channel().await?; | ||||
| let token: MetadataValue<_> = IDENTITY_SERVICE_CONFIG | let token: MetadataValue<_> = IDENTITY_SERVICE_CONFIG | ||||
| .identity_auth_token | .identity_auth_token | ||||
| .parse() | .parse() | ||||
| .map_err(|_| Error::from_status(Status::GenericFailure))?; | .map_err(|_| Error::from_status(Status::GenericFailure))?; | ||||
| let mut identity_client = | let mut identity_client = IdentityKeyserverServiceClient::with_interceptor( | ||||
| IdentityServiceClient::with_interceptor(channel, |mut req: Request<()>| { | channel, | ||||
| |mut req: Request<()>| { | |||||
| req.metadata_mut().insert("authorization", token.clone()); | req.metadata_mut().insert("authorization", token.clone()); | ||||
| Ok(req) | Ok(req) | ||||
| }); | }, | ||||
| ); | |||||
| let request = Request::new(CompareUsersRequest { users: users }); | let request = Request::new(CompareUsersRequest { users: users }); | ||||
| match identity_client.compare_users(request).await { | match identity_client.compare_users(request).await { | ||||
| Ok(tonic_response) => { | Ok(tonic_response) => { | ||||
| let compare_users_response = tonic_response.into_inner(); | let compare_users_response = tonic_response.into_inner(); | ||||
| let mut compare_result = HashMap::new(); | let mut compare_result = HashMap::new(); | ||||
| compare_result.insert( | compare_result.insert( | ||||
| "usersMissingFromKeyserver".to_string(), | "usersMissingFromKeyserver".to_string(), | ||||
| Show All 11 Lines | |||||