Class ConversationRuntime

tutorials/18_design_patterns_for_agents.py:246–296

注意: __init__ 不创建任何依赖, 全部从外部接收。 这就是依赖注入——"把依赖注入进来, 而不是自己造"。

    # 对应 conversation.rs:100-110 的 ConversationRuntime<C, T>
    class ConversationRuntime:
        """
        注意: __init__ 不创建任何依赖, 全部从外部接收。
        这就是依赖注入——"把依赖注入进来, 而不是自己造"。
        """
        def __init__(
            self,
            api_client: ApiClient,        # 从外部传入
            tool_executor: ToolExecutor,   # 从外部传入
            max_iterations: int = 10,
        ):
            self.api_client = api_client
            self.tool_executor = tool_executor
            self.max_iterations = max_iterations
            self.messages: list[dict] = []

        def run_turn(self, user_input: str) -> str:
            """对应 conversation.rs:170-283 的 run_turn"""
            self.messages.append({"role": "user", "content": user_input})

            for i in range(self.max_iterations):
                events = self.api_client.stream(self.messages)
                text_parts = []
                tool_calls = []

                for event in events:
                    if event["type"] == "text":
                        text_parts.append(event["text"])
                    elif event["type"] == "tool_use":
                        tool_calls.append(event)

                self.messages.append({
                    "role": "assistant",
                    "content": "".join(text_parts),
                    "tool_calls": tool_calls,
                })

                if not tool_calls:
                    return "".join(text_parts)

                for call in tool_calls:
                    result = self.tool_executor.execute(
                        call["name"], call["input"]
                    )
                    self.messages.append({
                        "role": "tool",
                        "tool_use_id": call["id"],
                        "content": result,
                    })

            return "达到最大迭代次数"

    # ---- 演示: 同一个 Runtime, 不同的 "插头" ----