kaizen-cli 0.1.43

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

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

use super::{SpanBuilder, ToolSpanRecord, span_end, span_start};

impl ToolSpanRecord {
    pub(crate) fn from_builder(span: &SpanBuilder) -> Self {
        let started = span_start(span);
        let ended = span_end(span);
        Self {
            span_id: span.span_id.clone(),
            session_id: span.session_id.clone(),
            tool: span.tool.clone(),
            tool_call_id: span.tool_call_id.clone(),
            status: status(started, ended).to_owned(),
            started_at_ms: started,
            ended_at_ms: ended,
            lead_time_ms: lead_time(span),
            tokens_in: span.tokens_in,
            tokens_out: span.tokens_out,
            reasoning_tokens: span.reasoning_tokens,
            cost_usd_e6: span.cost_usd_e6,
            paths: span.paths.iter().cloned().collect(),
            parent_span_id: span.parent_span_id.clone(),
            depth: span.depth,
            subtree_cost_usd_e6: span.subtree_cost_usd_e6,
            subtree_token_count: span.subtree_token_count,
        }
    }
}

fn status(started: Option<u64>, ended: Option<u64>) -> &'static str {
    if started.is_some() && ended.is_some() {
        "done"
    } else {
        "orphaned"
    }
}

fn lead_time(span: &SpanBuilder) -> Option<u64> {
    elapsed(span.hook_start_ms, span.hook_end_ms).or_else(|| exact_call_lead_time(span))
}

fn exact_call_lead_time(span: &SpanBuilder) -> Option<u64> {
    if !span.call_start_exact || !span.result_end_exact {
        return None;
    }
    elapsed(span.call_start_ms, span.result_end_ms)
}

fn elapsed(start: Option<u64>, end: Option<u64>) -> Option<u64> {
    start.zip(end).map(|(start, end)| end.saturating_sub(start))
}