feat: surface codex tool activity progress

2026-06-01 18:04:39 +08:00
parent 2a5dccf5cb
commit 2ca2737520
11 changed files with 558 additions and 7 deletions
--- a/tests/master-agent-task-progress-route.test.ts
+++ b/tests/master-agent-task-progress-route.test.ts
@@ -517,3 +517,97 @@ test("POST task progress preserves Codex thread collaboration summaries without
  assert.equal(serialized.includes("sk-secret-should-not-persist"), false);
  assert.equal(serialized.includes("turn-secret-should-not-persist"), false);
 });
+
+test("POST task progress preserves Codex tool activity summaries without leaking raw payloads", async () => {
+  const task = await data.queueMasterAgentTask({
+    taskId: "route-progress-tool-activity-task",
+    projectId: "group-progress-test",
+    taskType: "dispatch_execution",
+    requestMessageId: "msg-route-progress-tool-activity",
+    requestText: "检查 Codex 工具活动",
+    executionPrompt: "检查 Codex 工具活动",
+    requestedBy: "krisolo",
+    requestedByAccount: "krisolo",
+    deviceId: "mac-studio",
+    targetProjectId: "master-agent",
+    targetThreadId: "master-agent-thread",
+  });
+  await data.claimNextMasterAgentTask("mac-studio");
+
+  const response = await postProgress(
+    new NextRequest(`http://127.0.0.1:3000/api/v1/master-agent/tasks/${task.taskId}/progress`, {
+      method: "POST",
+      headers: {
+        "content-type": "application/json",
+        "x-boss-device-token": "boss-mac-studio-token",
+      },
+      body: JSON.stringify({
+        deviceId: "mac-studio",
+        status: "running",
+        executionProgress: {
+          steps: [{ text: "同步 Codex 工具活动", status: "running" }],
+          toolActivities: [
+            {
+              kind: "mcp",
+              name: "github/pull_request/list",
+              status: "failed",
+              detail: "token=sk-secret-should-not-persist failed",
+              arguments: { token: "sk-secret-should-not-persist" },
+              result: "internal tool result",
+            },
+            {
+              kind: "web_search",
+              name: "openPage",
+              status: "running",
+              detail: "Codex App Server ThreadItem",
+              url: "https://example.com/private?token=sk-secret-should-not-persist",
+            },
+            {
+              kind: "command",
+              name: "commandExecution",
+              status: "completed",
+              detail: "exit 0 · 2345ms",
+              command: "cat /Users/kris/.ssh/id_rsa",
+              cwd: "/Users/kris/code/boss",
+            },
+          ],
+        },
+      }),
+    }),
+    { params: Promise.resolve({ taskId: task.taskId }) },
+  );
+
+  assert.equal(response.status, 200);
+
+  const state = await data.readState();
+  const progress = state.projects
+    .find((project) => project.id === "master-agent")
+    ?.messages.find((message) => message.executionProgress?.taskId === task.taskId)
+    ?.executionProgress;
+  assert.deepEqual(progress?.toolActivities, [
+    {
+      kind: "mcp",
+      name: "github/pull_request/list",
+      status: "failed",
+      detail: "token=[redacted] failed",
+    },
+    {
+      kind: "web_search",
+      name: "openPage",
+      status: "running",
+      detail: "Codex App Server ThreadItem",
+    },
+    {
+      kind: "command",
+      name: "commandExecution",
+      status: "completed",
+      detail: "exit 0 · 2345ms",
+    },
+  ]);
+  const serialized = JSON.stringify(progress);
+  assert.equal(serialized.includes("sk-secret-should-not-persist"), false);
+  assert.equal(serialized.includes("internal tool result"), false);
+  assert.equal(serialized.includes("https://example.com/private"), false);
+  assert.equal(serialized.includes("/Users/kris"), false);
+  assert.equal(serialized.includes("id_rsa"), false);
+});