Function runChatTurn

apps/cli/src/ai/chat-command.ts:149–338

(
  options: Required<Pick<ChatCommandOptions, 'question'>> &
    Pick<ChatCommandOptions, 'sessionId' | 'aiChatId' | 'json' | 'stream' | 'locale' | 'includeEvents'>,
  deps: ChatCommandDeps
)

}

export async function runChatTurn(
  options: Required<Pick<ChatCommandOptions, 'question'>> &
    Pick<ChatCommandOptions, 'sessionId' | 'aiChatId' | 'json' | 'stream' | 'locale' | 'includeEvents'>,
  deps: ChatCommandDeps
): Promise<ChatTurnResult> {
  const stdout = deps.stdout ?? process.stdout
  const target = resolveAIChatTarget(options, deps)
  const startedAt = Date.now()
  let answer = ''
  let tokenUsage: TokenUsageData | null = null
  let streamError: Error | null = null
  const events: AgentStreamChunk[] = []
  const contentBlocks: ContentBlock[] = []
  let hasReplayContentBlocks = false

  const runAgentStream = (deps.createRunAgentStream ?? createCliRunAgentStream)(deps.dbManager, deps.aiChatManager)

  // 中文注释：CLI 历史回放依赖 contentBlocks 的时序；只要出现计划/思考块，
  // 就同步保留后续正文 text block，避免 UI 使用 blocks 渲染时丢失最终回答。
  const appendTextBlock = (text: string) => {
    if (!text) return
    const lastBlock = contentBlocks[contentBlocks.length - 1]
    if (lastBlock?.type === 'text') {
      lastBlock.text += text
    } else {
      contentBlocks.push({ type: 'text', text })
    }
  }

  const appendThinkBlock = (text: string, tag = 'thinking', durationMs?: number) => {
    if (!text && durationMs === undefined) return
    const lastBlock = contentBlocks[contentBlocks.length - 1]
    let targetBlock: ContentBlock | undefined

    if (lastBlock?.type === 'think' && lastBlock.tag === tag) {
      lastBlock.text += text
      targetBlock = lastBlock
    } else if (text.trim().length > 0) {
      targetBlock = { type: 'think', tag, text }
      contentBlocks.push(targetBlock)
    } else if (durationMs !== undefined) {
      for (let index = contentBlocks.length - 1; index >= 0; index--) {
        const block = contentBlocks[index]
        if (block.type === 'think' && block.tag === tag) {
          targetBlock = block
          break
        }
      }
    }

    if (durationMs !== undefined && targetBlock?.type === 'think') {
      targetBlock.durationMs = durationMs
    }
    if (targetBlock?.type === 'think') {
      hasReplayContentBlocks = true
    }
  }