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

export function createTransport(options) {
  let socket = null;
  let everOpened = false;
  let reconnectTimer = 0;
  let reconnectMs = 1_000;

  function connect() {
    clearTimeout(reconnectTimer);
    socket = new WebSocket(options.url());
    socket.addEventListener("open", opened);
    socket.addEventListener("close", closed);
    socket.addEventListener("message", event => options.onMessage(event.data));
  }

  function opened() {
    everOpened = true;
    reconnectMs = 1_000;
    options.onOpen();
  }

  function closed() {
    if (!everOpened) return options.onAuthFailure();
    options.onDisconnect();
    reconnectTimer = setTimeout(connect, reconnectMs);
    reconnectMs = Math.min(reconnectMs * 2, 10_000);
  }

  function send(value) {
    if (!isOpen()) return false;
    socket.send(JSON.stringify(value));
    return true;
  }

  function isOpen() {
    return socket?.readyState === WebSocket.OPEN;
  }

  return { connect, isOpen, send };
}