agtop 2.4.2

Terminal UI for monitoring AI coding agents (Claude Code, Codex, Aider, Cursor, Gemini, Goose, ...) — like top, but for agents.
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
100
101
102
103
104
105
106

// Generic enricher for agents that don't have a vendor-specific session
// reader (yet). Looks at the process's open writable file descriptors and
// uses the most recently modified file as the "current task" hint.
//
// This is a best-effort, vendor-agnostic fallback: it gives any AI coding
// agent (aider, cursor-agent, gemini, goose, continue, opencode, copilot,
// cody, amp, crush, mods, sgpt, llm, ollama, fabric, ...) at least a "what
// is it touching right now?" line in the DOING column, even if we can't
// parse its transcript.

use crate::model::{Agent, Session, Status};
use crate::sessions::{LiveAgentRef, SessionsResult};

use std::collections::HashMap;
use std::fs;
use std::path::Path;

// Vendor labels we already enrich in dedicated modules — generic skips these.
const SKIP_LABELS: &[&str] = &["claude", "claude-code", "codex", "openai-codex"];

pub fn summarise(agents: &[Agent], live_agents: &[LiveAgentRef], _now_ms: u64) -> SessionsResult {
    let mut by_pid: HashMap<u32, Session> = HashMap::new();
    for a in agents {
        if SKIP_LABELS.contains(&a.label.as_str()) { continue; }
        // Only consider the labels that actually appear in live_agents (i.e.
        // process really exists).
        if !live_agents.iter().any(|l| l.pid == a.pid) { continue; }

        // Pick the most-recently modified file the agent has open for write
        // and present it as the "current task" hint.
        let recent = most_recent_writable(a);
        let last_task = recent.as_ref().map(|p| {
            let s = p.to_string_lossy();
            // Strip the cwd prefix to keep the hint short.
            if let Some(rest) = s.strip_prefix(a.cwd.as_str()) {
                let r = rest.trim_start_matches('/');
                if r.is_empty() { s.into_owned() } else { r.to_string() }
            } else {
                s.into_owned()
            }
        });

        if last_task.is_some() {
            // Synthetic Session record for the merge step. We don't have a
            // real session id so we use "{pid}".
            by_pid.insert(a.pid, Session {
                id: format!("{}", a.pid),
                project: a.cwd.clone(),
                project_short: a.project.clone(),
                file: String::new(),
                size_bytes: 0,
                mtime_ms: 0,
                age_ms: 0,
                status: classify(a),
                stop_reason: None,
                last_task,
                last_tool: None,
                current_tool: None,
                // Generic enricher has no transcript; populate the preview
                // with the writing-files signal so the popup still shows
                // *something* useful for non-Claude / non-Codex agents.
                in_flight_tasks: 0,
                in_flight_subagents: Vec::new(),
                recent_activity: a.writing_files.iter().take(6)
                    .map(|f| format!("→ writing: {}", f)).collect(),
                live_pid: Some(a.pid),
                is_most_recent: true,
                tokens_input: 0,
                tokens_output: 0,
                tokens_total: 0,
                tokens_cache_read: 0,
                tokens_cache_write: 0,
                cost_usd: 0.0,
                context_used: 0,
                session_started_ms: 0,
                tool_counts: Vec::new(),
                model: None,
            });
        }
    }

    SessionsResult { sessions: crate::model::Sessions::default(), by_pid }
}

fn classify(a: &Agent) -> Status {
    if a.cpu >= 20.0 { Status::Busy }
    else if a.cpu >= 1.0 { Status::Active }
    else { Status::Idle }
}

fn most_recent_writable(a: &Agent) -> Option<std::path::PathBuf> {
    let mut best: Option<(std::path::PathBuf, std::time::SystemTime)> = None;
    for f in &a.writing_files {
        if f.is_empty() { continue; }
        let p = Path::new(f);
        if let Ok(md) = fs::metadata(p) {
            if let Ok(mt) = md.modified() {
                let take = best.as_ref().map(|(_, t)| mt > *t).unwrap_or(true);
                if take {
                    best = Some((p.to_path_buf(), mt));
                }
            }
        }
    }
    best.map(|(p, _)| p)
}