feat(vis): read Rust-engine sessions from SQLite (records-based wire view)

vis was stranded after the engine switched to SQLite persistence (no more
wire.jsonl). Restore it from the engine's own stores:
- server: sqlite-store.ts read-only reader (node:sqlite, zero deps) for
  sessions.db/agent_tasks.db — list/detail/state/context snapshot/tasks/
  cron/agents (flat); KIMI_VIS_SOURCE=legacy|sqlite|auto (auto = engine
  home readable); routes branch on detail.source
- server: sqlite-records.ts projects records rows into the wire view —
  message.append -> context.append_message (normalized camelCase), tool
  call/result -> append_loop_event (pairing/hover/duration work as-is),
  usage/goal mapped, unknown types fall back to generic records;
  empty records return 200 + warnings instead of 404; context route
  rebuilds the full timeline (history=full semantics) from message.append
- web: unknown-type generic rendering + search-crash fix, sqlite source
  badge on list/detail (i18n en/zh)
- tests: vis/server 165 (incl. records fixture + wire projection),
  vis/web 20; root vitest 1168 green

Author: 7723qqq

CODEX_MIGRATION_PLAN.md

@@ -47,8 +47,9 @@
 ## 1.4 已知缺口（不阻塞主线的记录）
 
 1. ~~**compaction summarizer 双通道**~~ ✅ **已补（2026-08-10）**：`LlmCompactionDelegate`（任意 `LLM` 实现）+ `ensure_compaction_delegate` 宿主分支——无 native LLM 的 host-proxy 会话经 `HostLlmProxy`（`HostCallbacks::llm_chat`）走宿主通道 compact（原报 `compaction.unable`）；单测 + stdio 集成适配（`session_compact_host_proxy_gets_a_summarizer_delegate`）
-2. ~~**子代理 replay 数据源**~~ ✅ **已补（2026-08-10 数据源 + 2026-08-11 读取面）**：Task 工具子代理在任务被跟踪时（task_service 存在）经 `run_child_agent_persistent_with_model` 持久化对话到 session store（agent_id = task_id，swarm 同一机制）；读取面：`session/list` 支持 `include_subagents`（默认过滤子代理记录，opt-in 全量），`session/get_context` 支持 `include_subagents` → 响应 `subagents` 摘要列表（agent_id/消息数/updated_at，`SubagentSummaryRpc`）；单测 + stdio 集成（`session_list_and_context_include_subagents`）。**宿主接线待定**：vscode harness 的 `includeSubagents` 尚未透传到 RPC、replay-adapter 消费的是完整 replay 而非摘要（`parentAgentId` 关联引擎未持久化）——vscode 为白名单包，改需单独确认
+2. ~~**子代理 replay 数据源**~~ ✅ **已补（2026-08-10 数据源 + 2026-08-11 读取面 + 2026-08-12 精确配对）**：Task 工具子代理在任务被跟踪时（task_service 存在）经 `run_child_agent_persistent_with_model` 持久化对话到 session store（agent_id = task_id，swarm 同一机制）；读取面：`session/list` 支持 `include_subagents`（默认过滤子代理记录，opt-in 全量），`session/get_context` 支持 `include_subagents` → 响应 `subagents` 摘要列表（agent_id/消息数/updated_at，`SubagentSummaryRpc`）；**配对已精确化（2026-08-12）**：子代理持久化时盖章父 Task/swarm 工具调用 id（`parent_tool_call_id` 落 `state_json` 顶层键，旧记录 None 兼容），摘要透出该字段，vscode 配对改为精确匹配 + 未盖章 FIFO 兜底 + 盖章孤儿丢弃；swarm 子代理合成 replay 仍缺失（需 XML 结果解析或 child-context 读 RPC，后续项）
 3. **用户真实 config.toml 损坏**：`duplicate defaultModel`（defaultModel 与 default_model 并存）导致 Rust TOML 严格解析拒绝整个配置（用户禁止修改真实文件，隔离配置验证绕开；建议用户侧删 camelCase 行）
