csift 0.9.4

ripgrep for Claude Code session transcripts: fast regex list/search over ~/.claude/projects/**/*.jsonl
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

//! `run_status`: resolve one target, join the surfaces, render the verdict.

use super::*;

/// Resolve the single transcript a status/wait target names (same exactly-one contract
/// as `show`, same resolver grammar as everything).
pub(crate) fn resolve_live_target(target: &[PathBuf], want_subagents: bool) -> Result<PathBuf> {
    let one = match target {
        [one] => one,
        many => bail!(
            "status/wait watch exactly ONE session per call; got {} targets — run one \
             call per session",
            many.len()
        ),
    };
    let scope = crate::path::SubagentScope::from(want_subagents);
    let files = crate::path::resolve_session_files(
        std::slice::from_ref(one),
        scope,
        crate::path::Caller::Other,
    )?;
    // The MAIN transcript anchors the watch; children are discovered from it. A
    // subagent target anchors on its own transcript.
    let main = files
        .iter()
        .find(|p| !crate::subagent::is_subagent_path(p))
        .or_else(|| files.first())
        .cloned();
    main.ok_or_else(|| anyhow::anyhow!("the target resolved to no transcript"))
}

/// Entry point for `csift status`.
pub fn run_status(args: &StatusArgs) -> Result<()> {
    let main = resolve_live_target(&args.target, args.want_subagents())?;
    let assessment = assess_path(&main, args.want_subagents())?;
    let session_id = crate::subagent::session_id_from_path(&main);
    let is_subagent = crate::subagent::is_subagent_path(&main);
    let parent_session_id =
        crate::subagent::parent_session_id_from_path(&main).unwrap_or_else(|| session_id.clone());
    match args.format {
        OutputFormat::Text => render_status_text(&session_id, &assessment),
        OutputFormat::Json => {
            render_status_json(&session_id, is_subagent, &parent_session_id, &assessment)?;
        }
    }
    Ok(())
}

/// One full three-way join over a resolved transcript path.
pub(crate) fn assess_path(main: &Path, want_subagents: bool) -> Result<Assessment> {
    let session_id = crate::subagent::session_id_from_path(main);
    let is_subagent_target = crate::subagent::is_subagent_path(main);
    let owner_id =
        crate::subagent::parent_session_id_from_path(main).unwrap_or_else(|| session_id.clone());

    let registry = registry_row_for(&owner_id)?;
    let liveness = registry
        .as_ref()
        .and_then(|r| r.pid)
        .map(|pid| probe_pid(pid, registry.as_ref().and_then(|r| r.proc_start.as_deref())));

    let main_tail = tail_shape(main)?;
    let children = if want_subagents && !is_subagent_target {
        children_report(main)?
    } else {
        ChildrenReport::default()
    };

    // The elicitation sidecar covers HITL (AUQ / ExitPlanMode / MCP): unresolved
    // pendings only, keyed by the top-level session.
    let pending: Vec<String> = if is_subagent_target {
        Vec::new() // the sidecar is keyed by the top-level session
    } else {
        crate::elicitation::unresolved_pending(main)?
            .0
            .iter()
            .map(|r| {
                r.csift_kind
                    .clone()
                    .unwrap_or_else(|| "elicitation".to_string())
            })
            .collect()
    };

    let mut assessment = assess(
        registry.as_ref(),
        liveness.as_ref(),
        &main_tail,
        &children,
        &pending,
        is_subagent_target,
    );
    // The task list is keyed by the top-level session (like the sidecar); a subagent
    // target gets no section instead of its parent's list under its own id.
    if !is_subagent_target {
        assessment.tasks = tasks_report(&owner_id);
    }
    Ok(assessment)
}