THE MESSAGE IS THE UNIT OF COVERAGE (vision-extraction-coverage.md): a per-chat append-only ledger (coverage.jsonl) records which messages the pipeline has extracted, by content fingerprint over exactly what the extraction view sees (one shared line builder — core/coverage.ts); the uncovered remainder is DERIVED at read time, never dual-tracked. A quiz answer merging into the asking message re-opens only that message; plan-block data-part attach never re-opens anything. - The trigger (turn-service) replaces every-3-quiz-answers with uncovered-tokens >= EXTRACTION.chunkTokens (4096) — quiz-less sessions extract too, content size is the honest signal. - runExtraction is now chunked: token-budgeted batches of the oldest uncovered consecutive messages (a tool call + result never split), each merged batch checkpointing its messages' coverage atomically — an abort or error loses at most the in-flight batch; merged batches stay covered. - Observation refs are batch-tagged (obs:<batchTag>:<sourceId>): re-runs of the same batch dedupe; a re-opened message's fresh understanding lands as a new event. Fixes the old obs:p1 position-collision. - New API: GET /api/graph/coverage (exact per-session derived coverage + running flags, most-uncovered first) and POST /api/graph/coverage/extract (manual run for one session, 409 while in flight). - Graph view chrome: the coverage button opens a panel with every session's covered/uncovered tokens and a per-session Extract button — the manual answer to aborted runs, errors, and dormant tails. Renders even when the graph is empty: an empty graph with uncovered sessions is exactly when it matters. Polls only while open. - Notes imports keep the whole-file checkpoint path (coverage undefined). - Tests: pure-core coverage suite (11), chunked-pipeline suite (3: multi-batch + no-op, abort-keeps-earlier-batches + remainder re-run, re-open alone + data-part invisibility), panel render suite (5); pendingQuizAnswers and its tests deleted as dead code. 486/486. Live-smoked on real GLM: manual extract of "teach me modal realism" ran one batch, wrote 4 coverage entries, panel flipped to "1.3k covered · complete" with the button disabled, graph refetched (nodes 11), usage persisted with real stats.
116 lines
5.6 KiB
TypeScript
116 lines
5.6 KiB
TypeScript
import path from "node:path";
|
|
import { fileURLToPath } from "node:url";
|
|
|
|
/** Repository root (this file is at <root>/config.ts). */
|
|
export const ROOT = path.dirname(fileURLToPath(import.meta.url));
|
|
|
|
export const PATHS = {
|
|
root: ROOT,
|
|
/** Teacher system prompt — the agent's instructions (src/agent/). */
|
|
teacherPrompt: path.join(ROOT, "src", "agent", "system-prompt.md"),
|
|
data: path.join(ROOT, "data"),
|
|
/** Chat sessions (AI SDK UIMessage transcripts, one JSON file per chat). */
|
|
chats: path.join(ROOT, "data", "chats"),
|
|
graph: path.join(ROOT, "data", "graph"),
|
|
} as const;
|
|
|
|
// ─── Models ────────────────────────────────────────────────────────────────
|
|
// THE single place every LLM is chosen and tuned. .env stays for secrets
|
|
// (API keys) only — model choice and thinking budget are product tuning,
|
|
// not deployment environment, and this section is the one place they grow.
|
|
// `effort` is pi's thinking-level scale (off|minimal|low|medium|high|xhigh
|
|
// |max): the per-model truth lives in pi-ai's catalog (thinkingLevelMap) —
|
|
// getSupportedThinkingLevels(model) lists what a model actually accepts,
|
|
// and streamSimple clamps any other value to the nearest supported one
|
|
// (e.g. GLM-5.3-flash supports exactly low|high|max).
|
|
|
|
export type ThinkingLevel = "off" | "minimal" | "low" | "medium" | "high" | "xhigh" | "max";
|
|
|
|
export interface ModelSpec {
|
|
/** OpenRouter model id (e.g. "z-ai/glm-5.3-flash") — must exist in pi-ai's catalog. */
|
|
model: string;
|
|
/** Thinking budget — what the model may spend on reasoning tokens. */
|
|
effort: ThinkingLevel;
|
|
}
|
|
|
|
export const MODELS = {
|
|
/** The prober (agent A) — edge-bracketing questions; keep it lively and adaptive. */
|
|
prober: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
/** The teacher (agent B) — planning + streaming, lesson-facing: smart, but keep it lively. */
|
|
teacher: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
/** Background sub-agents: fast and cheap beats deep thought. */
|
|
researcher: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
demoBuilder: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
/** Must be vision-capable: it looks at rendered SVGs. */
|
|
visualMaker: { model: "qwen/qwen3.8-flash", effort: "low" },
|
|
/** Extraction is judgment over given evidence — light thinking suffices. */
|
|
extractor: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
/** The auditor verifies evidence exists; keep it cheap. */
|
|
auditor: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
/** Names detected communities — one singular call, given member names
|
|
* + statements. Purely a labeling flourish; keep it cheap. */
|
|
labeler: { model: "z-ai/glm-5.3-flash", effort: "low" },
|
|
} satisfies Record<string, ModelSpec>;
|
|
|
|
export type ModelRole = keyof typeof MODELS;
|
|
|
|
/**
|
|
* The extraction pipeline (vision §1 construction): the sole graph writer.
|
|
* Triggered per chat once this many NEW quiz answers have landed since the
|
|
* chat's last extraction checkpoint. The trigger mechanism is a v1
|
|
* placeholder — deliberately isolated behind one seam
|
|
* (server/turn-service.ts) so it can be swapped without touching the
|
|
* pipeline.
|
|
*/
|
|
/**
|
|
* The extraction trigger (vision-extraction-coverage.md, 2026-09-15): a run
|
|
* fires when a chat's UNCOVERED transcript tokens reach the chunk budget.
|
|
* Runs are token-budgeted batches of the oldest uncovered messages — this
|
|
* knob is the transcript share of the extractor's context (it also carries
|
|
* the whole graph + instructions), so it bounds both cost and chunk size.
|
|
* Replaces the old every-3-quiz-answers trigger, which never fired for
|
|
* quiz-less sessions.
|
|
*/
|
|
export const EXTRACTION = { chunkTokens: 4096 } as const;
|
|
|
|
/**
|
|
* The LIVE graph store (src/store/graph.ts) — owned by the app's extraction
|
|
* pipeline. Line shapes: src/core/contracts.ts.
|
|
*/
|
|
export const LEDGER_FILES = {
|
|
nodes: path.join(PATHS.graph, "nodes.jsonl"),
|
|
edges: path.join(PATHS.graph, "edges.jsonl"),
|
|
events: path.join(PATHS.graph, "events.jsonl"),
|
|
mappings: path.join(PATHS.graph, "mappings.jsonl"),
|
|
sessions: path.join(PATHS.graph, "sessions.jsonl"),
|
|
/** Per-message extraction coverage (contracts/graph.ts CoverageEntry;
|
|
* the checkpoint's replacement for chat extractions — notes keep
|
|
* sessions.jsonl, whole-file as they are). */
|
|
coverage: path.join(PATHS.graph, "coverage.jsonl"),
|
|
/** LLM-named community records (contracts/graph.ts ClusterLabeling). */
|
|
clusterLabels: path.join(PATHS.graph, "cluster-labels.jsonl"),
|
|
} as const;
|
|
|
|
/**
|
|
* Notes-import bookkeeping (NOT a ledger): one JSON map, src-id → NotesSource
|
|
* record (contracts/graph.ts) — the file path + import time + the run's usage
|
|
* log. Read-modify-write like a chat file, not append-only like the ledgers.
|
|
*/
|
|
export const SOURCES_FILE = path.join(PATHS.graph, "sources.json");
|
|
/** The layout ledger (read-modify-write like sources.json): nodeId →
|
|
* {x,y} resting positions from the incremental settle (core/layout.ts).
|
|
* Carries an updatedAt stamp for future live-physics conflict handling. */
|
|
export const POSITIONS_FILE = path.join(PATHS.graph, "positions.json");
|
|
|
|
/** The embedding ledger: one L2-normalized vector per node id, all from
|
|
* ONE model (swapping models re-embeds everything — vectors from
|
|
* different models live in incompatible spaces). Read-modify-write
|
|
* JSON like positions/sources. */
|
|
export const EMBEDDINGS_FILE = path.join(PATHS.graph, "embeddings.json");
|
|
|
|
/**
|
|
* Graph render settings (the settings-panel controls): one small JSON blob,
|
|
* read-modify-write. Shared shape/sanitizer: src/core/render-settings.ts.
|
|
*/
|
|
export const RENDER_SETTINGS_FILE = path.join(PATHS.graph, "render-settings.json");
|