Changeset View
Changeset View
Standalone View
Standalone View
services/identity/src/main.rs
Show All 11 Lines | |||||
mod nonce; | mod nonce; | ||||
mod pake_grpc; | mod pake_grpc; | ||||
mod service; | mod service; | ||||
mod token; | mod token; | ||||
use config::load_config; | use config::load_config; | ||||
use constants::{IDENTITY_SERVICE_SOCKET_ADDR, SECRETS_DIRECTORY}; | use constants::{IDENTITY_SERVICE_SOCKET_ADDR, SECRETS_DIRECTORY}; | ||||
use keygen::generate_and_persist_keypair; | use keygen::generate_and_persist_keypair; | ||||
use service::{IdentityServiceServer, MyIdentityService}; | use service::{IdentityKeyserverServiceServer, MyIdentityService}; | ||||
#[derive(Parser)] | #[derive(Parser)] | ||||
#[clap(author, version, about, long_about = None)] | #[clap(author, version, about, long_about = None)] | ||||
#[clap(propagate_version = true)] | #[clap(propagate_version = true)] | ||||
struct Cli { | struct Cli { | ||||
#[clap(subcommand)] | #[clap(subcommand)] | ||||
command: Commands, | command: Commands, | ||||
} | } | ||||
Show All 22 Lines | Commands::Keygen { dir } => { | ||||
generate_and_persist_keypair(dir)?; | generate_and_persist_keypair(dir)?; | ||||
} | } | ||||
Commands::Server => { | Commands::Server => { | ||||
load_config(); | load_config(); | ||||
let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?; | let addr = IDENTITY_SERVICE_SOCKET_ADDR.parse()?; | ||||
let aws_config = aws_config::from_env().region("us-east-2").load().await; | let aws_config = aws_config::from_env().region("us-east-2").load().await; | ||||
let database_client = DatabaseClient::new(&aws_config); | let database_client = DatabaseClient::new(&aws_config); | ||||
let server = MyIdentityService::new(database_client); | let server = MyIdentityService::new(database_client); | ||||
let svc = IdentityServiceServer::with_interceptor(server, check_auth); | let svc = | ||||
IdentityKeyserverServiceServer::with_interceptor(server, check_auth); | |||||
Server::builder().add_service(svc).serve(addr).await?; | Server::builder().add_service(svc).serve(addr).await?; | ||||
} | } | ||||
Commands::PopulateDB => unimplemented!(), | Commands::PopulateDB => unimplemented!(), | ||||
} | } | ||||
Ok(()) | Ok(()) | ||||
} | } |