feat: chat pipeline tracing + markdown table scroll fix (v0.1.13)

- 新增 [trace:cap] 全链路追踪日志（home/agent/runner/llm/client）
  覆盖 chat.start → agent.iter → tool → message_stop 全生命周期
  max_tokens 场景提为 warn 级，定位「干着干着断了」问题
- 修复 Markdown 宽表被 bubble 裁切：table 外包滚动层 + CSS class
  移除 inline style，改用 .markdown-table-wrap 样式
- runner.ts 增加 stopReason 追踪（converged/max_supersteps/aborted）

Author: shijianzhong

package.json

@@ -1,6 +1,6 @@
 {
   "name": "one",
-  "version": "0.1.12",
+  "version": "0.1.13",
   "description": "One desktop app built with Electron, React, and TypeScript.",
   "main": "./out/main/index.cjs",
   "author": "shijianzhong",

src/main/ipc/home.ts

@@ -452,6 +452,15 @@ export function registerHomeHandlers(): void {
         `caps=[${mentions.capabilities.map((c) => c.name).join(',')}] skills=[${mentions.skills.map((s) => s.name).join(',')}] ` +
         `→ ${focusCap ? 'focusCap(主Agent介绍/组队)' : directAgent ? 'directAgent' : '主Agent路由'}`,
     )
+    logger.info(
+      `[trace:cap] home.chat.start session=${sid} focusCap=${focusCap?.id ?? '-'}(${focusCap?.name ?? '-'}) ` +
+        `msgLen=${message.length} msgHead=${JSON.stringify(message.slice(0, 80))}`,
+    )
+    signal.addEventListener(
+      'abort',
+      () => logger.warn(`[trace:cap] home.signal.abort session=${sid}`),
+      { once: true },
+    )
 
     try {
       if (directAgent) {
@@ -464,9 +473,11 @@ export function registerHomeHandlers(): void {
         )
         if (!graph) throw new Error('组队图构建失败')
         const question = mentions.cleanText || message
+        logger.info(`[trace:cap] home.directAgent → runTeam agents=${directAgent.map((a) => a.id).join(',')}`)
         const result = await runTeam(graph, question, sid, buildDeps, emitStream, signal)
         addMessage({ sessionId: sid, role: 'assistant', content: result.output })
         emitStream({ type: 'message_stop', stop_reason: 'end_turn' })
+        logger.info(`[trace:cap] home.directAgent.end session=${sid} outputLen=${result.output.length}`)
         return { runId: sid }
       }
 
@@ -509,6 +520,10 @@ export function registerHomeHandlers(): void {
       if (result.hitIterationLimit) {
         logger.warn('[home] 主 Agent 达工具轮次上限，已强制无工具收尾')
       }
+      logger.info(
+        `[trace:cap] home.mainAgent.end session=${sid} hitIterLimit=${result.hitIterationLimit} ` +
+          `finalTextLen=${finalText.length} textTail=${JSON.stringify(finalText.slice(-80))}`,
+      )
 
       // —— 创建幻觉补跑：自称已入库 / 否认持久化，但从未调 propose_* → 按 kind 定向挂工具再跑 ——
       // 挡「嘴上创建成功、确认卡从未出现」；澄清追问不触发（见 needsCreateRecovery）。
@@ -591,13 +606,25 @@ export function registerHomeHandlers(): void {
 
       // 流结束：判定直答 vs 组队
       const decision = detector.decide()
+      logger.info(
+        `[trace:cap] home.router.decide session=${sid} kind=${decision.kind}` +
+          (decision.kind === 'team' ? ` json=${JSON.stringify(decision.json)}` : ''),
+      )
       if (decision.kind === 'team') {
         // 组队：拼编排图跑 runner，事件经 orch_event 转前端
         logger.info('[home-router] 判为组队:', JSON.stringify(decision.json))
         emitStream({ type: 'run_id', sessionId: sid })
         const graph = buildTeamGraph(decision.json, getAgent, getCapability)
         if (graph) {
+          logger.info(
+            `[trace:cap] home.team.run session=${sid} graphNodes=${graph.nodes.length} ` +
+              `types=[${graph.nodes.map((n) => `${n.id}:${n.type}`).join(',')}]`,
+          )
           const teamResult = await runTeam(graph, message, sid, buildDeps, emitStream, signal)
+          logger.info(
+            `[trace:cap] home.team.done session=${sid} outputLen=${teamResult.output.length} ` +
+              `tail=${JSON.stringify(teamResult.output.slice(-80))}`,
+          )
           addMessage({
             sessionId: sid,
             role: 'assistant',
@@ -611,6 +638,7 @@ export function registerHomeHandlers(): void {
         } else {
           // 组队 JSON 指向的 role/capability 全失效 → 回退直答
           logger.warn('[home-router] 组队图构建失败（role/capability 失效），回退直答')
+          logger.warn(`[trace:cap] home.team.graph_build_failed session=${sid} json=${JSON.stringify(decision.json)}`)
           const direct = detector.flushDirect()
           if (direct) emitStream({ type: 'text', text: direct })
           addMessage({
@@ -625,6 +653,9 @@ export function registerHomeHandlers(): void {
         }
       } else {
         // 直答：flush 尾窗残留推前端，存档
+        logger.info(
+          `[trace:cap] home.direct session=${sid} focusCap=${!!focusCap} finalTextLen=${finalText.length}`,
+        )
         const tail = detector.flushDirect()
         if (tail) emitStream({ type: 'text', text: tail })
         addMessage({
@@ -644,13 +675,16 @@ export function registerHomeHandlers(): void {
       )
 
       // 10. 结束事件：触顶收尾用 max_iterations，便于前端/日志区分假 end_turn
+      const stopReason = result.hitIterationLimit ? 'max_iterations' : 'end_turn'
+      logger.info(`[trace:cap] home.message_stop session=${sid} reason=${stopReason} aborted=${signal.aborted}`)
       emitStream({
         type: 'message_stop',
-        stop_reason: result.hitIterationLimit ? 'max_iterations' : 'end_turn',
+        stop_reason: stopReason,
       })
     } catch (e) {
       // 错误推到 AI 气泡位置（而非聊天区上方），含可重试提示
       const msg = e instanceof Error ? e.message : String(e)
+      logger.error(`[trace:cap] home.error session=${sid} aborted=${signal.aborted} err=${msg}`, e)
       emitStream({ type: 'error', error: msg })
       emitStream({ type: 'message_stop', stop_reason: 'error' })
       throw e

src/main/llm/client.ts

@@ -81,9 +81,22 @@ export class LLMClient {
     }
 
     const finalMessage = await stream.finalMessage()
-    logger.debug('[llm] finalMessage content types', finalMessage.content.map((b: { type: string }) => b.type))
-    // 清理最终 text 中的 thinking 标签（中转代理可能把标签留在 text block 里）
     const cleanedContent = fromAnthropicContent(finalMessage.content).map(stripThinkingTags)
+    const textLen = cleanedContent
+      .filter((b): b is { type: 'text'; text: string } => b.type === 'text')
+      .reduce((n, b) => n + b.text.length, 0)
+    const toolNames = cleanedContent
+      .filter((b): b is { type: 'tool_use'; id: string; name: string; input: unknown } => b.type === 'tool_use')
+      .map((b) => b.name)
+    // info：便于追踪「干着干着断了」——尤其 stop=max_tokens
+    logger.info(
+      `[trace:cap] llm.final model=${req.model} stop=${finalMessage.stop_reason ?? 'null'} ` +
+        `textLen=${textLen} tools=[${toolNames.join(',')}] ` +
+        `usage=${JSON.stringify(finalMessage.usage ?? null)}`,
+    )
+    if (finalMessage.stop_reason === 'max_tokens') {
+      logger.warn(`[trace:cap] llm.max_tokens model=${req.model} maxTokens=${req.maxTokens} textLen=${textLen}`)
+    }
     return {
       stopReason: finalMessage.stop_reason ?? null,
       content: cleanedContent,

src/main/orchestrator/agent.ts

@@ -88,8 +88,14 @@ export class Agent {
     let finalThinking = ''
     let hitIterationLimit = false
 
+    logger.info(
+      `[trace:cap] agent.start name=${this.config.name} model=${this.config.modelId} ` +
+        `maxIter=${maxIter} maxTokens=${this.config.defaultOptions.maxTokens} tools=${tools.length} msgs=${messages.length}`,
+    )
+
     for (let iter = 0; iter < maxIter; iter++) {
       if (input.signal?.aborted) {
+        logger.warn(`[trace:cap] agent.abort name=${this.config.name} iter=${iter}`)
         throw input.signal.reason ?? new Error('aborted')
       }
 
@@ -117,13 +123,24 @@ export class Agent {
       if (thinkingText) finalThinking = thinkingText
 
       // stop_reason 非 tool_use → 终止
-      if (response.stopReason !== 'tool_use') break
-
-      // 执行所有 tool_use 块，追加 tool_result
       const toolUses = response.content.filter(
         (b): b is Extract<LlmContentBlock, { type: 'tool_use' }> =>
           b.type === 'tool_use',
       )
+      logger.info(
+        `[trace:cap] agent.iter name=${this.config.name} iter=${iter}/${maxIter} ` +
+          `stop=${response.stopReason ?? 'null'} textLen=${text?.length ?? 0} ` +
+          `thinkingLen=${thinkingText?.length ?? 0} tools=[${toolUses.map((t) => t.name).join(',')}]`,
+      )
+      // max_tokens 常导致「干着干着断了」——正文被硬截断却当 end_turn 处理
+      if (response.stopReason === 'max_tokens') {
+        logger.warn(
+          `[trace:cap] agent.max_tokens name=${this.config.name} iter=${iter} ` +
+            `textTail=${JSON.stringify((text ?? '').slice(-80))}`,
+        )
+      }
+
+      if (response.stopReason !== 'tool_use') break
 
       if (limits.maxFunctionCalls && functionCallCount + toolUses.length > limits.maxFunctionCalls) {
         logger.warn(`[agent:${this.config.name}] 达 maxFunctionCalls，停止工具调用`)
@@ -135,6 +152,7 @@ export class Agent {
       for (const tu of toolUses) {
         functionCallCount++
         callbacks.onToolCall?.(tu.name, tu.input)
+        const toolStarted = Date.now()
 
         // —— Handoff 短路（铁律12）：handoff_to_X tool 不真执行 ——
         // 注入合成 result + 标记 target + 终止循环（MiddlewareTermination 等价）
@@ -146,6 +164,7 @@ export class Agent {
             content: JSON.stringify({ handoff_to: handoffTarget }),
             is_error: false,
           })
+          logger.info(`[trace:cap] agent.handoff name=${this.config.name} → ${handoffTarget}`)
           continue // 不 executeTool，短路
         }
 
@@ -162,6 +181,10 @@ export class Agent {
           },
         )
         callbacks.onToolResult?.(tu.name, result.content)
+        logger.info(
+          `[trace:cap] agent.tool name=${this.config.name} tool=${tu.name} ` +
+            `err=${result.isError} ms=${Date.now() - toolStarted} resultLen=${result.content.length}`,
+        )
         toolResults.push({
           type: 'tool_result',
           tool_use_id: tu.id,
@@ -188,7 +211,7 @@ export class Agent {
     // 触顶停在 tool_result 之后：强制无工具收尾，让模型基于已有结果给最终答复
     if (hitIterationLimit && needsToolResultFinalization(messages) && !input.signal?.aborted) {
       logger.warn(
-        `[agent:${this.config.name}] 达 maxIterations=${maxIter}，强制无工具收尾轮`,
+        `[trace:cap] agent.force_finalize name=${this.config.name} maxIterations=${maxIter}`,
       )
       const response = await client.stream({
         model: this.config.modelId,
@@ -207,8 +230,16 @@ export class Agent {
       if (text) finalText = text
       const thinkingText = extractThinking(response.content)
       if (thinkingText) finalThinking = thinkingText
+      logger.info(
+        `[trace:cap] agent.force_finalize.done name=${this.config.name} ` +
+          `stop=${response.stopReason ?? 'null'} textLen=${text?.length ?? 0}`,
+      )
     }
 
+    logger.info(
+      `[trace:cap] agent.end name=${this.config.name} hitIterLimit=${hitIterationLimit} ` +
+        `finalTextLen=${finalText.length} textTail=${JSON.stringify(finalText.slice(-60))}`,
+    )
     return { messages, finalText, finalThinking, hitIterationLimit }
   }
 

src/main/orchestrator/home.ts

@@ -562,13 +562,29 @@ export async function runTeam(
   onEvent: (e: HomeStreamEvent) => void,
   signal?: AbortSignal,
 ): Promise<{ output: string }> {
+  const nodeSummary = graph.nodes
+    .map((n) => `${n.id}:${n.type}`)
+    .join(',')
+  logger.info(
+    `[trace:cap] runTeam.start session=${sessionId} nodes=[${nodeSummary}] ` +
+      `edges=${graph.edges.length} inputLen=${inputText.length}`,
+  )
+  const t0 = Date.now()
   const wf = buildWorkflow(graph, deps)
   const result = await runWorkflow(
     wf,
     { text: inputText, sessionId },
-    (e: StreamEvent) => onEvent({ type: 'orch_event', event: e }),
+    (e: StreamEvent) => {
+      if (e.type === 'failed' || e.type === 'node_error' || e.type === 'done') {
+        logger.info(`[trace:cap] runTeam.event type=${e.type} ${JSON.stringify(e).slice(0, 240)}`)
+      }
+      onEvent({ type: 'orch_event', event: e })
+    },
     signal,
   )
+  logger.info(
+    `[trace:cap] runTeam.end session=${sessionId} ms=${Date.now() - t0} outputLen=${result.output.length}`,
+  )
   return result
 }
 

src/main/orchestrator/patterns/agent.ts

@@ -9,6 +9,7 @@ import type { Executor } from '../models'
 import { Agent } from '../agent'
 import type { AgentConfig } from '@shared/types'
 import type { LLMClientOptions } from '../../llm/client'
+import { logger } from '../../logger'
 
 // —— Agent 叶子 Executor（§三 D + §三之三 G Sequential）——
 // handle 接收消息 → 组装 LlmMessage（strip_tool_blocks_filter 治 2013，
@@ -64,10 +65,17 @@ export class AgentExecutor implements Executor {
       onThinking: () => {},
     }
 
+    logger.info(
+      `[trace:cap] AgentExecutor.run id=${this.id} msgs=${messages.length} cache=${this.cache.length}`,
+    )
     const result = await this.agent.run(
       { messages, signal: this.agent.deps.toolCtx?.signal },
       callbacks,
     )
+    logger.info(
+      `[trace:cap] AgentExecutor.done id=${this.id} hitIterLimit=${result.hitIterationLimit} ` +
+        `finalTextLen=${result.finalText.length}`,
+    )
 
     // 把产出追加到 cache（供下游 fan-out）
     this.cache.push({