fix: stop-agent无响应 + 日志分流 + 终端格式美化 + Windows删除目录权限

- stopAgent改为async，添加乐观更新和await sendToEngine
- 日志分流：system/error技术日志只走终端stderr，input/output及关键状态进UI
- 终端日志格式：组件前缀[Agent]/[Kimi]/[Git] + 颜色高亮（vLLM风格）
- Rust stdout reader不再回显JSON事件，只回显非JSON行
- agent.stop()改为async，kill后等待进程完全退出（避免Windows文件锁定）
- delete-agent增加rmdir /s /q fallback，解决Windows删除权限问题
- 同步更新docs/ARCHITECTURE.md、docs/STATUS.md

Author: HelloWorldU

docs/ARCHITECTURE.md

@@ -67,6 +67,11 @@ PR 创建时，Store 自动生成 `ReviewEntry[]`，包含所有其他 Agent 作
 3. Engine 创建成功后推送 `agent-created` 事件 → 前端列表更新
 4. 用户点击"启动"→ `startAgent()` 发送 `start-agent` 命令 → Engine 执行 clone/branch → 推送 `agent-status` 事件
 5. **引擎未启动或命令发送失败时**：`sendToEngine` 抛出异常，`startAgent` 已添加 `try/catch` 捕获并写入 Agent 日志，禁止静默失败
+6. 用户点击"停止"→ `stopAgent()` **乐观更新**前端状态为 `stopped`，再 `await sendToEngine({ type: 'stop-agent' })` → Engine 调用 `agent.stop()` 等待进程退出 → 推送 `agent-status` 事件；后端失败时自动回滚状态
+
+**日志分流**：
+- `input` / `output` 及关键状态变更（执行完毕/已停止/Token耗尽等）通过 `log` 事件进入前端聊天面板
+- `system` / `error` 技术日志（PID、命令行参数、文件变更数、内部异常等）输出到 **stderr**，由终端直接显示（带 `[Agent]`/`[Kimi]`/`[Git]` 组件前缀和颜色），不污染 UI
 
 ## 登录流程
 

docs/STATUS.md

@@ -32,7 +32,7 @@
 | Agent Engine 进程管理 | ✅ | Rust 后台 spawn Node.js Agent Engine，stdin/stdout 管道通信；Windows 优先使用本地 `tsx.cmd` 避免 PATH 继承问题 | `src-tauri/src/lib.rs`, `agent-engine/src/index.ts` |
 | Kimi CLI 接入 | ✅ | `sendInstruction` 调用 `kimi --print --quiet`，实时 stdout 流式捕获，可取消 | `src/store/useSwarmStore.ts` |
 | Token 预算控制 | ✅ | sendInstruction 前检查预算；process-output 中按输出行长度估算并累加；耗尽时自动 kill 进程 | `src/store/useSwarmStore.ts` |
-| Agent 多轮对话交互 | ✅ | 聊天式气泡 UI，支持 input/output/system/error 消息类型；ready/stopped/completed 状态下可持续对话；working 状态显示执行中指示器 | `src/components/AgentDetail.vue`, `src/store/useSwarmStore.ts`, `agent-engine/src/agent.ts` |
+| Agent 多轮对话交互 | ✅ | 聊天式气泡 UI，支持 input/output/system/error 消息类型；ready/stopped/completed 状态下可持续对话；working 状态显示执行中指示器；**日志已分流**（system/error 技术日志带组件前缀+颜色走终端 stderr，input/output 及关键状态变更进 UI）；**stop-agent 已修复**（前端乐观更新 + await IPC） | `src/components/AgentDetail.vue`, `src/store/useSwarmStore.ts`, `agent-engine/src/agent.ts` |
 
 ## 质量约束
 
@@ -59,4 +59,4 @@
 
 ---
 
-*Last updated: 2026-05-12*
+*Last updated: 2026-05-13*

kimi-code-swarm/agent-engine/src/agent.ts

@@ -11,6 +11,14 @@ const branchName = (name: string) => {
   return `agent/${slug}-${generateId().slice(-4)}`
 }
 
+const termColors = {
+  reset: '\x1b[0m',
+  red: '\x1b[31m',
+  yellow: '\x1b[33m',
+  cyan: '\x1b[36m',
+  gray: '\x1b[90m',
+}
+
 export class Agent {
   state: AgentState
   private process?: KimiProcess
@@ -54,11 +62,63 @@ export class Agent {
     }
   }
 
