mirror of
https://github.com/block/buzz.git
synced 2026-10-28 21:11:48 +00:00
Signed-off-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co> Co-authored-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co>
28 lines
797 B
Rust
28 lines
797 B
Rust
use std::net::SocketAddr;
|
|
use std::sync::Arc;
|
|
|
|
use buzz_pair_relay::{run_server, Relay};
|
|
use tokio::net::TcpListener;
|
|
|
|
#[tokio::main]
|
|
async fn main() {
|
|
let addr_raw =
|
|
std::env::var("BUZZ_PAIR_RELAY_BIND_ADDR").unwrap_or_else(|_| "127.0.0.1:5000".to_string());
|
|
let addr: SocketAddr = match addr_raw.parse() {
|
|
Ok(addr) => addr,
|
|
Err(e) => {
|
|
eprintln!("fatal: invalid BUZZ_PAIR_RELAY_BIND_ADDR {addr_raw:?}: {e}");
|
|
std::process::exit(1);
|
|
}
|
|
};
|
|
let listener = match TcpListener::bind(addr).await {
|
|
Ok(l) => l,
|
|
Err(e) => {
|
|
eprintln!("fatal: failed to bind {addr}: {e}");
|
|
std::process::exit(1);
|
|
}
|
|
};
|
|
let relay = Arc::new(Relay::new());
|
|
run_server(listener, relay).await;
|
|
}
|