cli.rs

use anyhow::Result;
use browser_echo::node::EchoNode;
use clap::Parser;
use iroh::NodeId;
use n0_future::StreamExt;

#[derive(Debug, Parser)]
struct Args {
    #[clap(subcommand)]
    command: Command,
}

#[derive(Debug, Parser)]
enum Command {
    Connect { node_id: NodeId, payload: String },
    Accept,
}

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt::init();
    let args = Args::parse();
    let node = EchoNode::spawn().await?;
    match args.command {
        Command::Connect { node_id, payload } => {
            let mut events = node.connect(node_id, payload);
            while let Some(event) = events.next().await {
                println!("event {event:?}");
            }
        }
        Command::Accept => {
            println!("connect to this node:");
            println!(
                "cargo run -- connect {} {}",
                node.endpoint().node_id(),
                "hello-please-echo-back"
            );
            let mut events = node.accept_events();
            while let Some(event) = events.next().await {
                println!("event {event:?}");
            }
        }
    }

    Ok(())
}