+4. ~~**vis 断代（Rust 引擎 SQLite 持久化后 wire.jsonl 不再写）**~~ ✅ **已闭环（2026-08-12）**：引擎 `records` 表生产接线（9 类事件：message.append/turn.started·ended/tool.call·result/usage.updated/goal.updated/compaction.started·completed，SessionStore/RecordStore 共享同一 SQLite 连接，集成测试 `session_prompt_writes_wire_records` 锁定）；vis/server 新增 SQLite reader（`sqlite-store.ts`，node:sqlite 只读，KIMI_VIS_SOURCE=legacy|sqlite|auto）恢复列表/detail/state/context 快照/tasks/cron/agents 平铺；wire 视图从 records 投影（`sqlite-records.ts`：message.append→context.append_message 等映射复用现有渲染器，空记录 200+warnings）；context 路由用 records 重建 full timeline（含被 compaction 丢弃的历史）；前端通用兜底 + sqlite 徽标。**剩余**：子代理不写 records（独立会话未接线）、TUI 直连路径（RUN_TURN）无 session_id 不写记录（需协议扩展）
 
 > **2026-08-10 收口复核**：原第 4-6 项已消失——vscode typecheck 全过（`replay-adapter.ts` 错误已随 sdk-local 完成消除）；kosong 已退役（flaky 测试随包）；发布打包已接入 CI（`_rust-bin-build.yml` + release 注入）；**vscode legacy backfill 已闭环**（kimi-runtime.ts 迁移会话读 `kimi_cli_source_path` → 写 `vscode_legacy_approval` metadata → session-runtime 消费，create/resume 全链路完整）。另：apps/kimi-code 的 `@moonshot-ai/kimi-agent` devDep 已删（全仓无真实 import，仅注释引用 wire.gen）。
 

apps/vis/server/src/config.ts

@@ -61,3 +61,26 @@ export function resolveVisAuthToken(host: string = resolveHost()): string | unde
 }
 
 export const KIMI_CODE_HOME: string = resolveKimiCodeHome();
+
+// ── session-data source selection (legacy dirs vs Rust engine SQLite) ───────
+
+export type VisSource = 'legacy' | 'sqlite' | 'auto';
+
+/**
+ * Which on-disk session source vis reads from:
+ *
+ * - `legacy` — the retired agent-core directory layout under
+ *   `<home>/sessions/<bucket>/<id>/` (state.json + wire.jsonl).
+ * - `sqlite` — the Rust engine's `$KIMI_AGENT_HOME/sessions.db` +
+ *   `agent_tasks.db` (read-only).
+ * - `auto` (default) — SQLite when the engine home's `sessions.db` is
+ *   readable, legacy directories otherwise.
+ *
+ * Read live from the env on every call (never cached) so tests and
+ * long-running processes can switch sources without a restart.
+ */
+export function resolveVisSource(): VisSource {
+  const raw = process.env['KIMI_VIS_SOURCE']?.trim().toLowerCase();
+  if (raw === 'legacy' || raw === 'sqlite') return raw;
+  return 'auto';
+}

apps/vis/server/src/lib/agent-record-types.ts

