Differential D7028 Diff 23597 services/identity/src/main.rs

Changeset 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);
		jonAuthorUnsubmitted Done Inline Actions Just added this because it's pretty jarring to get 0 output initially. jon: Just added this because it's pretty jarring to get 0 output initially.
		varunUnsubmitted Done Inline Actions nit: `gRPC` varun: nit: `gRPC`
		jonAuthorUnsubmitted Done Inline Actions fair jon: fair
Server::builder().add_service(svc).serve(addr).await?;		Server::builder().add_service(svc).serve(addr).await?;
}		}
Commands::PopulateDB => unimplemented!(),		Commands::PopulateDB => unimplemented!(),
}		}

Ok(())		Ok(())
}		}