Page MenuHomePhorge
Files F33385093

D4800.1768966765.diff
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

D4800.1768966765.diff
View Options

diff --git a/native/cpp/CommonCpp/grpc/grpc_client/src/lib.rs b/native/cpp/CommonCpp/grpc/grpc_client/src/lib.rs
--- a/native/cpp/CommonCpp/grpc/grpc_client/src/lib.rs
+++ b/native/cpp/CommonCpp/grpc/grpc_client/src/lib.rs
@@ -1,13 +1,34 @@
use lazy_static::lazy_static;
+use opaque_ke::{
+ ClientLogin, ClientLoginFinishParameters, ClientLoginStartParameters,
+ ClientRegistration, ClientRegistrationFinishParameters,
+ CredentialFinalization, CredentialResponse, RegistrationResponse,
+ RegistrationUpload,
+};
+use rand::{rngs::OsRng, CryptoRng, Rng};
use std::sync::Arc;
use tokio::runtime::{Builder, Runtime};
-use tonic::{transport::Channel, Response, Status};
-use tracing::instrument;
+use tokio::sync::mpsc;
+use tokio_stream::wrappers::ReceiverStream;
+use tonic::{transport::Channel, Request, Response, Status};
+use tracing::{error, instrument};
+
+use ::identity::Cipher;
use crate::identity::{
get_user_id_request::AuthType,
- identity_service_client::IdentityServiceClient, GetUserIdRequest,
- GetUserIdResponse, VerifyUserTokenRequest, VerifyUserTokenResponse,
+ identity_service_client::IdentityServiceClient,
+ pake_login_response::Data::AccessToken,
+ pake_login_response::Data::PakeCredentialResponse,
+ registration_request::Data::PakeCredentialFinalization,
+ registration_request::Data::PakeRegistrationRequestAndUserId,
+ registration_request::Data::PakeRegistrationUploadAndCredentialRequest,
+ registration_response::Data::PakeLoginResponse,
+ registration_response::Data::PakeRegistrationResponse, GetUserIdRequest,
+ GetUserIdResponse, PakeLoginResponse as PakeLoginResponseStruct,
+ PakeRegistrationRequestAndUserId as PakeRegistrationRequestAndUserIdStruct,
+ PakeRegistrationUploadAndCredentialRequest as PakeRegistrationUploadAndCredentialRequestStruct,
+ RegistrationRequest, VerifyUserTokenRequest, VerifyUserTokenResponse,
};
pub mod identity {
tonic::include_proto!("identity");
@@ -73,3 +94,30 @@
.await
}
}
+
+fn pake_registration_finish(
+ rng: &mut (impl Rng + CryptoRng),
+ registration_response_bytes: &[u8],
+ client_registration: Option<ClientRegistration<Cipher>>,
+) -> Result<RegistrationUpload<Cipher>, Status> {
+ client_registration
+ .ok_or_else(|| {
+ error!("PAKE client_registration not found");
+ Status::aborted("Registration not found")
+ })?
+ .finish(
+ rng,
+ RegistrationResponse::deserialize(registration_response_bytes).map_err(
+ |e| {
+ error!("Could not deserialize registration response bytes: {}", e);
+ Status::aborted("Invalid response bytes")
+ },
+ )?,
+ ClientRegistrationFinishParameters::default(),
+ )
+ .map_err(|e| {
+ error!("Failed to finish PAKE registration: {}", e);
+ Status::aborted("PAKE failure")
+ })
+ .map(|res| res.message)
+}

File Metadata

Mime Type
text/plain
Expires
Wed, Jan 21, 3:39 AM (5 h, 23 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5966311
Default Alt Text
D4800.1768966765.diff (2 KB)

Event Timeline