✨ 任务工具持久化 & OPFS Blob 跨上下文传输修复

- 任务工具精简为 3 个（create/update/list），新增持久化存储和 UI 实时推送
- 新增 TaskListBlock 组件展示任务进度
- 修复 chrome.runtime sendResponse 不支持 Blob 的问题，改用 blobUrl + CAT_fetchBlob 模式
- 简化 readAttachment API，统一返回 Blob 对象
- 新增 read blob 格式支持
- 更新系统提示词与类型定义

Author: CodFrm

src/app/repo/agent_chat.ts

@@ -1,9 +1,11 @@
 import type { Conversation, ChatMessage } from "@App/app/service/agent/types";
+import type { Task } from "@App/app/service/agent/tools/task_tools";
 import { OPFSRepo } from "./opfs_repo";
 
 const CONVERSATIONS_FILE = "conversations.json";
 const MESSAGES_DIR = "data";
 const ATTACHMENTS_DIR = "attachments";
+const TASKS_DIR = "tasks";
 
 // 目录结构：agents/conversations/
 //            agents/conversations/conversations.json       - 会话列表
@@ -66,6 +68,8 @@ export class AgentChatRepo extends OPFSRepo {
     // 删除对应消息文件
     const messagesDir = await this.getChildDir(MESSAGES_DIR);
     await this.deleteFile(`${id}.json`, messagesDir);
+    // 删除关联的任务数据
+    await this.deleteTasks(id).catch(() => {});
   }
 
   // 获取指定会话的所有消息
@@ -147,6 +151,26 @@ export class AgentChatRepo extends OPFSRepo {
     }
   }
 
