src/magentic_ui/
├── teams/
│   ├── orchestrator/
│   │   ├── _group_chat.py      # GroupChat 類定義，管理參與者的狀態(tài)
│   │   ├── _orchestrator.py    # Orchestrator 類定義，維護(hù)對(duì)話的狀態(tài)
│   │   └── orchestrator_config.py    # 相關(guān)的配置 
│   └── roundrobin_orchestrator.py    # 輪詢狀態(tài)的管理
├── agents/
│   ├── file_surfer/
│   │   └── _file_surfer.py
│   ├── web_surfer/
│   │   └── _web_surfer.py
│   └── users/
│       ├── _dummy_user_proxy.py
│       └── _metadata_user_proxy.py
├── backend/
│   ├── teammanager/
│       └── _teammanager.py
└── task_team.py

# src\magentic_ui\task_team.py
# 用戶代理的創(chuàng)建
user_proxy: DummyUserProxy | MetadataUserProxy | UserProxyAgentif magentic_ui_config.user_proxy_type == "dummy":user_proxy = DummyUserProxy(name="user_proxy")elif magentic_ui_config.user_proxy_type == "metadata":assert (magentic_ui_config.task is not None), "Task must be provided for metadata user proxy"assert (magentic_ui_config.hints is not None), "Hints must be provided for metadata user proxy"assert (magentic_ui_config.answer is not None), "Answer must be provided for metadata user proxy"user_proxy = MetadataUserProxy(name="user_proxy",description="Metadata User Proxy Agent",task=magentic_ui_config.task,helpful_task_hints=magentic_ui_config.hints,task_answer=magentic_ui_config.answer,model_client=model_client_orch,)else:user_proxy_input_func = make_agentchat_input_func(input_func)user_proxy = UserProxyAgent(description=USER_PROXY_DESCRIPTION,name="user_proxy",input_func=user_proxy_input_func,)# 輪詢代理if websurfer_loop_team:# simplified team of only the web surferteam = RoundRobinGroupChat(participants=[web_surfer, user_proxy],max_turns=10000,)await team.lazy_init()return team# 由LLM智能選擇team = GroupChat(participants=[web_surfer, user_proxy, coder_agent, file_surfer],orchestrator_config=orchestrator_config,model_client=model_client_orch,memory_provider=memory_provider,)await team.lazy_init()return team

async def on_messages_stream(self, messages: Sequence[BaseChatMessage], cancellation_token: CancellationToken
) -> AsyncGenerator[BaseAgentEvent | BaseChatMessage | Response, None]:"""處理輸入消息并生成響應(yīng)流這是核心方法，處理所有消息邏輯"""# 1. 嚴(yán)格模式下的提示重寫if (self.how_helpful == "strict"and self.helpful_task_hintsand self.helpful_task_hints != "Helpful hints are not available for this task."and self.rewritten_helpful_task_hints is None):self.rewritten_helpful_task_hints = await self._rewrite_helpful_hints(cancellation_token)# 2. 消息處理chat_messages = thread_to_context(list(messages),agent_name=self.name,is_multimodal=self._model_client.model_info["vision"],)self._chat_history.extend(chat_messages)# 3. 階段判斷if ("type" in messages[-1].metadataand messages[-1].metadata["type"] == "plan_message"):self.have_encountered_plan_message = Trueself.in_planning_phase = Trueelse:if self.have_encountered_plan_message:self.in_planning_phase = Falseelse:self.in_planning_phase = True# 4. 模型上下文準(zhǔn)備await self._model_context.clear()system_message = SystemMessage(content=self._get_system_message())await self._model_context.add_message(system_message)# 5. 添加聊天歷史for msg in self._chat_history:await self._model_context.add_message(msg)# 6. 獲取token限制的歷史記錄token_limited_history = await self._model_context.get_messages()# 7. 規(guī)劃階段處理if self.in_planning_phase:if self.simulated_user_type in ["co-planning", "co-planning-and-execution"]:if (self.max_co_planning_rounds is Noneor self.current_co_planning_round < self.max_co_planning_rounds):# 生成規(guī)劃響應(yīng)result = await self._model_client.create(messages=token_limited_history,cancellation_token=cancellation_token,)yield Response(chat_message=TextMessage(content=result.content,source=self.name,metadata={"co_planning_round": str(self.current_co_planning_round),"user_plan_reply": "llm","helpful_task_hints": self.rewritten_helpful_task_hintsif self.rewritten_helpful_task_hintselse self.helpful_task_hints,},),inner_messages=[],)self.current_co_planning_round += 1else:# 達(dá)到最大規(guī)劃輪次yield Response(chat_message=TextMessage(content="accept",source=self.name,metadata={"co_planning_round": str(self.current_co_planning_round),"user_plan_reply": "accept",},),inner_messages=[],)else:# 非協(xié)作規(guī)劃模式yield Response(chat_message=TextMessage(content="accept",source=self.name,metadata={"co_planning_round": str(self.current_co_planning_round),"user_plan_reply": "accept",},),inner_messages=[],)# 8. 執(zhí)行階段處理else:if self.simulated_user_type in ["co-execution", "co-planning-and-execution"]:if (self.max_co_execution_rounds is Noneor self.current_co_execution_round < self.max_co_execution_rounds):# 生成執(zhí)行響應(yīng)result = await self._model_client.create(messages=token_limited_history,cancellation_token=cancellation_token,)yield Response(chat_message=TextMessage(content=result.content,source=self.name,metadata={"user_execution_reply": "llm"},),inner_messages=[],)self.current_co_execution_round += 1else:# 達(dá)到最大執(zhí)行輪次yield Response(chat_message=TextMessage(content="I don't know, you figure it out, don't ask me again.",source=self.name,),)else:# 非協(xié)作執(zhí)行模式yield Response(chat_message=TextMessage(content="I don't know, you figure it out, don't ask me again.",source=self.name,metadata={"user_execution_reply": "idk"},),)

 @rpcasync def handle_start(self, message: GroupChatStart, ctx: MessageContext) -> None:
