Amos
1c3d288d08
- core/phases.ts: Phase3 (probe/plan/teach) + pure derivations — phaseOfTree (point-in-time, from the stored plan tree: no nodes → probe, no occupied node → plan, occupied → teach) and phaseAt3 (monotonic transcript fold for the dividers: failed plan_init never marks a seam; phase only advances). - contracts.ts: ChatSummary gains record-derived phase + pendingQuestion; ChatListItem adds liveness-merged busy. - store/chats.ts listChats computes the record-derived fields (tree + pending question scan). - api/chats route merges busy = turn running || running background job. Lane crossing granted by master: contracts/store/api (schema arbitration). Data-only inference: pre-plan planning reads as probe until the plan lands.
96 lines
3.2 KiB
TypeScript
96 lines
3.2 KiB
TypeScript
/**
|
|
* ChatStore — the fs JSON adapter (one file per chat in data/chats/).
|
|
*
|
|
* Implements core/ports.ts ChatStore; the record shapes live in
|
|
* core/contracts.ts (ChatRecord/ChatSummary). Idioms: sync fs, tiny
|
|
* records, id-guarded filenames, JSON with tab indentation. Wired in the
|
|
* composition root (src/server/stores.ts); nothing else constructs it.
|
|
*/
|
|
|
|
import * as fs from "node:fs";
|
|
import * as path from "node:path";
|
|
import { PATHS } from "../../config.ts";
|
|
import type { ChatStore } from "../core/ports.ts";
|
|
import type { ChatRecord, ChatSummary, PlanTree } from "../core/contracts.ts";
|
|
import type { UIMessage } from "ai";
|
|
import { findPendingToolCall } from "../core/pending.ts";
|
|
import { phaseOfTree } from "../core/phases.ts";
|
|
|
|
function chatFile(id: string): string {
|
|
if (!/^[A-Za-z0-9_-]+$/.test(id)) throw new Error(`Invalid chat id: ${id}`);
|
|
return path.join(PATHS.chats, `${id}.json`);
|
|
}
|
|
|
|
function createChat(title: string): ChatRecord {
|
|
const now = new Date().toISOString();
|
|
const record: ChatRecord = {
|
|
id: `chat_${Date.now().toString(36)}_${crypto.randomUUID().slice(0, 8)}`,
|
|
title: title.trim() || "Untitled session",
|
|
createdAt: now,
|
|
updatedAt: now,
|
|
messages: [],
|
|
};
|
|
fs.mkdirSync(PATHS.chats, { recursive: true });
|
|
fs.writeFileSync(chatFile(record.id), JSON.stringify(record, null, "\t"), "utf-8");
|
|
return record;
|
|
}
|
|
|
|
function getChat(id: string): ChatRecord | null {
|
|
try {
|
|
return JSON.parse(fs.readFileSync(chatFile(id), "utf-8")) as ChatRecord;
|
|
} catch {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
function listChats(): ChatSummary[] {
|
|
try {
|
|
fs.mkdirSync(PATHS.chats, { recursive: true });
|
|
return fs
|
|
.readdirSync(PATHS.chats)
|
|
.filter((f) => f.endsWith(".json"))
|
|
.map((f) => getChat(f.slice(0, -5)))
|
|
.filter((r): r is ChatRecord => r !== null)
|
|
.map(({ messages, tree, ...summary }) => ({
|
|
...summary,
|
|
messageCount: messages.length,
|
|
// Record-derived status for the session picker: phase from the
|
|
// stored plan tree, pending question from the transcript's last
|
|
// unanswered quiz/ask part. Liveness (busy) is NOT record-derived —
|
|
// the API route merges it (contracts.ts ChatListItem).
|
|
phase: phaseOfTree(tree),
|
|
pendingQuestion: findPendingToolCall(messages) !== null,
|
|
}))
|
|
.sort((a, b) => b.updatedAt.localeCompare(a.updatedAt));
|
|
} catch {
|
|
return [];
|
|
}
|
|
}
|
|
|
|
/** Persist the full message list (client state + new response) after a turn. */
|
|
function saveMessages(id: string, messages: UIMessage[]): void {
|
|
const record = getChat(id);
|
|
if (!record) throw new Error(`Chat not found: ${id}`);
|
|
record.messages = messages;
|
|
record.updatedAt = new Date().toISOString();
|
|
fs.writeFileSync(chatFile(id), JSON.stringify(record, null, "\t"), "utf-8");
|
|
}
|
|
|
|
/** Persist the session plan tree (plan tools call this in execute). */
|
|
function saveTree(id: string, tree: PlanTree): void {
|
|
const record = getChat(id);
|
|
if (!record) throw new Error(`Chat not found: ${id}`);
|
|
record.tree = tree;
|
|
// Deliberately does NOT bump updatedAt: tree mutations piggyback on the
|
|
// turn's saveMessages, and sidebar ordering shouldn't churn on tree edits.
|
|
fs.writeFileSync(chatFile(id), JSON.stringify(record, null, "\t"), "utf-8");
|
|
}
|
|
|
|
export const chatStore: ChatStore = {
|
|
createChat,
|
|
getChat,
|
|
listChats,
|
|
saveMessages,
|
|
saveTree,
|
|
};
|