+  private termLog(component: string, level: 'info' | 'warn' | 'error', message: string) {
+    const c = level === 'error' ? termColors.red : level === 'warn' ? termColors.yellow : termColors.cyan
+    const tag = level === 'info' ? '' : `${c}${level.toUpperCase()}${termColors.reset} `
+    console.error(`${c}[${component}]${termColors.reset} ${tag}${message}`)
+  }
+
+  private isUserVisibleLog(type: LogEntry['type'], content: string): boolean {
+    if (type === 'input' || type === 'output') return true
+    const patterns = [
+      'Agent 已恢复',
+      '工作空间就绪',
+      '启动失败',
+      'Token 预算已耗尽',
+      'Kimi CLI 未找到',
+      '启动 Kimi CLI 失败',
+      'Agent 执行完毕',
+      'Agent 执行失败',
+      'Agent 已停止',
+      '代码已推送',
+      '推送失败',
+      'PR #',
+      '已合并到 main',
+      'PR 被打回',
+      '合并被拒绝',
+      '审阅通过了此 PR',
+      '审阅拒绝了此 PR',
+      '全员审阅通过',
+      '已指派',
+      '自动修改已达最大轮次',
+    ]
+    return patterns.some((p) => content.includes(p))
+  }
+
+  private inferComponent(content: string): string {
+    if (content.includes('Kimi') || content.includes('kimi')) return 'Kimi'
+    if (content.includes('GitHub') || content.includes('github')) return 'GitHub'
+    if (content.includes('git ') || content.includes('仓库') || content.includes('分支') || content.includes('推送') || content.includes('代码') || content.includes('克隆')) return 'Git'
+    if (content.includes('审阅')) return 'Review'
+    return 'Agent'
+  }
+
   private log(type: LogEntry['type'], content: string, tokens?: number) {
     const entry = this.makeLog(type, content, tokens)
     this.state.logs.push(entry)
     this.state.lastActivity = new Date().toISOString()
-    this.emit({ type: 'log', agentId: this.state.id, entry })
+
+    const showInUi = this.isUserVisibleLog(type, content)
+    if (showInUi) {
+      this.emit({ type: 'log', agentId: this.state.id, entry })
+    }
+
+    // system/error 都输出到终端（带颜色、组件前缀）
+    if (type === 'system' || type === 'error') {
+      const level = type === 'error' ? 'error' : 'info'
+      const component = this.inferComponent(content)
+      this.termLog(component, level, content)
+    }
   }
 
   private setStatus(status: TaskStatus) {
@@ -159,16 +219,24 @@ export class Agent {
       }
     })()
 
