flowchart LR
    Host["MCP Host"]
    External["External MCP Server"]

    subgraph Package["opensquilla_mcp_gateway"]
        Server["FastMCP stdio server"]
        Bridge["OpenSquillaMCPBridge"]
        RPC["GatewayRPCClient"]
        Discovery["MCP discovery"]
        Registry["ToolRegistry"]
        Stdio["MCPStdioClient"]
        SSE["MCPSSEClient"]
    end

    Gateway["OpenSquilla Gateway<br/>WebSocket RPC"]
    Agent["Agent Runtime"]

    Host -->|"MCP JSON-RPC over stdio"| Server
    Server --> Bridge
    Bridge --> RPC
    RPC --> Gateway

    Agent --> Registry
    Registry --> Discovery
    Discovery --> Stdio
    Discovery --> SSE
    Stdio --> External
    SSE --> External

src/opensquilla_mcp_gateway/
├── server.py          # FastMCP tools 和 resources
├── bridge.py          # MCP -> Gateway 会话工作流适配
├── gateway_client.py  # WebSocket RPC client、事件队列与 heartbeat
├── client.py          # 出站 MCPClient 抽象接口
├── stdio.py           # 出站 stdio transport
├── sse.py             # 出站 HTTP+SSE transport
├── discovery.py       # tools/list、ToolSpec 转换与 client 生命周期
├── registry.py        # 独立包使用的最小 ToolRegistry
├── types.py           # MCP 配置、工具和结果类型
├── env.py             # HTTPX 环境代理开关
├── cli.py             # opensquilla-mcp-gateway run
└── __main__.py        # python -m opensquilla_mcp_gateway

tests/
├── test_protocol_smoke.py
├── test_stdio_client.py
├── test_sse_client.py
├── test_discovery_lifecycle.py
├── test_gateway_client.py
├── test_bridge.py
├── test_server.py
└── test_cli.py

git clone https://github.com/nhtqgm/opensquilla-mcp-gateway.git
Set-Location opensquilla-mcp-gateway
py -3.12 -m venv .venv
.venv\Scripts\python.exe -m pip install -e ".[dev]"

git clone https://github.com/nhtqgm/opensquilla-mcp-gateway.git
cd opensquilla-mcp-gateway
python3.12 -m venv .venv
.venv/bin/python -m pip install -e '.[dev]'

ws://127.0.0.1:18791/ws

.venv\Scripts\opensquilla-mcp-gateway.exe run `
  --gateway ws://127.0.0.1:18791/ws

.venv\Scripts\python.exe -m opensquilla_mcp_gateway run `
  --gateway ws://127.0.0.1:18791/ws

$env:OPENSQUILLA_GATEWAY_URL = "ws://127.0.0.1:18791/ws"
.venv\Scripts\opensquilla-mcp-gateway.exe run

{
  "mcpServers": {
    "opensquilla": {
      "command": "C:\\path\\to\\repo\\.venv\\Scripts\\python.exe",
      "args": [
        "-m",
        "opensquilla_mcp_gateway",
        "run",
        "--gateway",
        "ws://127.0.0.1:18791/ws"
      ]
    }
  }
}

session.event.done
session.event.error
task.cancelled
task.failed
task.timeout
task.abandoned

import asyncio

from opensquilla_mcp_gateway.discovery import (
    close_active_clients,
    discover_and_register,
)
from opensquilla_mcp_gateway.registry import ToolRegistry
from opensquilla_mcp_gateway.types import MCPServerConfig


async def main() -> None:
    registry = ToolRegistry()
    config = MCPServerConfig(
        name="filesystem",
        transport="stdio",
        command="npx",
        args=["-y", "@modelcontextprotocol/server-filesystem", "."],
        tool_timeout_seconds=30,
    )

    try:
        names = await discover_and_register(config, registry)
        print(names)
    finally:
        await close_active_clients()


asyncio.run(main())

config = MCPServerConfig(
    name="remote",
    transport="sse",
    url="http://127.0.0.1:8000/sse",
    tool_timeout_seconds=30,
)

.venv\Scripts\python.exe -m ruff check src tests
.venv\Scripts\python.exe -m pytest -q

33 passed（MCP Python SDK 1.29.0）