Monitoring.

// Module 12: Persist agent reasoning to SQLite
import Database from 'better-sqlite3';
import { mkdirSync } from 'node:fs';
import path from 'node:path';

const DATA_DIR = process.env.ACADEMY_DATA_DIR ?? './data';
const DB_DIR   = path.join(DATA_DIR, 'state');
mkdirSync(DB_DIR, { recursive: true });
const db = new Database(path.join(DB_DIR, 'traces.db'));

db.exec(`
  CREATE TABLE IF NOT EXISTS traces (
    run_id     TEXT NOT NULL,
    step       INTEGER NOT NULL,
    ts         TEXT NOT NULL,
    kind       TEXT NOT NULL,
    model      TEXT,
    content    TEXT,          -- JSON blob
    PRIMARY KEY (run_id, step)
  );
  CREATE INDEX IF NOT EXISTS idx_traces_ts   ON traces(ts);
  CREATE INDEX IF NOT EXISTS idx_traces_kind ON traces(kind);
`);

const insert = db.prepare(
  'INSERT INTO traces (run_id, step, ts, kind, model, content) VALUES (?, ?, ?, ?, ?, ?)'
);

export function recordTrace(runId: string, step: number, kind: string, model: string | null, content: unknown) {
  insert.run(runId, step, new Date().toISOString(), kind, model, JSON.stringify(content));
}

// Usage
recordTrace('run-42', 0, 'prompt',       'claude-opus-4-8', { system: '...', user: 'scan markets' });
recordTrace('run-42', 1, 'assistant',    'claude-opus-4-8', { text: 'I will first call browse_markets' });
recordTrace('run-42', 2, 'tool_call',    null,              { name: 'browse_markets', input: { limit: 20 } });
recordTrace('run-42', 3, 'tool_result',  null,              { output: { n: 20 } });
recordTrace('run-42', 4, 'assistant',    'claude-opus-4-8', { text: 'Nothing interesting, stopping.' });

// Example daily-audit query:
//   SELECT kind, COUNT(*) FROM traces WHERE ts > date('now', '-1 day') GROUP BY kind;

# Module 12: Persist agent reasoning to SQLite
import json
import os
import sqlite3
from datetime import datetime
from pathlib import Path
from typing import Any

DATA_DIR = Path(os.environ.get("ACADEMY_DATA_DIR", "./data"))
DB_PATH  = DATA_DIR / "state" / "traces.db"
DB_PATH.parent.mkdir(parents=True, exist_ok=True)

conn = sqlite3.connect(DB_PATH, isolation_level=None)
conn.executescript("""
  CREATE TABLE IF NOT EXISTS traces (
    run_id     TEXT NOT NULL,
    step       INTEGER NOT NULL,
    ts         TEXT NOT NULL,
    kind       TEXT NOT NULL,
    model      TEXT,
    content    TEXT,          -- JSON blob
    PRIMARY KEY (run_id, step)
  );
  CREATE INDEX IF NOT EXISTS idx_traces_ts   ON traces(ts);
  CREATE INDEX IF NOT EXISTS idx_traces_kind ON traces(kind);
""")


def record_trace(run_id: str, step: int, kind: str, model: str | None, content: Any) -> None:
    conn.execute(
        "INSERT INTO traces (run_id, step, ts, kind, model, content) VALUES (?, ?, ?, ?, ?, ?)",
        (run_id, step, datetime.utcnow().isoformat(), kind, model, json.dumps(content, default=str)),
    )


# Usage
record_trace("run-42", 0, "prompt",      "claude-opus-4-8", {"system": "...", "user": "scan markets"})
record_trace("run-42", 1, "assistant",   "claude-opus-4-8", {"text": "I will first call browse_markets"})
record_trace("run-42", 2, "tool_call",   None,              {"name": "browse_markets", "input": {"limit": 20}})
record_trace("run-42", 3, "tool_result", None,              {"output": {"n": 20}})
record_trace("run-42", 4, "assistant",   "claude-opus-4-8", {"text": "Nothing interesting, stopping."})

# Example daily-audit query:
#   SELECT kind, COUNT(*) FROM traces WHERE ts > date('now', '-1 day') GROUP BY kind;