Differential D7799 Diff 26432 services/tunnelbroker/src/main.rs

Changeset View

Standalone View

Show All 22 Lines	let filter = EnvFilter::builder()
.from_env_lossy();		.from_env_lossy();

let subscriber = tracing_subscriber::fmt().with_env_filter(filter).finish();		let subscriber = tracing_subscriber::fmt().with_env_filter(filter).finish();
tracing::subscriber::set_global_default(subscriber)		tracing::subscriber::set_global_default(subscriber)
.expect("Unable to configure tracing");		.expect("Unable to configure tracing");

config::parse_cmdline_args()?;		config::parse_cmdline_args()?;
let aws_config = config::load_aws_config().await;		let aws_config = config::load_aws_config().await;
let _db_client = database::DatabaseClient::new(&aws_config);		let db_client = database::DatabaseClient::new(&aws_config);

let grpc_server = grpc::run_server();		let grpc_server = grpc::run_server(db_client.clone());
let websocket_server = websockets::run_server();		let websocket_server = websockets::run_server(db_client.clone());

tokio::select! {		tokio::select! {
Ok(_) = grpc_server => { Ok(()) },		Ok(_) = grpc_server => { Ok(()) },
Ok(_) = websocket_server => { Ok(()) },		Ok(_) = websocket_server => { Ok(()) },
else => {		else => {
tracing::error!("A grpc or websocket server crashed.");		tracing::error!("A grpc or websocket server crashed.");
Err(anyhow!("A grpc or websocket server crashed."))		Err(anyhow!("A grpc or websocket server crashed."))
}		}
}		}
}		}