+  // ---- 任务 (task_tools) 存储 ----
+
+  // 获取会话关联的任务列表
+  async getTasks(conversationId: string): Promise<Task[]> {
+    const tasksDir = await this.getChildDir(TASKS_DIR);
+    return this.readJsonFile<Task[]>(`${conversationId}.json`, [], tasksDir);
+  }
+
+  // 保存会话关联的任务列表
+  async saveTasks(conversationId: string, tasks: Task[]): Promise<void> {
+    const tasksDir = await this.getChildDir(TASKS_DIR);
+    await this.writeJsonFile(`${conversationId}.json`, tasks, tasksDir);
+  }
+
+  // 删除会话关联的任务
+  async deleteTasks(conversationId: string): Promise<void> {
+    const tasksDir = await this.getChildDir(TASKS_DIR);
+    await this.deleteFile(`${conversationId}.json`, tasksDir);
+  }
+
   // 将 data URL 或纯 base64 转换为 Blob
   private dataUrlToBlob(data: string): Blob {
     // 匹配 data URL 格式

src/app/service/agent/agent.test.ts

@@ -692,7 +692,12 @@ describe("callLLMWithToolLoop", () => {
 
     const doneEvent = events.find((e) => e.type === "done");
     expect(doneEvent).toBeDefined();
-    expect(doneEvent!.type === "done" && doneEvent!.usage).toEqual({ inputTokens: 10, outputTokens: 5, cacheCreationInputTokens: 0, cacheReadInputTokens: 0 });
+    expect(doneEvent!.type === "done" && doneEvent!.usage).toEqual({
+      inputTokens: 10,
+      outputTokens: 5,
+      cacheCreationInputTokens: 0,
+      cacheReadInputTokens: 0,
+    });
   });
 
   it("单轮 tool calling", async () => {
@@ -747,7 +752,12 @@ describe("callLLMWithToolLoop", () => {
     const doneEvent = events.find((e) => e.type === "done");
     expect(doneEvent).toBeDefined();
     if (doneEvent?.type === "done") {
-      expect(doneEvent.usage).toEqual({ inputTokens: 50, outputTokens: 18, cacheCreationInputTokens: 0, cacheReadInputTokens: 0 });
+      expect(doneEvent.usage).toEqual({
+        inputTokens: 50,
+        outputTokens: 18,
+        cacheCreationInputTokens: 0,
+        cacheReadInputTokens: 0,
+      });
     }
   });
 

src/app/service/agent/system_prompt.ts

@@ -48,7 +48,17 @@ Detect when you are stuck and stop early:
 
 - **Read page content** → prefer \`get_tab_content\` (structured markdown) over \`execute_script\` (raw JS).
 - **Fetch remote data** → \`web_fetch\` for text/HTML/JSON. It does NOT support binary downloads — use a SkillScript with \`fetch()\` + \`CAT.agent.opfs.write(blob)\` for binary files.
-- **Ask user** → \`ask_user\` supports text only. To show images to the user, use \`execute_script\` to display them on page.
+- **Ask user** → \`ask_user\` for questions. Prefer providing \`options\` for structured choices so the user can select quickly; add \`multiple: true\` for multi-select. The user can also type a custom response even when options are provided. To show images to the user, use \`execute_script\` to display them on page.
+
+## Task Management
+
+For **complex, multi-step tasks**, use task tools to track your progress:
+- \`create_task\` — Break the work into individual steps at the start.
+- \`update_task\` — Mark each step as \`in_progress\` when you begin it, and \`completed\` when done.
+- \`list_tasks\` — Review remaining steps, especially after resuming a conversation.
+
+**When to use:** Tasks that involve 3+ distinct steps (e.g., navigating multiple pages, processing data, multi-stage workflows). Do NOT create tasks for simple, single-step requests.
+**Workflow:** Create all tasks first → work through them one by one → update status as you go.
 
 ## Binary File Workflow
 

src/app/service/agent/tools/opfs_tools.ts

@@ -81,7 +81,7 @@ export function setCreateBlobUrlFn(fn: CreateBlobUrlFn): void {
 }
 
 /** 根据文件扩展名推断 MIME 类型 */
-function guessMimeType(path: string): string {
+export function guessMimeType(path: string): string {
   const ext = path.split(".").pop()?.toLowerCase() || "";
   const map: Record<string, string> = {
     jpg: "image/jpeg",

src/app/service/agent/tools/task_tools.test.ts

@@ -1,15 +1,15 @@
-import { describe, it, expect } from "vitest";
-import { createTaskTools } from "./task_tools";
+import { describe, it, expect, vi } from "vitest";
+import { createTaskTools, type Task } from "./task_tools";
 
 describe("task_tools", () => {
-  it("should create 5 tools", () => {
+  it("应创建 3 个工具", () => {
     const { tools } = createTaskTools();
-    expect(tools).toHaveLength(5);
+    expect(tools).toHaveLength(3);
     const names = tools.map((t) => t.definition.name);
-    expect(names).toEqual(["create_task", "get_task", "update_task", "list_tasks", "delete_task"]);
+    expect(names).toEqual(["create_task", "update_task", "list_tasks"]);
   });
 
-  it("create_task should create a task with auto-incremented ID", async () => {
+  it("create_task 应创建自增 ID 的任务", async () => {
     const { tools } = createTaskTools();
     const create = tools.find((t) => t.definition.name === "create_task")!;
 
@@ -22,19 +22,7 @@ describe("task_tools", () => {
     expect(result2).toEqual({ id: "2", subject: "Task 2", description: "Details", status: "pending" });
   });
 
-  it("get_task should return task or throw", async () => {
-    const { tools } = createTaskTools();
-    const create = tools.find((t) => t.definition.name === "create_task")!;
-    const get = tools.find((t) => t.definition.name === "get_task")!;
-
-    await create.executor.execute({ subject: "Test" });
-    const result = JSON.parse((await get.executor.execute({ task_id: "1" })) as string);
-    expect(result.subject).toBe("Test");
-
-    await expect(get.executor.execute({ task_id: "999" })).rejects.toThrow('Task "999" not found');
-  });
-
-  it("update_task should update fields", async () => {
+  it("update_task 应更新任务字段", async () => {
     const { tools } = createTaskTools();
     const create = tools.find((t) => t.definition.name === "create_task")!;
     const update = tools.find((t) => t.definition.name === "update_task")!;
@@ -48,13 +36,13 @@ describe("task_tools", () => {
     expect(result.subject).toBe("Updated");
   });
 
-  it("update_task should throw for non-existent task", async () => {
+  it("update_task 应对不存在的任务抛错", async () => {
     const { tools } = createTaskTools();
     const update = tools.find((t) => t.definition.name === "update_task")!;
     await expect(update.executor.execute({ task_id: "1" })).rejects.toThrow();
   });
 
-  it("list_tasks should return all tasks summary", async () => {
+  it("list_tasks 应返回所有任务摘要", async () => {
     const { tools } = createTaskTools();
     const create = tools.find((t) => t.definition.name === "create_task")!;
     const list = tools.find((t) => t.definition.name === "list_tasks")!;
@@ -68,65 +56,83 @@ describe("task_tools", () => {
     expect(result[1]).toEqual({ id: "2", subject: "B", status: "pending" });
   });
 
-  it("list_tasks should return empty array initially", async () => {
+  it("list_tasks 初始应返回空数组", async () => {
     const { tools } = createTaskTools();
     const list = tools.find((t) => t.definition.name === "list_tasks")!;
     const result = JSON.parse((await list.executor.execute({})) as string);
     expect(result).toEqual([]);
   });
 
-  it("update_task should allow clearing description with empty string", async () => {
-    const { tools } = createTaskTools();
+  it("应从 initialTasks 恢复任务并继续递增 ID", async () => {
+    const initial: Task[] = [
+      { id: "3", subject: "Existing", status: "in_progress" },
+      { id: "5", subject: "Another", status: "pending" },
+    ];
+    const { tools } = createTaskTools({ initialTasks: initial });
     const create = tools.find((t) => t.definition.name === "create_task")!;
-    const update = tools.find((t) => t.definition.name === "update_task")!;
+    const list = tools.find((t) => t.definition.name === "list_tasks")!;
 
-    await create.executor.execute({ subject: "Test", description: "Some desc" });
+    // 新任务 ID 应从 6 开始（max existing ID 5 + 1）
+    const result = JSON.parse((await create.executor.execute({ subject: "New" })) as string);
+    expect(result.id).toBe("6");
 
-    const result = JSON.parse((await update.executor.execute({ task_id: "1", description: "" })) as string);
-    expect(result.description).toBe("");
+    const all = JSON.parse((await list.executor.execute({})) as string);
+    expect(all).toHaveLength(3);
   });
 
-  it("update_task with only task_id should not change anything", async () => {
-    const { tools } = createTaskTools();
+  it("create_task 应调用 onSave 和 sendEvent", async () => {
+    const onSave = vi.fn().mockResolvedValue(undefined);
+    const sendEvent = vi.fn();
+    const { tools } = createTaskTools({ onSave, sendEvent });
     const create = tools.find((t) => t.definition.name === "create_task")!;
-    const update = tools.find((t) => t.definition.name === "update_task")!;
 
-    await create.executor.execute({ subject: "Original", description: "Desc" });
-
-    const result = JSON.parse((await update.executor.execute({ task_id: "1" })) as string);
-    expect(result.subject).toBe("Original");
-    expect(result.description).toBe("Desc");
-    expect(result.status).toBe("pending");
-  });
+    await create.executor.execute({ subject: "Test" });
 
-  it("create_task without description should not include it in result", async () => {
-    const { tools } = createTaskTools();
-    const create = tools.find((t) => t.definition.name === "create_task")!;
+    expect(onSave).toHaveBeenCalledOnce();
+    expect(onSave).toHaveBeenCalledWith([{ id: "1", subject: "Test", status: "pending" }]);
 
-    const result = JSON.parse((await create.executor.execute({ subject: "No desc" })) as string);
-    expect(result.description).toBeUndefined();
+    expect(sendEvent).toHaveBeenCalledOnce();
+    expect(sendEvent).toHaveBeenCalledWith({
+      type: "task_update",
+      tasks: [{ id: "1", subject: "Test", status: "pending" }],
+    });
   });
 
-  it("delete_task should remove a task", async () => {
-    const { tools, tasks } = createTaskTools();
+  it("update_task 应调用 onSave 和 sendEvent", async () => {
+    const onSave = vi.fn().mockResolvedValue(undefined);
+    const sendEvent = vi.fn();
+    const { tools } = createTaskTools({ onSave, sendEvent });
     const create = tools.find((t) => t.definition.name === "create_task")!;
-    const del = tools.find((t) => t.definition.name === "delete_task")!;
+    const update = tools.find((t) => t.definition.name === "update_task")!;
 
-    await create.executor.execute({ subject: "To delete" });
-    expect(tasks.size).toBe(1);
+    await create.executor.execute({ subject: "Task" });
+    onSave.mockClear();
+    sendEvent.mockClear();
 
-    const result = JSON.parse((await del.executor.execute({ task_id: "1" })) as string);
-    expect(result).toEqual({ deleted: "1" });
-    expect(tasks.size).toBe(0);
+    await update.executor.execute({ task_id: "1", status: "completed" });
+
+    expect(onSave).toHaveBeenCalledOnce();
+    expect(sendEvent).toHaveBeenCalledOnce();
+    expect(sendEvent).toHaveBeenCalledWith({
+      type: "task_update",
+      tasks: [{ id: "1", subject: "Task", status: "completed" }],
+    });
   });
 
-  it("delete_task should throw for non-existent task", async () => {
-    const { tools } = createTaskTools();
-    const del = tools.find((t) => t.definition.name === "delete_task")!;
-    await expect(del.executor.execute({ task_id: "999" })).rejects.toThrow('Task "999" not found');
+  it("list_tasks 不应触发 onSave 或 sendEvent", async () => {
+    const onSave = vi.fn().mockResolvedValue(undefined);
+    const sendEvent = vi.fn();
+    const initial: Task[] = [{ id: "1", subject: "Existing", status: "pending" }];
+    const { tools } = createTaskTools({ initialTasks: initial, onSave, sendEvent });
+    const list = tools.find((t) => t.definition.name === "list_tasks")!;
+
+    await list.executor.execute({});
+
+    expect(onSave).not.toHaveBeenCalled();
+    expect(sendEvent).not.toHaveBeenCalled();
   });
 
-  it("tasks map should be independent per createTaskTools call", async () => {
+  it("多实例应独立", async () => {
     const instance1 = createTaskTools();
     const instance2 = createTaskTools();