第 07 章：信封飞向远方

async function* numbers(): AsyncGenerator<number> {
  yield 1           // 产出一个值，暂停
  yield 2           // 产出一个值，暂停
  return 3          // 最终返回值
}

// 消费方式 1：for await...of（自动迭代）
for await (const num of numbers()) {
  console.log(num)  // 1, 2
}

// 消费方式 2：yield* 委托（在另一个生成器中转发）
async function* wrapper(): AsyncGenerator<number> {
  const finalValue = yield* numbers()  // 转发所有 yield，获取 return 值
  console.log(finalValue)              // 3
}

// → src/query.ts 的 query() 函数
export async function* query(
  params: QueryParams,
): AsyncGenerator<
  StreamEvent | RequestStartEvent | Message | TombstoneMessage | ToolUseSummaryMessage,
  Terminal
> {
  const consumedCommandUuids: string[] = []
  const terminal = yield* queryLoop(params, consumedCommandUuids)
  for (const uuid of consumedCommandUuids) {
    notifyCommandLifecycle(uuid, 'completed')
  }
  return terminal
}

// → src/query.ts 的 queryLoop() 函数（简化版）
async function* queryLoop(params, consumedCommandUuids) {
  const deps = params.deps ?? productionDeps()
  let state: State = {
    messages: params.messages,
    toolUseContext: params.toolUseContext,
    turnCount: 1,
  }

  while (true) {
    // 步骤 1-4：上下文管理（预防溢出）
    // 裁剪过大工具结果 → Snip 压缩 → Microcompact → Autocompact

    // === 步骤 5：API 调用 ===
    for await (const message of deps.callModel({
      messages: prependUserContext(messagesForQuery, userContext),
      systemPrompt: fullSystemPrompt,
      tools: toolUseContext.options.tools,
    })) {
      yield message  // 转发给 UI 层渲染
    }

    // === 步骤 6-9：工具执行 & 循环控制 ===
    if (!needsFollowUp) return { reason: 'end_turn' }
    state = { ...state, messages: [...messages, ...toolResults], turnCount: turnCount + 1 }
  }
}

// → src/query/deps.ts 的 productionDeps() 函数
export function productionDeps(): QueryDeps {
  return {
    callModel: queryModelWithStreaming,
    microcompact: microcompactMessages,
    autocompact: autoCompactIfNeeded,
    uuid: randomUUID,
  }
}

// → src/services/api/claude.ts 的 queryModelWithStreaming() 函数（简化版）
export async function* queryModelWithStreaming({
  messages, systemPrompt, thinkingConfig, tools, signal, options,
}): AsyncGenerator<StreamEvent | AssistantMessage> {
  return yield* withStreamingVCR(async function* () {
    yield* queryModel(messages, systemPrompt, thinkingConfig, tools, signal, options)
  })
}

// → src/services/api/client.ts
const clientConfig = {
  apiKey: isClaudeAISubscriber() ? null : apiKey || getAnthropicApiKey(),
  authToken: isClaudeAISubscriber()
    ? getClaudeAIOAuthTokens()?.accessToken
    : undefined,
}
return new Anthropic(clientConfig)

// → src/services/api/withRetry.ts 的 shouldRetry() 函数（简化版）
function shouldRetry(error: APIError): boolean {
  if (error.status === 408) return true       // 请求超时
  if (error.status === 401) return true        // 认证失败（刷新令牌后重试）
  if (error.status && error.status >= 500) return true  // 服务器错误
  return false
}

{
  system: [
    { type: 'text', text: '...' },                    // 静态区
    { type: 'text', text: '__SYSTEM_PROMPT_DYNAMIC_BOUNDARY__' },
    { type: 'text', text: '...' },                    // 动态区
  ],
  messages: [
    { role: 'user', content: [...] },
    { role: 'assistant', content: [...] },
    { role: 'user', content: [...] },     // 工具结果
  ],
  tools: [...],                // 工具列表（JSON Schema 格式）
  model: 'claude-sonnet-4-6',
  stream: true,                // 流式响应
}

console.log('[DEBUG] API call - turn:', turnCount, 'messages:', messagesForQuery.length)

if (message.type === 'assistant') {
  const blockTypes = message.message.content.map(b => b.type).join(', ')
  console.log('[DEBUG] assistant blocks:', blockTypes)
}

console.log('[DEBUG] Retry attempt:', attempt, 'error:', error.status)