kaizen-cli 0.1.42

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
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

// SPDX-License-Identifier: AGPL-3.0-or-later

use crate::collect::hooks::{EventKind, HookEvent};
use crate::core::config;
use anyhow::Result;
use serde_json::Value;
use std::ffi::OsString;
use std::path::Path;

pub(super) fn post_ingest_detached(
    event: &HookEvent,
    cfg: &config::Config,
    workspace: &Path,
) -> Result<()> {
    if matches!(event.kind, EventKind::Stop) {
        stop_sidecars(event, cfg, workspace);
    }
    if should_start_sampler(event, cfg)
        && let Some(pid) = payload_pid(&event.payload)
    {
        spawn_sampler_run(workspace, &event.session_id, pid);
    }
    Ok(())
}

fn stop_sidecars(event: &HookEvent, cfg: &config::Config, workspace: &Path) {
    if cfg.collect.outcomes.enabled {
        spawn_outcome_measure(workspace, &event.session_id);
    }
    if cfg.collect.system_sampler.enabled {
        touch_sampler_stop_file(workspace, &event.session_id);
    }
}

fn should_start_sampler(event: &HookEvent, cfg: &config::Config) -> bool {
    matches!(event.kind, EventKind::SessionStart) && cfg.collect.system_sampler.enabled
}

fn payload_pid(value: &Value) -> Option<u32> {
    value
        .get("pid")
        .and_then(|pid| pid.as_u64().map(|raw| raw as u32))
        .or_else(|| {
            value
                .get("pid")
                .and_then(Value::as_i64)
                .and_then(|raw| u32::try_from(raw).ok())
        })
}

fn spawn_outcome_measure(workspace: &Path, session_id: &str) {
    let args = vec![
        OsString::from("outcomes"),
        OsString::from("measure"),
        OsString::from("--workspace"),
        workspace.as_os_str().to_owned(),
        OsString::from("--session"),
        OsString::from(session_id),
    ];
    spawn_detached(args, "kaizen outcomes measure");
}

fn spawn_sampler_run(workspace: &Path, session_id: &str, pid: u32) {
    let args = vec![
        OsString::from("__sampler-run"),
        OsString::from("--workspace"),
        workspace.as_os_str().to_owned(),
        OsString::from("--session"),
        OsString::from(session_id),
        OsString::from("--pid"),
        OsString::from(pid.to_string()),
    ];
    spawn_detached(args, "kaizen sampler");
}

fn spawn_detached(args: Vec<OsString>, message: &str) {
    if let Err(error) = super::super::kaizen_child::spawn_kaizen_detached(&args) {
        tracing::warn!(?error, "{message}");
    }
}

fn touch_sampler_stop_file(workspace: &Path, session_id: &str) {
    let relative = std::path::PathBuf::from("sampler-stop").join(session_id);
    let Ok(path) = crate::core::paths::project_file_for_write(workspace, &relative) else {
        tracing::warn!("sampler-stop: invalid path");
        return;
    };
    if path.exists() {
        return;
    }
    if let Err(error) = crate::core::safe_fs::create_new(&path) {
        tracing::warn!(?error, "sampler-stop touch");
    }
}