Function main

crates/flowtrace-cli/src/main.rs:295–337

()

fn ignore_sigpipe() {}

fn main() -> Result<()> {
    // A normal Unix CLI exits quietly when a downstream consumer closes the pipe
    // early (a pager quitting, `head`, `| grep -q`); `serve` overrides this below.
    restore_default_sigpipe();

    let cli = Cli::parse();
    match cli.cmd {
        Cmd::DebugWatch { path, debounce_ms } => debug_watch::run(&path, debounce_ms),
        Cmd::Validate => cmd_validate(),
        Cmd::Lint => cmd_lint(),
        Cmd::Show { fmt, downstream } => cmd_show(&fmt, downstream.as_deref()),
        Cmd::Reply { run } => cmd_reply(run),
        Cmd::Serve { scope, port, open } => {
            // Unlike the one-shot CLI commands, the server must survive a client
            // disconnecting mid-response, so keep SIGPIPE ignored.
            ignore_sigpipe();
            let runtime = tokio::runtime::Builder::new_multi_thread()
                .enable_all()
                .build()?;
            runtime.block_on(serve::run(&scope, port, open))
        }
        Cmd::Completion { shell } => cmd_completion(&shell),
        Cmd::Run { action } => cmd_run(action),
        Cmd::Step {
            step_id,
            status,
            message,
            assets,
            run,
        } => cmd_step(step_id, status, message, assets, run),
        Cmd::Deliverable {
            status,
            message,
            assets,
            run,
        } => cmd_deliverable(status, message, assets, run),
        Cmd::Explain { path, output } => {
            print!("{}", explain::explain(&path, output)?);
            Ok(())
        }
        Cmd::Init { slug } => cmd_init(&slug),
    }
}

fn cmd_init(slug: &str) -> Result<()> {
    validate_trace_id(slug)