@@ -144,7 +144,8 @@ export interface SessionDetail {
   sessionId: string;
   /** Canonical on-disk session directory. Routes derive agent wire paths
    *  from this rather than the mutable `homedir` field inside `state.json`,
-   *  which can drift after fork/rename. */
+   *  which can drift after fork/rename. Empty for SQLite-sourced sessions
+   *  (no session directory exists). */
   sessionDir: string;
   workDir: string;
   state: unknown; // 原样透传，前端按 state.json 真实形状渲染
@@ -153,6 +154,10 @@ export interface SessionDetail {
   imported: boolean;
   /** Export/import provenance for imported sessions; null for local ones. */
   importMeta: ImportInfo | null;
+  /** Which on-disk source produced this detail: `'sqlite'` when read from
+   *  the Rust engine's `sessions.db`, absent/`'legacy'` for the directory
+   *  layout. Route handlers switch their readers on this flag. */
+  source?: 'sqlite' | 'legacy';
 }
 
 /** One line of `wire.jsonl` after vis has parsed (and possibly migrated)
@@ -174,11 +179,26 @@ export interface WireEntry {
   raw: unknown;
 }
 
+/** Parsed wire metadata. Legacy `wire.jsonl` carries only
+ *  `protocolVersion` / `createdAt`; the SQLite records source (Rust engine
+ *  `records` table) additionally reports `source: 'sqlite'` and the
+ *  distinct `record_type` values seen for the session. */
+export interface WireMetadata {
+  protocolVersion: string;
+  createdAt: number;
+  /** `'sqlite'` when the wire view was reconstructed from the engine's
+   *  `records` table instead of a legacy `wire.jsonl`. */
+  source?: 'sqlite';
+  /** Distinct engine record types (`message.append`, `tool.call`, …) in
+   *  first-seen order; absent for legacy wires. */
+  recordTypes?: string[];
+}
+
 export interface WireResponse {
   sessionId: string;
   agentId: string;
   protocolVersion: string;
-  metadata: { protocolVersion: string; createdAt: number };
+  metadata: WireMetadata;
   records: readonly WireEntry[];
   warnings: string[];
 }

apps/vis/server/src/lib/session-store.ts

@@ -6,6 +6,7 @@ import { createInterface } from 'node:readline';
 import type { SessionSummary, SessionDetail, AgentInfo, SessionHealth, ImportInfo } from './agent-record-types';
 import { compareAgentIds } from './agent-tree';
 import { importedDirOf, isImportId, listImportedIds, readImportMeta } from './import-store';
+import { isSqliteSourceActive, listSqliteSessions, readSqliteSessionDetail } from './sqlite-store';
 
 const SESSION_ID_RE = /^session_[A-Za-z0-9._-]+$/;
 const AGENT_ID_RE = /^[A-Za-z0-9._-]+$/;
@@ -38,7 +39,17 @@ interface StateJson {
   custom?: Record<string, unknown>;
 }
 
+/**
+ * List sessions, newest first. Source is selected per `KIMI_VIS_SOURCE`:
+ * `sqlite` (Rust engine `sessions.db`, read-only), `legacy` (directory
+ * layout), or `auto` (default) — SQLite when the engine home's
+ * `sessions.db` is readable, legacy directories otherwise. The legacy scan
+ * below only runs for the directory source.
+ */
 export async function listSessions(home: string): Promise<SessionSummary[]> {
+  if (isSqliteSourceActive()) {
+    return listSqliteSessions();
+  }
   const sessionsDir = join(home, 'sessions');
   const buckets = await readdir(sessionsDir, { withFileTypes: true }).catch(() => []);
   const index = await readSessionIndex(home);
@@ -69,6 +80,9 @@ export async function listSessions(home: string): Promise<SessionSummary[]> {
 }
 
 export async function readSessionDetail(home: string, sessionId: string): Promise<SessionDetail | null> {
+  if (isSqliteSourceActive()) {
+    return readSqliteSessionDetail(undefined, sessionId);
+  }
   if (isImportId(sessionId)) return readImportedDetail(home, sessionId);
   const sessionDir = await findSessionDir(home, sessionId);
   if (sessionDir === null) return null;
@@ -159,7 +173,7 @@ async function discoverAgentsFromDisk(sessionDir: string): Promise<AgentInfo[]>
       swarmItem: null,
     });
   }
-  return out.sort((a, b) => compareAgentIds(a.agentId, b.agentId));
+  return out.toSorted((a, b) => compareAgentIds(a.agentId, b.agentId));
 }
 
 async function tryReadSummary(
@@ -294,7 +308,7 @@ async function inventoryAgents(sessionDir: string, state: StateJson): Promise<Ag
       swarmItem: meta.swarmItem ?? null,
     });
   }
-  return result.sort((a, b) => compareAgentIds(a.agentId, b.agentId));
+  return result.toSorted((a, b) => compareAgentIds(a.agentId, b.agentId));
 }
 
 async function readState(sessionDir: string): Promise<StateJson | null> {