# @rpc 是遠(yuǎn)程過程調(diào)用，運(yùn)行函數(shù)被遠(yuǎn)程調(diào)用，就像調(diào)用本地函數(shù)一樣
# message 來自于外部的調(diào)用.venv\Lib\site-packages\autogen_agentchat\teams\_group_chat\_base_group_chat.py 
文件中的 run_stream 方法，就是負(fù)責(zé)將初始值（初始消息）通過 GroupChatStart 消息傳遞
給群聊管理器（GroupChatManager）的地方。具體流程如下：'''
對(duì)第一點(diǎn)的self.team的解釋，實(shí)際上self.team就是代指GroupChat
路徑：src\magentic_ui\teams\orchestrator\_group_chat.py下的run_stream誰去調(diào)用？
不會(huì)直接 new 一個(gè) GroupChat 然后直接 run_stream，而是通過 TeamManager 統(tǒng)一管理
GroupChat.run_stream 的實(shí)際調(diào)用，主要是通過 TeamManager 的 self.team.run_stream 
實(shí)現(xiàn)的，這就是 “間接調(diào)用”
(本文件的)14，15，16行在src\magentic_ui\backend\teammanager\teammanager.py下的run_stream 調(diào)用
的313到315行代碼中async for message in self.team.run_stream(task=task, cancellation_token=cancellation_token):
其中的self.team.run_stream也就代指了GroupChat.run_stream
src\magentic_ui\backend\teammanager\teammanager.py 的 run_stream 由
src\magentic_ui\backend\web\managers\connection.py 下start_stream方法的run_stream調(diào)用
'''
1.調(diào)用 self.team.run_stream(task=...)，其中 task 可以是字符串、消息對(duì)象、
消息列表，或者為 None。2.run_stream 方法會(huì)把 task 轉(zhuǎn)換成 messages，然后封裝到 GroupChatStart(
messages=messages) 這個(gè)消息對(duì)象里。（路徑：.venv\Lib\site-packages\autogen_agentchat\teams\_group_chat\_base_group_chat.py）if task is None:# 如果 task 是 None，則 messages 也是 Nonepasselif isinstance(task, str):# 如果 task 是字符串，就會(huì)被包裝成一個(gè) TextMessage，放到 messages 列表里messages = [TextMessage(content=task, source="user")]elif isinstance(task, BaseChatMessage):# 如果 task 是單個(gè)消息對(duì)象，也會(huì)被放到 messages 列表里。messages = [task]elif isinstance(task, list):# 如果 task 是消息對(duì)象列表，則直接賦值給 messages。...# 也就是把 messages 作為參數(shù)，封裝進(jìn) GroupChatStart 消息對(duì)象里  499行await self._runtime.send_message(GroupChatStart(messages=messages),recipient=AgentId(type=self._group_chat_manager_topic_type, key=self._team_id),cancellation_token=cancellation_token,)3.通過 self._runtime.send_message(...)，把 GroupChatStart 
消息發(fā)送給群聊管理器（GroupChatManager）。
# .venv/Lib/site-packages/autogen_agentchat/teams/_group_chat/_base_group_chat.py 中的run_stream方法await self._runtime.send_message(GroupChatStart(messages=messages),recipient=AgentId(type=self._group_chat_manager_topic_type, key=self._team_id),cancellation_token=cancellation_token,)
# recipient=AgentId(type=self._group_chat_manager_topic_type, key=self._team_id) 
# 明確指定了接收者就是群聊管理器， _group_chat_manager_topic_type 就是Orchestrator這個(gè)群聊管理器實(shí)例4.群聊管理器收到 GroupChatStart 后，會(huì)調(diào)用 handle_start 方法，正式啟動(dòng)群聊流程。
# 對(duì)于 GroupChatStart 消息，自動(dòng)調(diào)用handle_start方法，message參數(shù)就是剛收到的 GroupChatStart消息