feat: 重构性能监视器，更新相关文档和测试用例，优化会话切换时的性能恢复

Author: chenlongapps

ROADMAP.md

@@ -59,6 +59,7 @@ TTFT  2.7s
 目标：提供可查询的价格目录，便于用户了解不同模型的计费档位。
 
 * [ ] 构建公开价格目录，包含模型、价格档位及阈值
+* [ ] 只收录半年内发布的模型
 <!-- TODO -->
 
 ## v0.4.0 — 用量命令

docs/verification.md

@@ -2,26 +2,28 @@
 
 ## 未发布（SDK 2.0.11）
 
-验证日期：2026-09-20。环境：macOS、Node.js v22.23.2、npm 10.9.8、OpenCode v2.0.11；`@opencode/plugin`、`@opencode/client`、`@opencode/schema` 和 `@opencode/theme` 均精确锁定为 2.0.11。
+验证日期：2026-09-22。环境：macOS、Node.js v22.23.2、npm 10.9.8、OpenCode v2.0.11；`@opencode/plugin`、`@opencode/client`、`@opencode/schema` 和 `@opencode/theme` 均精确锁定为 2.0.11。
 
 ### 自动化检查
 
 | 检查 | 结果 |
 | --- | --- |
 | `npm run typecheck` | 通过 |
-| `npm test` | 29 项通过 |
+| `npm test` | 31 项通过 |
 | `npm run build` | 通过，输出 ESM 与类型声明 |
 | `npm run test:smoke` | 通过，使用实际 `.tgz` 安装产物和真实 OpenCode 2.0.11 |
 
 SDK 从 2.0.9 升级到 2.0.11 后，四个顶层 OpenCode 包及锁文件中的传递依赖均已统一到 2.0.11。`@opencode/plugin` 两版的导出结构一致；包内容差异除依赖版本外，仅为 `ToastOptions` 新增可选的 `sessionID` 类型字段。
 
+新增共享性能监视器测试覆盖：查看会话 A 时捕获独立会话 B 的流，切换到 B 后立即恢复实时 TPS/TTFT；生成中切走、继续接收 delta 再切回；控制器销毁重建后恢复共享流；不同会话树隔离、新子代理即时纳入，以及删除会话清理运行期状态。既有重复事件去重与完成后收敛为精确 TPS 的断言继续通过。
+
 ### 真实 OpenCode 集成
 
-隔离 smoke 测试确认打包插件可加载；空会话隐藏无数据行；活动 TPS 估算会收敛为精确值；TTFT、token、上下文与费用正常刷新；真实子代理用量可从父子视图累计且上下文保持会话局部；切换活动模型会同步更新价格选择与上下文上限。测试产物保存在 `/var/folders/rw/bmx6c8hd737brl55m0_ff_b80000gn/T/token-usage-smoke-JXe1KG`。
+隔离 smoke 测试确认打包插件可加载；空会话隐藏无数据行；在独立会话已经开始慢速流后，同一 TUI 切换过去会立即显示 `TPS ~…` 与 TTFT，完成后变为无 `~` 的精确 TPS；既有 token、上下文与费用刷新、真实子代理全树累计、会话局部上下文及模型切换验证均继续通过。测试产物保存在 `/var/folders/rw/bmx6c8hd737brl55m0_ff_b80000gn/T/token-usage-smoke-cgsCK2`。
 
 ### 验证边界
 
-当前 SDK 2.0.11 与宿主 2.0.11 的组合已完整验证。2.0.9 和 2.0.10 宿主的历史验证记录保留在下方，但升级 SDK 后未重新执行这两个旧宿主的打包矩阵：本地仅有 2.0.11，官方 GitHub Releases 也没有可获取的对应旧版本资产。后续升级 SDK 或宿主时，仍需重新核对分叉副本、compaction 排序及 step/delta 事件语义。
+当前 SDK 2.0.11 与宿主 2.0.11 的组合已完整验证。验证时机器默认宿主已是 2.0.12，因此 smoke 使用校验完整性的官方 `@opencode/cli-darwin-arm64@2.0.11` 隔离二进制，没有放宽宿主版本断言。2.0.9 和 2.0.10 宿主的历史验证记录保留在下方，但升级 SDK 后未重新执行这两个旧宿主的打包矩阵。后续升级 SDK 或宿主时，仍需重新核对分叉副本、compaction 排序及 step/delta 事件语义。
 
 ## v0.2.1（TPS 与 TTFT）
 

opencode.jsonc

