查询的完整生命周期

// main.tsx:857-868
async function getInputPrompt(prompt, inputFormat) {
  if (!process.stdin.isTTY && !process.argv.includes('mcp')) {
    if (inputFormat === 'stream-json') return process.stdin;
    process.stdin.setEncoding('utf8');
    // ... 从 stdin 读取完整输入
  }
}

• 检测并执行斜杠命令（如 /compact、/clear）
• 加载附件消息（CLAUDE.md、memory 文件、图片等）
• 更新 allowedTools（来自 --allowedTools 标志）
• 返回 messagesFromUserInput、shouldQuery、resultText

// QueryEngine.ts:450-463
if (persistSession && messagesFromUserInput.length > 0) {
  const transcriptPromise = recordTranscript(messages);
  if (isBareMode()) { void transcriptPromise; }
  else { await transcriptPromise; }
}

// QueryEngine.ts:534-537
const [skills, { enabled: enabledPlugins }] = await Promise.all([
  getSlashCommandToolSkills(getCwd()),
  loadAllPluginsCacheOnly(),
]);

// QueryEngine.ts:675-686
for await (const message of query({
  messages, systemPrompt, userContext, systemContext,
  canUseTool: wrappedCanUseTool,
  toolUseContext: processUserInputContext,
  fallbackModel, querySource: 'sdk', maxTurns, taskBudget,
})) { ... }

• 收集 assistantMessages 用于后续工具执行
• 检测 tool_use 块并设置 needsFollowUp = true
• 对每个 tool_use 块，StreamingToolExecutor 立即开始执行
• withhold 可恢复错误（prompt-too-long、max-output-tokens）

// query.ts:799-825 withhold 逻辑
let withheld = false;
if (contextCollapse?.isWithheldPromptTooLong(message, ...)) withheld = true;
if (reactiveCompact?.isWithheldPromptTooLong(message)) withheld = true;
if (isWithheldMaxOutputTokens(message)) withheld = true;
if (!withheld) yield yieldMessage;

// 决策优先级
if (isWithheld413) {
  // 1. 尝试 Context Collapse drain → continue
  // 2. 尝试 Reactive Compact → continue
  // 3. 都失败 → yield 错误，终止
}
if (isWithheldMaxOutputTokens) {
  // 1. 首次：提升 max_output_tokens 到 64k → continue
  // 2. 后续：注入恢复消息 → continue
  // 3. 达到限制 → yield 错误
}
if (lastMessage?.isApiErrorMessage) {
  // 其他 API 错误 → 执行失败 hooks → 终止
}
// Stop Hooks 检查 → 可能 continue
// Token Budget 检查 → 可能 continue
// 正常完成 → return { reason: 'completed' }

1. 权限检查：canUseTool() 根据权限模式决定允许/拒绝/询问用户
2. 工具执行：每个工具实现 execute() 方法，返回结构化结果
3. 结果规范化：normalizeMessagesForAPI() 将工具结果转换为 API 可消费的格式
4. 上下文更新：工具可能返回新的 toolUseContext（如新的文件状态）

// query.ts:1380-1408
const toolUpdates = streamingToolExecutor
  ? streamingToolExecutor.getRemainingResults()
  : runTools(toolUseBlocks, assistantMessages, canUseTool, toolUseContext);
for await (const update of toolUpdates) {
  if (update.message) {
    yield update.message;
    toolResults.push(...normalizeMessagesForAPI([update.message], tools));
  }
  if (update.newContext) updatedToolUseContext = { ...update.newContext, queryTracking };
}

// query.ts 简化的 continue 模式
state = {
  messages: [...messagesForQuery, ...assistantMessages, ...toolResults],
  toolUseContext: updatedToolUseContext,
  autoCompactTracking: tracking,
  maxOutputTokensRecoveryCount: 0,
  // ...
  transition: { reason: 'tool_execution' },
};
continue; // → 回到 Stage 6 的压缩管道

1. yield SDKResultMessage（包含成本、持续时间、使用量统计）
2. 更新 this.mutableMessages（会话消息历史）
3. 记录最终转录