xoq 0.2.1

X-Embodiment over QUIC - P2P and relay communication for robotics
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

//! Serial port bridge server - all forwarding handled internally
//!
//! Usage: serial_server <port> [baud_rate]
//! Example: serial_server /dev/ttyUSB0 115200

use anyhow::Result;
use std::env;
use xoq::Server;

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::from_default_env()
                .add_directive("xoq=debug".parse()?)
                .add_directive("info".parse()?),
        )
        .init();

    let args: Vec<String> = env::args().collect();
    if args.len() < 2 {
        println!("Usage: serial_server <port> [baud_rate]");
        println!("Example: serial_server /dev/ttyUSB0 115200");
        println!("\nAvailable ports:");
        for port in xoq::list_ports()? {
            println!("  {} - {:?}", port.name, port.port_type);
        }
        return Ok(());
    }

    let port_name = &args[1];
    let baud_rate: u32 = args.get(2).and_then(|s| s.parse().ok()).unwrap_or(115200);

    // Create bridge server - opens serial port and starts iroh
    // Use persistent identity so server ID stays the same across restarts
    let bridge = Server::new(port_name, baud_rate, Some(".xoq_server_key")).await?;

    tracing::info!("Serial bridge server started");
    tracing::info!("Port: {} @ {} baud", port_name, baud_rate);
    tracing::info!("Server ID: {}", bridge.id());
    tracing::info!("Waiting for connections...");

    // Run forever - all forwarding handled internally
    bridge.run().await?;

    Ok(())
}