opencrabs 0.3.66

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Install with: cargo install opencrabs
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

//! RSI staleness line for Mission Control (#469): a dark RSI looked
//! identical to a healthy one — it went silent for three days while the
//! ledger kept recording, and nothing surfaced it. Pure formatting so the
//! threshold rules are unit tested without a database.

/// RSI counts as stale when its last activity is older than this while
/// tool events kept recording (activity happened, RSI didn't process it).
pub const RSI_STALE_AFTER_SECS: i64 = 12 * 3600;

/// The Mission Control line for RSI liveness. `now_ts` / `last_ts` are unix
/// seconds; `events_since` counts tool events recorded after the last RSI
/// activity.
pub fn rsi_staleness_line(now_ts: i64, last_ts: Option<i64>, events_since: i64) -> String {
    match last_ts {
        None if events_since > 0 => {
            format!("⚠️ RSI has never run — {events_since} tool event(s) recorded and unprocessed")
        }
        None => "RSI has never run".to_string(),
        Some(ts) => {
            let age = (now_ts - ts).max(0);
            let human = humanize_age(age);
            if age > RSI_STALE_AFTER_SECS && events_since > 0 {
                format!("⚠️ RSI stale: last run {human} ago ({events_since} tool event(s) since)")
            } else {
                format!("RSI last run {human} ago")
            }
        }
    }
}

/// Coarse age: `3d 2h`, `5h 12m`, `42m`, `<1m`.
fn humanize_age(secs: i64) -> String {
    let secs = secs.max(0);
    let days = secs / 86_400;
    let hours = (secs % 86_400) / 3_600;
    let mins = (secs % 3_600) / 60;
    if days > 0 {
        format!("{days}d {hours}h")
    } else if hours > 0 {
        format!("{hours}h {mins}m")
    } else if mins > 0 {
        format!("{mins}m")
    } else {
        "<1m".to_string()
    }
}