#Agent Loop：从一句话到完成任务

// src/entrypoints/cli.tsx
async function main() {
  // 快速路径：--version, --help 等不需要完整启动
  if (args.version) { /* 直接输出版本号，退出 */ }
  if (args.dumpSystemPrompt) { /* 输出 system prompt，退出 */ }

  // 完整启动：加载主模块
  const { cliMain } = await import('../main.js')
  await cliMain(/* ... */)
}

// src/bootstrap/state.ts (lines 44-256)
type State = {
  // 你在哪个目录工作
  originalCwd: string
  cwd: string
  projectRoot: string

  // 这次对话花了多少钱
  totalCostUSD: number

  // 每一轮用了多少工具
  turnToolCount: number

  // 会话唯一标识
  sessionId: SessionId

  // 上一次 API 请求的缓存（用于续传）
  lastAPIRequest: /* ... */ | null
  lastAPIRequestMessages: /* ... */ | null

  // 定时任务
  sessionCronTasks: SessionCronTask[]

  // ...更多字段
}

// src/bootstrap/state.ts (line 330)
sessionId: randomUUID() as SessionId

// src/QueryEngine.ts (lines 184-198)
export class QueryEngine {
  private mutableMessages: Message[]       // 所有历史消息
  private abortController: AbortController // 中断控制
  private permissionDenials: SDKPermissionDenial[] // 权限拒绝记录
  private totalUsage: NonNullableUsage     // 累计用量
}

// src/QueryEngine.ts (lines 209+)
async *submitMessage(
  prompt: string | ContentBlockParam[],
  options?: { uuid?: string; isMeta?: boolean },
): AsyncGenerator<SDKMessage, void, unknown> {

  // 1. 解析用户输入，处理斜杠命令
  const { shouldQuery } = await processUserInput(prompt)

  // 2. 如果是本地命令（如 /help），直接返回
  if (!shouldQuery) { yield localResult; return }

  // 3. 进入核心循环
  for await (const message of query({
    messages,
    systemPrompt,
    canUseTool: wrappedCanUseTool,
    maxTurns,
    taskBudget,
    // ...
  })) {
    // 4. 处理循环产出的每条消息
    switch (message.type) {
      case 'assistant': yield message; break
      case 'progress': yield message; break
      case 'stream_event': updateUsage(message); break
      // ...
    }
  }
}

// src/query.ts (lines 218-238)
export async function* query(params: QueryParams) {
  // 循环状态
  let state = {
    messages: [],
    turnCount: 0,
    hasAttemptedReactiveCompact: false,
    maxOutputTokensRecoveryCount: 0,
    // ...
  }

  while (true) {
    // ====== 阶段 1：调用 Claude API ======
    for await (const message of callModel({
      messages: state.messages,
      systemPrompt,
      tools: availableTools,
      // ...
    })) {
      yield message  // 流式输出给用户
    }

    // ====== 阶段 2：错误恢复 ======
    // 如果 prompt 太长，尝试压缩后重试
    // 如果输出被截断，提高 max_tokens 重试

    // ====== 阶段 3：执行工具 ======
    for await (const update of runTools(toolUseBlocks)) {
      yield update.message
    }

    // ====== 阶段 4：决定是否继续 ======
    if (noMoreToolCalls) break  // 模型没有调用工具 → 任务完成
    if (turnCount >= maxTurns) break  // 达到轮次上限
    if (aborted) break  // 用户中断

    // 否则：把工具结果加入消息，继续下一轮
    state.messages.push(...toolResults)
    state.turnCount++
    continue  // 回到 while(true) 顶部
  }
}

// src/query.ts (lines 1119-1166)
// 如果 API 返回 "prompt too long" 错误
if (withheldError?.type === 'prompt_too_long') {
  // 尝试压缩上下文（详见第6章）
  await compactConversation(messages, context)
  // 压缩成功 → 用新消息重试
  state.messages = compactedMessages
  continue  // 回到循环顶部
}

// src/query.ts (lines 1188-1256)
// 如果输出超过了 max_output_tokens
if (withheldError?.type === 'max_output_tokens') {
  // 从 8K 升级到 64K
  state.maxOutputTokensOverride = 64_000
  // 注入恢复消息："你的输出被截断了，请继续"
  state.messages.push(recoveryMessage)
  state.maxOutputTokensRecoveryCount++
  continue  // 重试（最多 3 次）
}