-    // stderr reader — filter out kimi CLI internal logging errors
+    // stderr reader — filter out kimi CLI internal loguru errors (Windows known issue)
+    let loguruBlockActive = false
     ;(async () => {
       try {
         for await (const line of this.process!.stderr) {
           if (!this.running) break
-          // Skip loguru internal rotation errors on Windows (not actionable)
-          if (line.includes('Loguru Handler') || line.includes('PermissionError')) {
-            this.log('system', `[kimi stderr filtered] ${line.substring(0, 120)}`)
+          // Detect start of loguru error block
+          if (line.includes('--- Logging error') && line.includes('Loguru')) {
+            loguruBlockActive = true
+            this.log('system', '[kimi stderr] loguru logging error filtered (see ~/.kimi/logs)')
             continue
           }
+          // End of loguru block: empty line or non-traceback line after PermissionError
+          if (loguruBlockActive && (line.trim() === '' || (!line.startsWith('  ') && !line.includes('Traceback')))) {
+            loguruBlockActive = false
+            continue
+          }
+          if (loguruBlockActive) continue
           this.log('error', line)
           this.emit({ type: 'agent-output', agentId: this.state.id, line, isStderr: true })
         }
@@ -208,10 +276,19 @@ export class Agent {
     }
   }
 
-  stop() {
+  async stop() {
     if (this.process) {
       this.process.kill()
       this.running = false
+      // 等待进程完全退出（kill() 内部 2s 后会 SIGKILL，这里最多等 3s）
+      try {
+        await Promise.race([
+          this.process.wait(),
+          new Promise<void>((_, reject) => setTimeout(() => reject(new Error('timeout')), 3000)),
+        ])
+      } catch {
+        // 超时或异常，忽略
+      }
     }
     this.state.pid = undefined
     this.setStatus('stopped')

kimi-code-swarm/agent-engine/src/engine.ts

@@ -53,20 +53,41 @@ export class AgentEngine {
 
         case 'stop-agent': {
           const agent = this.agents.get(cmd.agentId)
-          if (agent) agent.stop()
+          if (agent) await agent.stop()
           break
         }
 
         case 'delete-agent': {
           const agent = this.agents.get(cmd.agentId)
           if (agent) {
-            agent.stop()
+            await agent.stop()
             const workspace = agent.state.workspace || `E:/workspace/${agent.state.id}`
+            // 给 Windows 一点时间释放文件句柄
+            await new Promise((r) => setTimeout(r, 500))
+
+            let deleted = false
+            // 先尝试 Node.js 原生删除
             try {
               await rm(workspace, { recursive: true, force: true })
+              deleted = true
+            } catch {
+              // fallback: Windows 系统命令（对锁定文件更激进）
+              try {
+                const { exec } = await import('child_process')
+                await new Promise<void>((resolve, reject) => {
+                  exec(`rmdir /s /q "${workspace}"`, (err) => {
+                    if (err) reject(err)
+                    else resolve()
+                  })
+                })
+                deleted = true
+              } catch {}
+            }
+
+            if (deleted) {
               this.broadcast({ type: 'log', agentId: cmd.agentId, entry: { id: 'system', timestamp: new Date().toISOString(), type: 'system', content: `工作目录已清理: ${workspace}` } })
-            } catch (err) {
-              const msg = `清理工作目录失败: ${String(err)}`
+            } else {
+              const msg = `清理工作目录失败: ${workspace}，请手动删除`
               console.error(`[engine] ${msg}`)
               this.broadcast({ type: 'log', agentId: cmd.agentId, entry: { id: 'system', timestamp: new Date().toISOString(), type: 'error', content: msg } })
             }
@@ -157,9 +178,7 @@ export class AgentEngine {
 
         case 'shutdown': {
           // Stop all agents gracefully
-          for (const agent of this.agents.values()) {
-            agent.stop()
-          }
+          await Promise.all(Array.from(this.agents.values()).map((a) => a.stop()))
           this.agents.clear()
           this.broadcast({ type: 'pong', message: 'Engine shutting down' })
           break

kimi-code-swarm/src-tauri/src/lib.rs

@@ -241,6 +241,10 @@ fn spawn_agent_engine(app: tauri::AppHandle) -> Result<u32, String> {
         let reader = BufReader::new(stdout);
         for line in reader.lines() {
             if let Ok(line) = line {
+                // 非 JSON 行（如引擎崩溃输出）直接回显终端；JSON 事件由前端处理，不回显
+                if serde_json::from_str::<serde_json::Value>(&line).is_err() {
+                    println!("{}", line);
+                }
                 let _ = app_emit.emit("agent-engine-event", AgentEngineEvent { line });
             }
         }

kimi-code-swarm/src/store/useSwarmStore.ts

@@ -371,18 +371,27 @@ export function useSwarmStore() {
     sendToEngine({ type: 'send-instruction', agentId: id, instruction })
   }
 
-  function stopAgent(id: string) {
-    if (!isTauri) {
-      const agent = state.agents.find((a) => a.id === id)
-      if (agent) {
-        agent.status = 'stopped'
-        agent.pid = undefined
-        agent.logs.push({ id: generateId(), timestamp: new Date().toISOString(), type: 'system', content: 'Agent 已停止' })
-        persistAgents()
-      }
-      return
+  async function stopAgent(id: string) {
+    const agent = state.agents.find((a) => a.id === id)
+    if (!agent) return
+
+    // 乐观更新：立即改 UI 状态，不再等待后端确认
+    const previousStatus = agent.status
+    agent.status = 'stopped'
+    agent.pid = undefined
+    agent.logs.push({ id: generateId(), timestamp: new Date().toISOString(), type: 'system', content: 'Agent 已停止' })
+    persistAgents()
+
+    if (!isTauri) return
+
+    try {
+      await sendToEngine({ type: 'stop-agent', agentId: id })
+    } catch (err) {
+      log.error('停止 Agent 失败:', err)
+      // 后端调用失败时恢复状态
+      agent.status = previousStatus
+      persistAgents()
     }
-    sendToEngine({ type: 'stop-agent', agentId: id })
   }
 
   function submitForReview(id: string) {