Files
buzz/crates/buzz-pair-relay/src/main.rs
Tyler 9b47c8548f Add optional standalone pairing relay to Helm chart (#1799)
Signed-off-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co>
Co-authored-by: npub12gtutshhh76rx0jx697f32f9tffd4hhp3hx58fp4x6u4uemkm7sqf8f757 <5217c5c2f7bfb4333e46d17c98a9255a52dadee18dcd43a43536b95e6776dfa0@sprout-oss.stage.blox.sqprod.co>
2026-07-13 11:36:04 -04:00

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;
}