@@ -50,7 +50,9 @@ const mock = createServer(async (request, response) => {
     const data = JSON.parse(body);
     requests.push(data);
     const lastUser = data.messages.findLastIndex(message => message.role === "user");
-    const spawnChild = JSON.stringify(data.messages[lastUser]).includes("SPAWN_SMOKE_CHILD")
+    const userText = JSON.stringify(data.messages[lastUser]);
+    const switchSmoke = userText.includes("SWITCH_SMOKE");
+    const spawnChild = userText.includes("SPAWN_SMOKE_CHILD")
       && !data.messages.slice(lastUser + 1).some(message => message.role === "tool");
     const tool = data.tools?.find(tool => tool.function.name === "subagent");
     const toolCalls = spawnChild && tool ? [{ index: 0, id: "usage-smoke-child", type: "function", function: {
@@ -71,7 +73,7 @@ const mock = createServer(async (request, response) => {
       chunk({ role: "assistant" });
       await new Promise(resolve => setTimeout(resolve, 300));
       chunk(toolCalls ? { tool_calls: toolCalls } : { content: content.slice(0, 4) });
-      await new Promise(resolve => setTimeout(resolve, 700));
+      await new Promise(resolve => setTimeout(resolve, switchSmoke ? 2_500 : 700));
       if (content) chunk({ content: content.slice(4) });
       await new Promise(resolve => setTimeout(resolve, 100));
       chunk({}, toolCalls ? "tool_calls" : "stop", usage);
@@ -131,7 +133,8 @@ const openTui = sessionID => {
     await writeFile(path.join(work, `${name}.txt`), screen());
     await writeFile(path.join(work, `${name}.ansi`), raw);
   };
-  const entry = { process, screen, save, terminal };
+  const send = data => process.stdin.write(data);
+  const entry = { process, screen, save, send, terminal };
   terminals.push(entry);
   return entry;
 };
@@ -164,9 +167,43 @@ try {
   assert.doesNotMatch(tui.screen(), /\b(?:TPS|TTFT)\b/, "empty session hides unavailable performance rows");
   await tui.save("01-empty");
   console.log("PASS: packed plugin loads; empty sidebar hides zero-value and context rows");
+
+  const switchTarget = await client.session.create({ location: { directory: project }, title: "Live Switch Target", permissions: [{ action: "*", resource: "*", effect: "allow" }] });
+  const switchPrompt = client.session.prompt({ sessionID: switchTarget.id, text: "SWITCH_SMOKE" });
+  await new Promise(resolve => setTimeout(resolve, 650));
+  tui.send("\x18");
+  await new Promise(resolve => setTimeout(resolve, 50));
+  tui.send("l");
+  await wait(() => /Sessions for project/.test(tui.screen()) && /Live Switch Target/.test(tui.screen()), "session switch dialog");
+  tui.send("Live Switch Target");
+  await new Promise(resolve => setTimeout(resolve, 100));
+  tui.send("\r");
+  await wait(() => !/Sessions for project/.test(tui.screen()) && /TPS\s+~[\d.]+ tok\/s/.test(tui.screen())
+    && /TTFT\s+[\d.]+s/.test(tui.screen()), "live performance restored after session switch");
+  await tui.save("02-switched-streaming");
+  await switchPrompt;
+  await wait(async () => (await client.message.list({ sessionID: switchTarget.id })).data.some(m => m.type === "assistant" && m.tokens), "switched session usage");
+  const switchSnapshot = await loadSnapshot(source, switchTarget.id, new AbortController().signal);
+  const switchPerformance = historicalPerformance(uniqueMessages(switchSnapshot));
+  assert.ok(switchPerformance.tps && switchPerformance.tps > 0);
+  await wait(() => new RegExp(`TPS\\s+${switchPerformance.tps.toFixed(1).replace(".", "\\.")} tok/s`).test(tui.screen()), "switched stream exact TPS");
+  assert.doesNotMatch(tui.screen(), /TPS\s+~/, "switched stream converges to exact TPS");
+  await tui.save("03-switched-complete");
+  console.log("PASS: switching to an in-flight session restores live TPS/TTFT and converges to exact TPS");
+
+  tui.send("\x18");
+  await new Promise(resolve => setTimeout(resolve, 50));
+  tui.send("l");
+  await wait(() => /Sessions for project/.test(tui.screen()) && /Token Usage Smoke/.test(tui.screen()), "return session dialog");
+  tui.send("\x1b[B");
+  await new Promise(resolve => setTimeout(resolve, 100));
+  tui.send("\r");
+  await wait(() => !/Sessions for project/.test(tui.screen()) && /Token Usage/.test(tui.screen())
+    && /Cache Rate\s+0\.0%/.test(tui.screen()) && !/\bTPS\b/.test(tui.screen()), "return to empty root session");
+
   const firstPrompt = client.session.prompt({ sessionID: root.id, text: "Return SMOKE_OK." });
   await wait(() => /TPS\s+~[\d.]+ tok\/s/.test(tui.screen()) && /TTFT\s+[\d.]+s/.test(tui.screen()), "live TPS and TTFT");
-  await tui.save("02-streaming");
+  await tui.save("04-streaming");
   await firstPrompt;
   await wait(async () => (await client.message.list({ sessionID: root.id })).data.some(m => m.type === "assistant" && m.tokens), "first usage");
   let snapshot = await loadSnapshot(source, root.id, new AbortController().signal);
@@ -186,19 +223,19 @@ try {
   assert.equal(lineNumber(tui.screen(), /\bTPS\s+/), lineNumber(tui.screen(), /\bCost\s+/) + 2, "one blank line separates usage and performance");
   assert.ok(lineNumber(tui.screen(), /\bTPS\s+/) < lineNumber(tui.screen(), /\bTTFT\s+/));
   assert.ok(lineNumber(tui.screen(), /\bCost\s+/) < lineNumber(tui.screen(), /\bTPS\s+/));
-  await tui.save("03-message");
+  await tui.save("05-message");
   console.log("PASS: live estimates converge to exact TPS; TTFT and token/context rows update");
   await client.session.wait({ sessionID: root.id });
   await client.session.prompt({ sessionID: root.id, text: "SPAWN_SMOKE_CHILD" });
   await wait(async () => (await client.session.list({ parentID: root.id })).data.length > 0, "real subagent creation");
   const child = (await client.session.list({ parentID: root.id })).data[0];
   await client.session.wait({ sessionID: root.id });
   await wait(() => /Input\s+400/.test(tui.screen()) && /Cache Read\s+4,000/.test(tui.screen()), "child usage in root sidebar");
-  await tui.save("04-subagent");
+  await tui.save("06-subagent");
   const childTui = openTui(child.id);
   await wait(() => /Input\s+400/.test(childTui.screen()) && /Cache Read\s+4,000/.test(childTui.screen()), "same tree in child sidebar");
   assert.match(childTui.screen(), /Context\s+1,270 \/ 128,000 \(1\.0%\)/);
-  await childTui.save("05-child-view");
+  await childTui.save("07-child-view");
   snapshot = await loadSnapshot(source, child.id, new AbortController().signal);
   assert.equal(snapshot.rootID, root.id);
   assert.equal(snapshot.viewedID, child.id);
@@ -208,9 +245,9 @@ try {
   await client.session.switchModel({ sessionID: root.id, model: { providerID: "usage-test", id: "large" } });
   await wait(async () => (await loadSnapshot(source, root.id, new AbortController().signal)).model.label === "usage-test/large", "active model switch");
   await wait(() => /Context\s+1,270 \/ 32,000 \(4\.0%\)/.test(tui.screen()), "context window follows model switch");
-  await tui.save("06-model-switch");
+  await tui.save("08-model-switch");
   console.log("PASS: active model switch refreshes price selection and context window");
-  await writeFile(path.join(work, "result.json"), JSON.stringify({ version: opencodeVersion.replace(/^opencode v/, ""), root: root.id, child: child.id, total: 5080, performance, context: { used: 1270, limitBefore: 128000, limitAfter: 32000, percentAfter: "4.0" }, package: packed[0].filename, files }, null, 2));
+  await writeFile(path.join(work, "result.json"), JSON.stringify({ version: opencodeVersion.replace(/^opencode v/, ""), root: root.id, child: child.id, switchTarget: switchTarget.id, total: 5080, performance, switchPerformance, context: { used: 1270, limitBefore: 128000, limitAfter: 32000, percentAfter: "4.0" }, package: packed[0].filename, files }, null, 2));
 } finally {
   for (const [index, terminal] of terminals.entries()) {
     await terminal.save(`final-${index}`);

scripts/smoke.mjs

@@ -1,6 +1,6 @@
 import { loadSnapshot, uniqueMessages, viewedMessages } from "./source.js";
 import type { Snapshot, UsageSource } from "./source.js";
-import { PerformanceTracker } from "./performance.js";
+import { PerformanceMonitor } from "./performance.js";
 import type { PerformanceSummary } from "./performance.js";
 import { contextUsage, summarize } from "./usage.js";
 import type { ContextUsage, Summary } from "./usage.js";
@@ -16,11 +16,6 @@ export interface UsageState {
 export interface UsageEvent { type: string; data: unknown; id?: string; created?: number }
 export type Subscribe = (listener: (event: UsageEvent) => void) => () => void;
 
-const performanceEvents = new Set([
-  "session.step.started", "session.step.streamed", "session.step.ended", "session.step.failed",
-  "session.text.delta", "session.reasoning.delta", "session.tool.input.delta",
-]);
-
 const sessionEvents = new Set([
   "session.created", "session.deleted", "session.forked", "session.moved",
   "session.model.selected", "session.agent.selected", "session.step.ended", "session.step.failed",
@@ -43,10 +38,13 @@ export class UsageController {
   private timer: ReturnType<typeof setTimeout> | undefined;
   private retry: ReturnType<typeof setTimeout> | undefined;
   private performanceTimer: ReturnType<typeof setTimeout> | undefined;
+  private sessions = new Set<string>();
   private pending = false;
   private disposed = false;
   private unsubscribe: () => void;
-  private readonly performance = new PerformanceTracker();
+  private readonly unsubscribePerformance: () => void;
+  private readonly performance: PerformanceMonitor;
+  private readonly ownsPerformance: boolean;
 
   constructor(
     private readonly source: UsageSource,
@@ -55,11 +53,19 @@ export class UsageController {
     private readonly delay = 80,
     private readonly retryDelay = 3_000,
     private readonly performanceDelay = 100,
+    performance?: PerformanceMonitor,
   ) {
+    this.ownsPerformance = performance === undefined;
+    this.performance = performance ?? new PerformanceMonitor(subscribe);
+    this.unsubscribePerformance = this.performance.listen(sessionID => {
+      if (this.sessions.has(sessionID)) this.refreshPerformance();
+    });
     this.unsubscribe = subscribe(event => {
       const data = (event.data && typeof event.data === "object" ? event.data : {}) as { sessionID?: string; parentID?: string };
-      if (event.type === "session.created") this.performance.addSession(data.sessionID, data.parentID);
-      if (performanceEvents.has(event.type) && this.performance.handle(event)) this.refreshPerformance();
+      if (event.type === "session.created" && data.sessionID && data.parentID && this.sessions.has(data.parentID)) {
+        this.sessions.add(data.sessionID);
+      }
+      if (event.type === "session.deleted" && data.sessionID) this.sessions.delete(data.sessionID);
       if (globalEvents.has(event.type)) return this.refresh();
       if (!sessionEvents.has(event.type)) return;
       if (!this.snapshot || event.type === "session.created" || event.type === "session.forked"
@@ -79,6 +85,7 @@ export class UsageController {
     this.performanceTimer = undefined;
     this.pending = false;
     this.snapshot = undefined;
+    this.sessions.clear();
     this.sessionID = sessionID;
     this.update({ status: "loading" });
     void this.run();
@@ -101,7 +108,9 @@ export class UsageController {
     clearTimeout(this.timer);
     clearTimeout(this.retry);
     clearTimeout(this.performanceTimer);
+    this.unsubscribePerformance();
     this.unsubscribe();
+    if (this.ownsPerformance) this.performance.dispose();
   }
 
   private update(state: UsageState) { this.state = state; this.publish(state); }
@@ -111,7 +120,7 @@ export class UsageController {
     this.performanceTimer = setTimeout(() => {
       this.performanceTimer = undefined;
       if (this.disposed || !this.snapshot || !this.state.summary) return;
-      this.update({ ...this.state, performance: this.performance.summary(uniqueMessages(this.snapshot)) });
+      this.update({ ...this.state, performance: this.performance.summary(uniqueMessages(this.snapshot), this.sessions) });
     }, this.performanceDelay);
   }
 
@@ -126,15 +135,15 @@ export class UsageController {
       if (this.disposed || generation !== this.generation) return;
       this.snapshot = snapshot;
       const messages = [...uniqueMessages(snapshot)];
-      this.performance.setTree(snapshot.rootID, snapshot.sessions.keys());
-      this.performance.reconcile(messages);
+      this.sessions = new Set(snapshot.sessions.keys());
+      this.performance.reconcile(messages, this.sessions);
       clearTimeout(this.performanceTimer);
       this.performanceTimer = undefined;
       this.update({
         status: "ready",
         summary: summarize(messages, snapshot.model.prices),
         context: contextUsage(viewedMessages(snapshot), snapshot.model.context),
-        performance: this.performance.summary(messages),
+        performance: this.performance.summary(messages, this.sessions),
         model: snapshot.model.label,
       });
     } catch {