refactor(lab): session 类型迁移到 @earendil-works/pi-agent-core

api.ts 手写的 SessionEvent/SessionMessage/AssistantContent/ToolResultContent
类型替换为 pi-agent-core 的标准 Entry/MessageEntry/AgentMessage 类型,
与 pi 的 session JSONL 格式保持同步。

改动:
- 安装 @earendil-works/pi-agent-core + @earendil-works/pi-telemetry
- api.ts: SessionEvent -> Entry, re-export Entry/MessageEntry
- metrics.ts: computeSessionMetrics(events: Entry[]), 用 msgTimestamp()
  辅助函数从 AgentMessage 提取 timestamp (所有变体都有此字段)
- 新增类型覆盖 compaction/branch_summary/active_tools_change 等,
  被 type==='message' 过滤自然忽略

验证: typecheck + build 通过, JS bundle 51.76->51.58KB (仅类型导入,
无运行时依赖被打包), CSS 不变 366KB

Author: CornWorld

lab/package.json

@@ -11,6 +11,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
+    "@earendil-works/pi-agent-core": "^0.84.2",
+    "@earendil-works/pi-telemetry": "^0.84.2",
     "@solidjs/router": "^1.0.0",
     "solid-js": "^1.9.15"
   },

lab/src/api.ts

@@ -1,4 +1,10 @@
 // API client + types for the artifacts-server.
+// Session event types are imported from @earendil-works/pi-agent-core
+// instead of hand-written, to stay in sync with pi's session JSONL format.
+
+import type { Entry } from "@earendil-works/pi-agent-core";
+
+export type { Entry, MessageEntry } from "@earendil-works/pi-agent-core";
 
 export interface RunSummary {
   id: string;
@@ -41,52 +47,10 @@ async function get<T>(url: string): Promise<T> {
   return res.json();
 }
 
-// ── Session event types (raw pi session JSONL) ──
-
-/** A single session event as recorded by pi's --session-dir. */
-export type SessionEvent =
-  | { type: "session"; id: string }
-  | { type: "model_change"; modelId: string; provider: string }
-  | { type: "thinking_level_change"; level: string | null }
-  | { type: "message"; message: SessionMessage };
-
-export type SessionMessage =
-  | { role: "user"; content: string; timestamp: number }
-  | {
-      role: "assistant";
-      content: AssistantContent[];
-      usage: {
-        input: number;
-        output: number;
-        cacheRead: number;
-        cacheWrite: number;
-        reasoning: number;
-      };
-      stopReason: string;
-      model: string;
-      provider: string;
-      timestamp: number;
-    }
-  | {
-      role: "toolResult";
-      content: ToolResultContent[];
-      toolName: string;
-      isError: boolean;
-      timestamp: number;
-    };
-
-export type AssistantContent =
-  | { type: "text"; text: string }
-  | { type: "toolCall"; id: string; name: string; args: unknown };
-
-export type ToolResultContent =
-  | { type: "text"; text: string }
-  | { type: "resource"; resource: unknown };
-
 export const api = {
   runs: () => get<RunSummary[]>("/api/runs"),
   run: (id: string) => get<RunDetail>(`/api/runs/${id}`),
-  session: (id: string) => get<SessionEvent[]>(`/api/runs/${id}/session`),
+  session: (id: string) => get<Entry[]>(`/api/runs/${id}/session`),
   file: async (id: string, path: string): Promise<string> => {
     const res = await fetch(
       `/api/runs/${id}/file?path=${encodeURIComponent(path)}`

lab/src/lib/metrics.ts

@@ -1,5 +1,6 @@
-import type { SessionEvent, RunDetail } from "../api";
+import type { Entry, RunDetail } from "../api";
 import { fmtSec, fmtNum } from "./format";
+import type { AgentMessage } from "@earendil-works/pi-agent-core";
 
 // ── session metrics (computed client-side from raw session events) ──
 // NOTE on timestamps: an assistant message's timestamp is when the model request
@@ -37,40 +38,30 @@ export interface SessionMetrics {
   rounds: SessionRound[];
 }
 
-export function computeSessionMetrics(events: SessionEvent[]): SessionMetrics {
+/** Extract timestamp from an AgentMessage (all variants carry timestamp). */
+function msgTimestamp(m: AgentMessage): number {
+  return (m as { timestamp: number }).timestamp;
+}
+
+export function computeSessionMetrics(events: Entry[]): SessionMetrics {
   const messages = events
     .map((event, index) => ({ event, index }))
     .filter((x) => x.event.type === "message");
+  const ts = (x: { event: Entry }) =>
+    x.event.type === "message" ? msgTimestamp(x.event.message) : NaN;
+
   const timestampAdjusted =
-    messages.some(
-      (x) =>
-        x.event.type === "message" &&
-        !Number.isFinite(
-          (x.event as Extract<SessionEvent, { type: "message" }>).message
-            .timestamp
-        )
-    ) ||
+    messages.some((x) => !Number.isFinite(ts(x))) ||
     messages.some(
       (x, i) =>
         i > 0 &&
-        x.event.type === "message" &&
-        messages[i - 1].event.type === "message" &&
-        Number.isFinite(
-          (x.event as Extract<SessionEvent, { type: "message" }>).message
-            .timestamp
-        ) &&
-        Number.isFinite(
-          (messages[i - 1].event as Extract<SessionEvent, { type: "message" }>)
-            .message.timestamp
-        ) &&
-        (x.event as Extract<SessionEvent, { type: "message" }>).message
-          .timestamp <
-          (messages[i - 1].event as Extract<SessionEvent, { type: "message" }>)
-            .message.timestamp
+        Number.isFinite(ts(x)) &&
+        Number.isFinite(ts(messages[i - 1])) &&
+        ts(x) < ts(messages[i - 1])
     );
   messages.sort((a, b) => {
-    const at = a.event.type === "message" ? a.event.message.timestamp : NaN;
-    const bt = b.event.type === "message" ? b.event.message.timestamp : NaN;
+    const at = ts(a),
+      bt = ts(b);
     if (Number.isFinite(at) && Number.isFinite(bt))
       return at - bt || a.index - b.index;
     if (Number.isFinite(at)) return -1;
@@ -100,11 +91,11 @@ export function computeSessionMetrics(events: SessionEvent[]): SessionMetrics {
   }[] = [];
   for (const { event } of messages) {
     if (event.type !== "message") continue;
-    const m = event.message,
-      ts = m.timestamp;
-    if (Number.isFinite(ts)) {
-      firstTs = Math.min(firstTs, ts);
-      lastTs = Math.max(lastTs, ts);
+    const m = event.message;
+    const mts = msgTimestamp(m);
+    if (Number.isFinite(mts)) {
+      firstTs = Math.min(firstTs, mts);
+      lastTs = Math.max(lastTs, mts);
     }
     if (m.role === "assistant") {
       modelRequests++;
@@ -121,7 +112,7 @@ export function computeSessionMetrics(events: SessionEvent[]): SessionMetrics {
           tools.push(part.name);
         }
       assistantMsg.push({
-        ts,
+        ts: mts,
         model: m.model,
         stopReason: m.stopReason,
         input: m.usage?.input ?? 0,