✨ 支持 Agent 会话后台运行模式

UI 断开后会话继续执行，重新连接后通过 sync 快照恢复进度。

- 新增 RunningConversation 注册表与 broadcastEvent/updateStreamingState 机制
- handleConversationChat 支持 background 参数，断开只移除 listener 不 abort
- 新增 attachToConversation 处理器，重连时发送 sync 快照
- UI hooks 新增 attachToConversation、useRunningConversations
- ChatArea 自动 attach 运行中会话，ChatInput 增加后台模式开关
- 会话列表显示运行中指示器
- Script API (cat_agent) 支持 background 参数和 attach() 方法
- 26 个单元测试覆盖核心逻辑

Author: CodFrm

src/app/service/agent/types.ts

@@ -93,6 +93,15 @@ export type ChatStreamEvent =
   | { type: "content_block_complete"; block: ImageBlock | FileBlock | AudioBlock; data?: string }
   | { type: "ask_user"; id: string; question: string; options?: string[]; multiple?: boolean }
   | { type: "sub_agent_event"; agentId: string; description: string; event: ChatStreamEvent }
+  | {
+      type: "task_update";
+      tasks: Array<{
+        id: string;
+        subject: string;
+        status: "pending" | "in_progress" | "completed";
+        description?: string;
+      }>;
+    }
   | { type: "new_message" }
   | {
       type: "done";
@@ -105,7 +114,19 @@ export type ChatStreamEvent =
       durationMs?: number;
     }
   | { type: "error"; message: string; errorCode?: string }
-  | { type: "compact_done"; summary: string; originalCount: number };
+  | { type: "compact_done"; summary: string; originalCount: number }
+  | {
+      type: "sync";
+      streamingMessage?: { content: string; thinking?: string; toolCalls: ToolCall[] };
+      pendingAskUser?: { id: string; question: string; options?: string[]; multiple?: boolean };
+      tasks: Array<{
+        id: string;
+        subject: string;
+        status: "pending" | "in_progress" | "completed";
+        description?: string;
+      }>;
+      status: "running" | "done" | "error";
+    };
 
 // UI -> Service Worker 的聊天请求
 export type ChatRequest = {
@@ -164,6 +185,7 @@ export type ConversationCreateOptions = {
   commands?: Record<string, CommandHandler>; // 自定义命令处理器，以 / 开头
   ephemeral?: boolean; // 临时会话：不持久化、不加载内置资源、工具由脚本提供
   cache?: boolean; // 是否启用 prompt caching，默认 true
+  background?: boolean; // 后台运行：UI 断开后继续执行，默认 false
 };
 
 // conv.chat() 的参数
@@ -176,7 +198,12 @@ export type ChatReply = {
   content: MessageContent;
   thinking?: string;
   toolCalls?: ToolCall[];
-  usage?: { inputTokens: number; outputTokens: number; cacheCreationInputTokens?: number; cacheReadInputTokens?: number };
+  usage?: {
+    inputTokens: number;
+    outputTokens: number;
+    cacheCreationInputTokens?: number;
+    cacheReadInputTokens?: number;
+  };
   command?: boolean; // 标识该回复来自命令处理
 };
 
@@ -186,7 +213,12 @@ export type StreamChunk = {
   content?: string;
   block?: ContentBlock;
   toolCall?: ToolCall;
-  usage?: { inputTokens: number; outputTokens: number; cacheCreationInputTokens?: number; cacheReadInputTokens?: number };
+  usage?: {
+    inputTokens: number;
+    outputTokens: number;
+    cacheCreationInputTokens?: number;
+    cacheReadInputTokens?: number;
+  };
   error?: string;
   /** 错误分类码："rate_limit" | "auth" | "tool_timeout" | "max_iterations" | "api_error" */
   errorCode?: string;
@@ -252,8 +284,8 @@ export type SkillApiRequest =
 // CAT.agent.opfs API 请求
 export type OPFSApiRequest =
   | { action: "write"; path: string; content: string | Blob; scriptUuid: string }
-  | { action: "read"; path: string; format?: "text" | "bloburl"; scriptUuid: string }
-  | { action: "readAttachment"; id: string; format?: "bloburl" | "dataurl"; scriptUuid: string }
+  | { action: "read"; path: string; format?: "text" | "bloburl" | "blob"; scriptUuid: string }
+  | { action: "readAttachment"; id: string; scriptUuid: string }
   | { action: "list"; path?: string; scriptUuid: string }
   | { action: "delete"; path: string; scriptUuid: string };
 

src/app/service/content/gm_api/cat_agent.ts

@@ -35,6 +35,8 @@ export class ConversationInstance {
     toolCalls?: ToolCall[];
   }> = [];
 
+  private background: boolean;
+
   constructor(
     private conv: Conversation,
     private gmSendMessage: (api: string, params: any[]) => Promise<any>,
@@ -45,9 +47,11 @@ export class ConversationInstance {
     commands?: Record<string, CommandHandler>,
     ephemeral?: boolean,
     system?: string,
-    cache?: boolean
+    cache?: boolean,
+    background?: boolean
   ) {
     this.ephemeral = ephemeral || false;
+    this.background = background || false;
     this.cache = cache;
     this.systemPrompt = system;
     if (initialTools) {
@@ -109,6 +113,9 @@ export class ConversationInstance {
     if (this.cache !== undefined) {
       connectParams.cache = this.cache;
     }
+    if (this.background) {
+      connectParams.background = true;
+    }
     if (this.ephemeral) {
       connectParams.ephemeral = true;
       connectParams.messages = this.messageHistory;
@@ -179,6 +186,9 @@ export class ConversationInstance {
     if (this.cache !== undefined) {
       connectParams.cache = this.cache;
     }
+    if (this.background) {
+      connectParams.background = true;
+    }
     if (this.ephemeral) {
       connectParams.ephemeral = true;
       connectParams.messages = this.messageHistory;
@@ -286,6 +296,14 @@ export class ConversationInstance {
     ]);
   }
 
+  // 附加到后台运行中的会话，返回流式事件
+  async attach(): Promise<AsyncIterable<StreamChunk>> {
+    const conn = await this.gmConnect("CAT_agentAttachToConversation", [
+      { conversationId: this.conv.id, scriptUuid: this.scriptUuid },
+    ]);
+    return this.processStream(conn, new Map());
+  }
+
   // 处理非流式 chat 的响应
   private processChat(
     conn: MessageConnect,
@@ -543,7 +561,8 @@ function buildInstance(
     options?.commands,
     options?.ephemeral,
     options?.system,
-    options?.cache
+    options?.cache,
+    options?.background
   );
 }