Method run_turn

mini_claude_code/runtime.py:328–394

源码: conversation.rs:170-283

(
        self,
        user_input: str,
        prompter: Optional[PermissionPrompter] = None,
    )

    # --------------------------------------------------------

    def run_turn(
        self,
        user_input: str,
        prompter: Optional[PermissionPrompter] = None,
    ) -> TurnSummary:
        """源码: conversation.rs:170-283"""
        # 推入用户消息 — conversation.rs:175-176
        self._session.messages.append(Message.user_text(user_input))

        assistant_messages: list[Message] = []
        tool_results: list[Message] = []
        iterations = 0

        # ===== 主循环 =====
        while True:
            iterations += 1
            if iterations > self._max_iterations:
                raise RuntimeError(
                    "conversation loop exceeded the maximum number of iterations"
                )

            # 调 API — conversation.rs:191-195
            events = self._api_client.stream(
                self._system_prompt,
                self._session.messages,
            )

            # 事件流 → 结构化消息 — conversation.rs:196
            assistant_message, usage = build_assistant_message(events)

            if usage is not None:
                self._usage_tracker.record(usage)

            # 提取 tool_use blocks — conversation.rs:200-209
            pending_tool_uses: list[tuple[str, str, str]] = []
            for block in assistant_message.content:
                if isinstance(block, ToolContentBlock):
                    pending_tool_uses.append(
                        (block.id, block.name, block.input)
                    )

            # 推入 session — conversation.rs:211
            self._session.messages.append(assistant_message)
            assistant_messages.append(assistant_message)

            # 没有 tool_use → 结束 — conversation.rs:214-216
            if not pending_tool_uses:
                break

            # 对每个 tool_use 执行 — conversation.rs:218-271
            for tool_use_id, tool_name, tool_input in pending_tool_uses:
                result_message = self._process_tool_use(
                    tool_use_id, tool_name, tool_input, prompter,
                )
                self._session.messages.append(result_message)
                tool_results.append(result_message)

        # 自动压缩 — conversation.rs:274