Page MenuHomePhabricator
Differential D6955 Diff 23458 keyserver/addons/rust-node-addon/src/identity_client/update_user.rs

Changeset View

Standalone View

View Options

keyserver/addons/rust-node-addon/src/identity_client/update_user.rs

use crate::identity_client::identity as proto; use crate::identity_client::identity as proto;
use crate::identity_client::identity::identity_service_client::IdentityServiceClient; use crate::identity_client::identity::identity_service_client::IdentityServiceClient;
use crate::identity_client::identity::pake_login_response::Data::AccessToken; use crate::identity_client::identity::pake_login_response::Data::AccessToken;
use crate::identity_client::identity::{ use crate::identity_client::identity::{
update_user_request, update_user_response, UpdateUserRequest, update_user_request, update_user_response, UpdateUserRequest,
UpdateUserResponse, UpdateUserResponse,
}; };
use crate::identity_client::{AUTH_TOKEN, IDENTITY_SERVICE_SOCKET_ADDR};
use comm_opaque::Cipher; use comm_opaque::Cipher;
use napi::bindgen_prelude::*; use napi::bindgen_prelude::*;
use opaque_ke::{ use opaque_ke::{
ClientLogin, ClientLoginFinishParameters, ClientLoginStartParameters, ClientLogin, ClientLoginFinishParameters, ClientLoginStartParameters,
ClientLoginStartResult, ClientRegistration, ClientLoginStartResult, ClientRegistration,
ClientRegistrationFinishParameters, CredentialFinalization, ClientRegistrationFinishParameters, CredentialFinalization,
CredentialResponse, RegistrationUpload, CredentialResponse, RegistrationUpload,
}; };
use rand::{rngs::OsRng, CryptoRng, Rng}; use rand::{rngs::OsRng, CryptoRng, Rng};
use tokio::sync::mpsc; use tokio::sync::mpsc;
use tokio_stream::wrappers::ReceiverStream; use tokio_stream::wrappers::ReceiverStream;
use tonic; use tonic;
use tonic::{metadata::MetadataValue, transport::Channel}; use tonic::metadata::MetadataValue;
use tracing::{error, instrument}; use tracing::{error, instrument};
use super::{get_identity_service_channel, IDENTITY_SERVICE_CONFIG};
#[napi] #[napi]
#[instrument(skip_all)] #[instrument(skip_all)]
pub async fn update_user(user_id: String, password: String) -> Result<String> { pub async fn update_user(user_id: String, password: String) -> Result<String> {
let channel = Channel::from_static(&IDENTITY_SERVICE_SOCKET_ADDR) let channel = get_identity_service_channel().await?;
.connect() let token: MetadataValue<_> = IDENTITY_SERVICE_CONFIG
.await .identity_auth_token
.map_err(|_| Error::from_status(Status::GenericFailure))?;
let token: MetadataValue<_> = AUTH_TOKEN
.parse() .parse()
.map_err(|_| Error::from_status(Status::GenericFailure))?; .map_err(|_| Error::from_status(Status::GenericFailure))?;
let mut identity_client = IdentityServiceClient::with_interceptor( let mut identity_client = IdentityServiceClient::with_interceptor(
channel, channel,
|mut req: tonic::Request<()>| { |mut req: tonic::Request<()>| {
req.metadata_mut().insert("authorization", token.clone()); req.metadata_mut().insert("authorization", token.clone());
Ok(req) Ok(req)
}, },
▲ Show 20 Lines • Show All 273 Lines • Show Last 20 Lines