wsx 0.15.1

TUI workspace manager — git worktrees + tmux sessions in one tree
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
107
108
109
110
111
112
113
114
115

// Bell/activity detection from tmux sessions.
// ref: tmux(1) — list-windows, session_alerts, window_activity

use super::tmux_cmd;
use std::collections::HashMap;
use std::time::{SystemTime, UNIX_EPOCH};

pub struct SessionStatus {
    pub has_bell: bool,
    pub last_activity_ts: u64, // Unix timestamp, 0 if unknown
    pub has_running_app: bool, // foreground process is not a bare shell
    pub is_running_wsx: bool,  // foreground process is wsx itself
    pub wsx_muted: bool,       // @wsx-muted user option set on this session
    pub wsx_suppressed: bool,  // @wsx-suppressed user option set on this session
}

fn is_shell(cmd: &str) -> bool {
    matches!(
        cmd.trim(),
        "bash" | "zsh" | "sh" | "fish" | "csh" | "tcsh" | "ksh" | "dash" | "elvish"
    )
}

// Watch-mode / long-running foreground commands that should remain "active" even
// when tmux window_activity is quiet.
fn is_watch_mode(cmd: &str) -> bool {
    matches!(
        cmd.trim(),
        "watch"
            | "tail"
            | "watchexec"
            | "entr"
            | "reflex"
            | "node"
            | "bun"
            | "deno"
            | "dotenvx"
            | "npm"
            | "pnpm"
            | "yarn"
            | "npx"
    )
}

// Passive watchers/servers — continuously running but not "needing attention".
fn is_passive(cmd: &str) -> bool {
    matches!(
        cmd.trim(),
        // output viewers
        "watch" | "tail" | "less" | "more" | "man" | "top" | "htop" | "btop" | "bat" |
        // dev servers / watch-mode runtimes
        "node" | "dotenvx" | "bun" | "npm" | "pnpm" | "yarn" | "npx" | "deno" |
        "watchexec" | "entr" | "reflex"
    )
}

/// Single tmux call: returns bell flag, last window_activity timestamp, foreground process,
/// and wsx user options (@wsx-muted, @wsx-suppressed) per session.
pub fn session_activity() -> HashMap<String, SessionStatus> {
    // ^ include @wsx-muted and @wsx-suppressed so all instances share these user-intent flags
    let Ok(output) = tmux_cmd(&[
        "list-windows",
        "-a",
        "-F",
        "#{session_name}\t#{session_alerts}\t#{window_activity}\t#{pane_current_command}\t#{@wsx-muted}\t#{@wsx-suppressed}",
    ])
    .output() else {
        return HashMap::new();
    };

    let now_ts = SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .map(|d| d.as_secs())
        .unwrap_or(0);

    let mut result: HashMap<String, SessionStatus> = HashMap::new();
    for line in String::from_utf8_lossy(&output.stdout).lines() {
        let mut parts = line.splitn(6, '\t');
        let Some(name) = parts.next() else { continue };
        let Some(alerts) = parts.next() else { continue };
        let Some(ts_str) = parts.next() else { continue };
        let cmd = parts.next().unwrap_or("").trim();
        let muted_str = parts.next().unwrap_or("").trim();
        let suppressed_str = parts.next().unwrap_or("").trim();
        let name = name.trim().to_string();
        let has_bell = !alerts.trim().is_empty() && alerts.trim() != "0";
        let ts = ts_str.trim().parse::<u64>().unwrap_or(0);
        let wsx_muted = muted_str == "1";
        let wsx_suppressed = suppressed_str == "1";
        let entry = result.entry(name).or_insert(SessionStatus {
            has_bell: false,
            last_activity_ts: 0,
            has_running_app: false,
            is_running_wsx: false,
            wsx_muted,
            wsx_suppressed,
        });
        entry.has_bell |= has_bell;
        entry.wsx_muted |= wsx_muted;
        entry.wsx_suppressed |= wsx_suppressed;
        if ts > entry.last_activity_ts {
            entry.last_activity_ts = ts;
        }
        if is_watch_mode(cmd) && now_ts > entry.last_activity_ts {
            entry.last_activity_ts = now_ts;
        }
        if !cmd.is_empty() && !is_shell(cmd) && !is_passive(cmd) {
            entry.has_running_app = true;
        }
        if cmd == "wsx" {
            entry.is_running_wsx = true;
        }
    }
    result
}