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

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

mod open;
mod requests;
mod responses;

use super::view::{DetailData, DetailState, EventView, SessionView};
use super::worker::{StoreRequest, StoreResponse};
use crate::core::event::{Event, SessionRecord};
use crate::metrics::types::MetricsReport;
use crate::visualization::VisualizationReport;
use arc_swap::ArcSwapOption;
use std::collections::HashMap;
use std::sync::{
    Arc,
    atomic::{AtomicBool, Ordering},
};
use tokio::sync::{Notify, mpsc};

pub(super) const DEFAULT_VIEWPORT_HEIGHT: usize = 32;

pub(super) struct App {
    pub(super) sessions: SessionView,
    pub(super) events: EventView,
    pub(super) detail_state: DetailState,
    pub(super) agent_filter: String,
    pub(super) filter_mode: bool,
    pub(super) filter_buf: String,
    pub(super) clipboard_note: String,
    pub(super) left_focus: bool,
    pub(super) show_help: bool,
    pub(super) detail: bool,
    pub(super) show_metrics: bool,
    pub(super) metrics: Option<MetricsReport>,
    pub(super) visualization: Option<VisualizationReport>,
    pub(super) metrics_cache: Arc<ArcSwapOption<MetricsReport>>,
    pub(super) visualization_cache: Arc<ArcSwapOption<VisualizationReport>>,
    pub(super) report_dirty: Arc<AtomicBool>,
    pub(super) report_notify: Arc<Notify>,
    pub(super) pulse: bool,
    pub(super) workspace: String,
    pub(super) store_tx: mpsc::UnboundedSender<StoreRequest>,
    pub(super) store_rx: mpsc::UnboundedReceiver<StoreResponse>,
    pub(super) feedback_scores: HashMap<String, u8>,
    pub(super) feedback_token: u64,
    pub(super) detail_token: u64,
    pub(super) last_session_id: Option<String>,
    pub(super) session_viewport_height: usize,
    pub(super) event_viewport_height: usize,
    pub(super) error_note: String,
}

impl App {
    pub(super) fn sync_metrics_cache(&mut self) {
        self.metrics = self.metrics_cache.load_full().as_deref().cloned();
        self.visualization = self.visualization_cache.load_full().as_deref().cloned();
    }

    pub(super) fn mark_report_dirty(&self) {
        self.report_dirty.store(true, Ordering::Release);
        self.report_notify.notify_one();
    }

    pub(super) fn selected_session(&self) -> Option<&SessionRecord> {
        self.sessions.selected()
    }

    pub(super) fn selected_id(&self) -> Option<&str> {
        self.selected_session().map(|session| session.id.as_str())
    }

    pub(super) fn selected_event(&self) -> Option<&Event> {
        self.events.selected()
    }
}