Page MenuHomePhabricator
Files F3354132

D4140.id13152.diff
No OneTemporary
Actions

D4140.id13152.diff
View Options

diff --git a/services/identity/src/service.rs b/services/identity/src/service.rs
--- a/services/identity/src/service.rs
+++ b/services/identity/src/service.rs
@@ -1,15 +1,21 @@
use futures_core::Stream;
+use opaque_ke::{
+ errors::ProtocolError, keypair::Key,
+ RegistrationRequest as PakeRegistrationRequest, ServerRegistration,
+};
+use rand::{CryptoRng, Rng};
use std::pin::Pin;
+use tokio::sync::mpsc::{error::SendError, Sender};
use tonic::{Request, Response, Status};
-use crate::config::Config;
-use crate::database::DatabaseClient;
+use crate::{config::Config, database::DatabaseClient, opaque::Cipher};
pub use proto::identity_service_server::IdentityServiceServer;
use proto::{
- identity_service_server::IdentityService, LoginRequest, LoginResponse,
- RegistrationRequest, RegistrationResponse, VerifyUserTokenRequest,
- VerifyUserTokenResponse,
+ identity_service_server::IdentityService,
+ registration_response::Data::PakeRegistrationResponse, LoginRequest,
+ LoginResponse, PakeRegistrationRequestAndUserId, RegistrationRequest,
+ RegistrationResponse, VerifyUserTokenRequest, VerifyUserTokenResponse,
};
mod proto {
@@ -57,3 +63,35 @@
unimplemented!()
}
}
+
+async fn pake_registration_start(
+ pake_registration_request: Vec<u8>,
+ rng: &mut (impl Rng + CryptoRng),
+ server_secret_key: &Key,
+ tx: Sender<Result<RegistrationResponse, Status>>,
+) -> Result<(), Error> {
+ let server_registration_start_result = ServerRegistration::<Cipher>::start(
+ rng,
+ PakeRegistrationRequest::deserialize(&pake_registration_request)?,
+ &server_secret_key,
+ )
+ .map_err(Error::Pake)?;
+ tx.send(Ok(RegistrationResponse {
+ data: Some(PakeRegistrationResponse(
+ server_registration_start_result.message.serialize(),
+ )),
+ }))
+ .await
+ .map_err(Error::Channel)?;
+ Ok(())
+}
+
+#[derive(
+ Debug, derive_more::Display, derive_more::From, derive_more::Error,
+)]
+pub enum Error {
+ #[display(...)]
+ Pake(ProtocolError),
+ #[display(...)]
+ Channel(SendError<Result<RegistrationResponse, Status>>),
+}

File Metadata

Mime Type
text/plain
Expires
Sun, Nov 24, 11:58 AM (20 h, 43 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2575483
Default Alt Text
D4140.id13152.diff (2 KB)

Event Timeline