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

use super::super::Store;
use super::outbox_support::{
    create_legacy, legacy_path, migrated_path, migration_marker, pending_rows, seed_sqlite,
};
use tempfile::TempDir;

#[test]
fn locked_legacy_outbox_fails_without_mutating_either_store() {
    let dir = TempDir::new().unwrap();
    let db = seeded_db(&dir);
    let legacy = create_legacy(dir.path(), &[("legacy", "events", "row")]).unwrap();

    assert!(Store::open(&db).is_err());
    assert_untouched(&dir, &db);
    drop(legacy);
}

#[test]
fn corrupt_legacy_outbox_fails_without_mutating_either_store() {
    let dir = TempDir::new().unwrap();
    let db = seeded_db(&dir);
    std::fs::create_dir_all(dir.path().join("hot")).unwrap();
    std::fs::write(legacy_path(dir.path()), b"not a redb database").unwrap();
    let before = std::fs::read(legacy_path(dir.path())).unwrap();

    assert!(Store::open(&db).is_err());
    assert_untouched(&dir, &db);
    assert_eq!(std::fs::read(legacy_path(dir.path())).unwrap(), before);
}

#[test]
fn read_only_open_never_migrates_legacy_outbox() {
    let dir = TempDir::new().unwrap();
    let db = seeded_db(&dir);
    drop(create_legacy(dir.path(), &[("legacy", "events", "row")]).unwrap());

    let store = Store::open_read_only(&db).unwrap();
    assert_eq!(pending_rows(&store), vec![sqlite_row()]);
    assert!(legacy_path(dir.path()).is_file());
    assert!(!migrated_path(dir.path()).exists());
}

fn seeded_db(dir: &TempDir) -> std::path::PathBuf {
    let db = dir.path().join("kaizen.db");
    let store = Store::open(&db).unwrap();
    seed_sqlite(&store, &[("sqlite", "events", "sqlite-row")]);
    db
}

fn assert_untouched(dir: &TempDir, db: &std::path::Path) {
    let store = Store::open_read_only(db).unwrap();
    assert_eq!(pending_rows(&store), vec![sqlite_row()]);
    assert!(migration_marker(&store).is_none());
    assert!(legacy_path(dir.path()).is_file());
    assert!(!migrated_path(dir.path()).exists());
}

fn sqlite_row() -> (String, String, String) {
    ("sqlite".into(), "events".into(), "sqlite-row".into())
}