workmux 0.1.269

An opinionated workflow tool that orchestrates git worktrees and tmux
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

//! Shared stale-agent classification used by dashboard and sidebar.

use crate::multiplexer::AgentStatus;

/// Whether an agent is stale under the shared timeout and activity rules.
pub(crate) fn is_stale(
    activity_ts: Option<u64>,
    status: Option<AgentStatus>,
    now_secs: u64,
    stale_after_secs: u64,
    is_sleeping: bool,
    is_interrupted: bool,
) -> bool {
    if is_sleeping {
        return true;
    }

    if !is_interrupted && matches!(status, Some(AgentStatus::Working | AgentStatus::Waiting)) {
        return false;
    }

    activity_ts
        .map(|ts| now_secs.saturating_sub(ts) > stale_after_secs)
        .unwrap_or(true)
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn applies_threshold_strictly_after_the_boundary() {
        assert!(!is_stale(Some(100), None, 200, 100, false, false));
        assert!(is_stale(Some(100), None, 201, 100, false, false));
    }

    #[test]
    fn missing_activity_is_stale_unless_status_is_active() {
        assert!(is_stale(None, None, 100, 60, false, false));
        assert!(!is_stale(
            None,
            Some(AgentStatus::Working),
            100,
            60,
            false,
            false,
        ));
        assert!(!is_stale(
            None,
            Some(AgentStatus::Waiting),
            100,
            60,
            false,
            false,
        ));
    }

    #[test]
    fn sleeping_and_interrupted_statuses_override_active_status() {
        assert!(is_stale(
            Some(100),
            Some(AgentStatus::Working),
            100,
            60,
            true,
            false,
        ));
        assert!(is_stale(
            Some(100),
            Some(AgentStatus::Working),
            201,
            100,
            false,
            true,
        ));
        assert!(!is_stale(
            Some(150),
            Some(AgentStatus::Working),
            201,
            100,
            false,
            true,
        ));
    }
}