kaizen-cli 0.1.44

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

// SPDX-License-Identifier: AGPL-3.0-or-later
//! Periodic transcript scanner owned by the daemon runtime.

use crate::store::Store;
use anyhow::Result;
use std::path::{Path, PathBuf};
use std::sync::{Mutex, OnceLock};

pub(super) async fn scanner_loop(ws: PathBuf) {
    loop {
        tokio::time::sleep(scan_interval(&ws)).await;
        scan_once(ws.clone()).await;
    }
}

async fn scan_once(ws: PathBuf) {
    if let Err(err) = tokio::task::spawn_blocking(move || scan_workspace(&ws)).await {
        tracing::warn!(%err, "daemon scanner task join failed");
    }
}

fn scan_workspace(ws: &Path) -> Result<()> {
    let _guard = scan_lock()
        .lock()
        .unwrap_or_else(|error| error.into_inner());
    let cfg = crate::core::config::load(ws)?;
    let store = Store::open(&crate::core::workspace::db_path(ws)?)?;
    let ws_str = ws.to_string_lossy().to_string();
    crate::shell::cli::maybe_scan_all_agents(ws, &cfg, &ws_str, &store, true)?;
    crate::shell::cli::maybe_auto_prune_after_scan(&store, &cfg)
}

fn scan_lock() -> &'static Mutex<()> {
    static LOCK: OnceLock<Mutex<()>> = OnceLock::new();
    LOCK.get_or_init(|| Mutex::new(()))
}

fn scan_interval(ws: &Path) -> std::time::Duration {
    let secs = crate::core::config::load(ws)
        .map(|cfg| cfg.scan.min_rescan_seconds.max(5))
        .unwrap_or(300);
    std::time::Duration::from_secs(secs)
}