Changeset View
Changeset View
Standalone View
Standalone View
services/identity/src/main.rs
Show All 12 Lines | |||||
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::{IdentityServiceServer, MyIdentityService}; | ||||
use tracing::info; | |||||
#[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 23 Lines | match &cli.command { | ||||
} | } | ||||
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 = IdentityServiceServer::with_interceptor(server, check_auth); | ||||
info!("Listening to gRPC traffic on {}", addr); | |||||
Server::builder().add_service(svc).serve(addr).await?; | Server::builder().add_service(svc).serve(addr).await?; | ||||
} | } | ||||
Commands::PopulateDB => unimplemented!(), | Commands::PopulateDB => unimplemented!(), | ||||
} | } | ||||
Ok(()) | Ok(()) | ||||
} | } |