kaizen-cli 0.1.35

Distributable agent observability: real-time-tailable sessions, agile-style retros, and repo-level improvement (Cursor, Claude Code, Codex). SQLite, redact before any sync you enable.
Documentation 
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

// SPDX-License-Identifier: AGPL-3.0-or-later
//! Session lifecycle state machine — pure core, no IO.
//!
//! # Invariants
//! - `Done` is terminal: `transition` always returns `None` for Done sessions.
//! - `gc` fires only when `elapsed >= GC_DEADLINE`.

pub const GC_DEADLINE: u32 = 24;

#[derive(Debug, Clone, PartialEq, Eq)]
pub enum Status {
    Running,
    Waiting,
    Idle,
    Done,
}

pub struct Session {
    pub status: Status,
    pub elapsed: u32,
}

impl Default for Session {
    fn default() -> Self {
        Session {
            status: Status::Running,
            elapsed: 0,
        }
    }
}

/// Pure transition: returns next `Session` or `None` if action is not enabled.
pub fn transition(s: &Session, action: &str) -> Option<Session> {
    let next = |status| Session {
        status,
        elapsed: s.elapsed + 1,
    };
    match (action, &s.status) {
        ("tool_call", Status::Running) => Some(next(Status::Waiting)),
        ("user_responds", Status::Waiting) => Some(next(Status::Running)),
        ("agent_idles", Status::Running) => Some(next(Status::Idle)),
        ("agent_resumes", Status::Idle) => Some(next(Status::Running)),
        ("session_ends", st) if *st != Status::Done => Some(next(Status::Done)),
        ("gc", st) if *st != Status::Done && s.elapsed >= GC_DEADLINE => Some(next(Status::Done)),
        _ => None,
    }
}