Method _wrap

src/server/mcp_runtime.py:116–144

Build a loop-correct sync Tool that dispatches to the connection loop.

(self, server: str, mcp_tool: Any, client: Any)

        return True

    def _wrap(self, server: str, mcp_tool: Any, client: Any) -> Any:
        """Build a loop-correct sync Tool that dispatches to the connection loop."""
        from src.services.mcp.mcp_string_utils import build_mcp_tool_name
        from src.tool_system.build_tool import build_tool
        from src.tool_system.protocol import ToolResult

        full = build_mcp_tool_name(server, mcp_tool.name)
        schema = getattr(mcp_tool, "input_schema", None) or {"type": "object", "properties": {}}
        loop = self._loop

        def _call(args: dict[str, Any], ctx: Any) -> ToolResult:
            try:
                fut = asyncio.run_coroutine_threadsafe(client.call_tool(mcp_tool.name, args), loop)
                res = fut.result(_CALL_TIMEOUT_S)
            except Exception as exc:  # noqa: BLE001
                return ToolResult(name=full, output=f"MCP call failed: {exc}", is_error=True)
            return ToolResult(
                name=full,
                output=_render_content(getattr(res, "content", None)),
                is_error=bool(getattr(res, "is_error", False)),
            )

        return build_tool(
            name=full,
            input_schema=schema,
            call=_call,
            description=getattr(mcp_tool, "description", None) or f"MCP tool {full}",
            is_mcp=True,
        )

    def shutdown(self) -> None:
        """Disconnect clients and stop the background loop. Idempotent."""