Function cmd_reply

crates/flowtrace-cli/src/main.rs:401–442

(run: Option<String>)

}

fn cmd_reply(run: Option<String>) -> Result<()> {
    let root = trace_root_or_bail()?;
    let raw = reply::read_stdin_to_string()?;
    let payload = reply::parse_payload(&raw)?;
    let step_id: Option<String> = payload.step_id().map(String::from);

    // Every cited evidence path must exist on disk at call time.
    let run_id = resolve_run(&root, run.as_deref())?;
    let cited = payload.evidence_paths();
    for p in &cited {
        let abs = flowtrace_core::state::run_dir(&root, &run_id).join(p);
        if !abs.exists() {
            anyhow::bail!(
                "evidence path `{}` not found on disk (resolved to {}) — write the file before calling `flowtrace reply`",
                p,
                abs.display()
            );
        }
    }

    let (seq, _at) = reply::append_reply(&root, &run_id, payload)?;

    // Stage explicitly: the new reply file + every cited evidence path.
    // No `add -A`; commits should contain only what the payload declares.
    let reply_rel = format!("runs/{}/replies/{:04}.json", run_id, seq);
    let cited_rel: Vec<String> = cited
        .iter()
        .map(|p| format!("runs/{}/{}", run_id, p))
        .collect();
    let mut files: Vec<&str> = Vec::with_capacity(1 + cited_rel.len());
    files.push(reply_rel.as_str());
    for c in &cited_rel {
        files.push(c.as_str());
    }
    git::commit_files(&root, &git::reply_commit_msg(step_id.as_deref(), seq), &files)?;

    match step_id {
        Some(s) => println!("ok: run={} step={} seq={:04}", run_id, s, seq),
        None => println!("ok: run={} seq={:04}", run_id, seq),
    }
    Ok(())
}

fn cmd_completion(shell: &str) -> Result<()> {
    use clap_complete::Shell;