Spawn a mock agent, returns the manager.
(mgr, agent_id="a", name="A", **kwargs)
| 207 | |
| 208 | |
| 209 | async def _spawn_mock_agent(mgr, agent_id="a", name="A", **kwargs): |
| 210 | """Spawn a mock agent, returns the manager.""" |
| 211 | mock_ctx = MagicMock() |
| 212 | mock_ctx.agent_id = agent_id |
| 213 | mock_ctx.initialize = AsyncMock(return_value=True) |
| 214 | mock_ctx.openai_tools = [] |
| 215 | mock_ctx.conversation_history = [] |
| 216 | mock_ctx.exit_requested = True # stop loop immediately |
| 217 | mock_ctx.dashboard_bridge = None |
| 218 | mock_ctx._system_prompt = "" |
| 219 | mock_ctx._system_prompt_dirty = False |
| 220 | |
| 221 | with ( |
| 222 | patch( |
| 223 | "mcp_cli.chat.chat_context.ChatContext.create", |
| 224 | return_value=mock_ctx, |
| 225 | ), |
| 226 | patch("mcp_cli.dashboard.bridge.DashboardBridge") as MockBridge, |
| 227 | ): |
| 228 | mock_bridge = MagicMock() |
| 229 | mock_bridge.set_context = MagicMock() |
| 230 | mock_bridge.set_input_queue = MagicMock() |
| 231 | MockBridge.return_value = mock_bridge |
| 232 | |
| 233 | cfg = AgentConfig(agent_id=agent_id, name=name, **kwargs) |
| 234 | await mgr.spawn_agent(cfg) |
| 235 | |
| 236 | return mgr |
| 237 | |
| 238 | |
| 239 | # --------------------------------------------------------------------------- |
no test coverage detected