Page MenuHomePhabricator
Differential D8506

[keyserver][lib] Simplify join_thread endpoint response following deprecation of old codeVersions
ClosedPublic
Actions

Authored by ashoat on Jul 15 2023, 8:03 PM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Apr 1, 2:59 PM
Unknown Object (File)
Sun, Mar 23, 1:37 PM
Unknown Object (File)
Sun, Mar 23, 1:35 PM
Unknown Object (File)
Sun, Mar 23, 1:35 PM
Unknown Object (File)
Sun, Mar 23, 6:47 AM
Unknown Object (File)
Mon, Mar 17, 10:44 PM
Unknown Object (File)
Mon, Mar 17, 10:44 PM
Unknown Object (File)
Mon, Mar 17, 10:43 PM
View All 93 Files
Subscribers
tomek

Details

Reviewers
michal
kamil
Commits
rCOMMa2f1e6b9f353: [keyserver][lib] Simplify join_thread endpoint response following deprecation…
Summary

See the first diff in the stack. We're no longer expecting to see these old codeVersions, so we're simplifying this code.

Depends on D8505

Test Plan

I tested this whole stack together by playing around with the web app and making sure thread mutation endpoints seemed to work correctly

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
keyserver/
src/
responders/
3 lines
updaters/
54 lines
lib/
types/
14 lines

Diff 28742

View Options

keyserver/src/responders/thread-responders.js

use clap::{Parser, Subcommand};
use tonic::transport::Server; use tonic::transport::Server;
mod keygen;
mod opaque;
mod service; mod service;
use keygen::generate_and_persist_keypair;
use service::{IdentityServiceServer, MyIdentityService}; use service::{IdentityServiceServer, MyIdentityService};
const IDENTITY_SERVICE_SOCKET_ADDR: &str = "[::]:50051"; const IDENTITY_SERVICE_SOCKET_ADDR: &str = "[::]:50051";
const DEFAULT_SECRETS_DIRECTORY: &str = "secrets";
#[derive(Parser)]
#[clap(author, version, about, long_about = None)]
#[clap(propagate_version = true)]
struct Cli {
#[clap(subcommand)]
command: Commands,
}
#[derive(Subcommand)]
enum Commands {
/// Runs the server
Server,
/// Generates and persists a keypair to use for PAKE registration and login
Keygen {
#[clap(short, long)]
#[clap(default_value_t = String::from(DEFAULT_SECRETS_DIRECTORY))]
dir: String,
},
}
#[tokio::main] #[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> { async fn main() -> Result<(), Box<dyn std::error::Error>> {
let cli = Cli::parse();
match &cli.command {
Commands::Keygen { dir } => {
generate_and_persist_keypair(dir)?;
}
Commands::Server => {
let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?; let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?;
let identity_service = MyIdentityService::default(); let identity_service = MyIdentityService::default();
Server::builder() Server::builder()
.add_service(IdentityServiceServer::new(identity_service)) .add_service(IdentityServiceServer::new(identity_service))
.serve(addr) .serve(addr)
.await?; .await?;
}
}
Ok(()) Ok(())
} }
View Options

keyserver/src/updaters/thread-updaters.js

use clap::{Parser, Subcommand};
use tonic::transport::Server; use tonic::transport::Server;
mod keygen;
mod opaque;
mod service; mod service;
use keygen::generate_and_persist_keypair;
use service::{IdentityServiceServer, MyIdentityService}; use service::{IdentityServiceServer, MyIdentityService};
const IDENTITY_SERVICE_SOCKET_ADDR: &str = "[::]:50051"; const IDENTITY_SERVICE_SOCKET_ADDR: &str = "[::]:50051";
const DEFAULT_SECRETS_DIRECTORY: &str = "secrets";
#[derive(Parser)]
#[clap(author, version, about, long_about = None)]
#[clap(propagate_version = true)]
struct Cli {
#[clap(subcommand)]
command: Commands,
}
#[derive(Subcommand)]
enum Commands {
/// Runs the server
Server,
/// Generates and persists a keypair to use for PAKE registration and login
Keygen {
#[clap(short, long)]
#[clap(default_value_t = String::from(DEFAULT_SECRETS_DIRECTORY))]
dir: String,
},
}
#[tokio::main] #[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> { async fn main() -> Result<(), Box<dyn std::error::Error>> {
let cli = Cli::parse();
match &cli.command {
Commands::Keygen { dir } => {
generate_and_persist_keypair(dir)?;
}
Commands::Server => {
let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?; let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?;
let identity_service = MyIdentityService::default(); let identity_service = MyIdentityService::default();
Server::builder() Server::builder()
.add_service(IdentityServiceServer::new(identity_service)) .add_service(IdentityServiceServer::new(identity_service))
.serve(addr) .serve(addr)
.await?; .await?;
}
}
Ok(()) Ok(())
} }
View Options

lib/types/thread-types.js

use clap::{Parser, Subcommand};
use tonic::transport::Server; use tonic::transport::Server;
mod keygen;
mod opaque;
mod service; mod service;
use keygen::generate_and_persist_keypair;
use service::{IdentityServiceServer, MyIdentityService}; use service::{IdentityServiceServer, MyIdentityService};
const IDENTITY_SERVICE_SOCKET_ADDR: &str = "[::]:50051"; const IDENTITY_SERVICE_SOCKET_ADDR: &str = "[::]:50051";
const DEFAULT_SECRETS_DIRECTORY: &str = "secrets";
#[derive(Parser)]
#[clap(author, version, about, long_about = None)]
#[clap(propagate_version = true)]
struct Cli {
#[clap(subcommand)]
command: Commands,
}
#[derive(Subcommand)]
enum Commands {
/// Runs the server
Server,
/// Generates and persists a keypair to use for PAKE registration and login
Keygen {
#[clap(short, long)]
#[clap(default_value_t = String::from(DEFAULT_SECRETS_DIRECTORY))]
dir: String,
},
}
#[tokio::main] #[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> { async fn main() -> Result<(), Box<dyn std::error::Error>> {
let cli = Cli::parse();
match &cli.command {
Commands::Keygen { dir } => {
generate_and_persist_keypair(dir)?;
}
Commands::Server => {
let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?; let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?;
let identity_service = MyIdentityService::default(); let identity_service = MyIdentityService::default();
Server::builder() Server::builder()
.add_service(IdentityServiceServer::new(identity_service)) .add_service(IdentityServiceServer::new(identity_service))
.serve(addr) .serve(addr)
.await?; .await?;
}
}
Ok(()) Ok(())
} }