Dive MCP Host

✨ Dive MCP Host を選ぶ理由

MCP エコシステムは急速に成長していますが、多くのホストは単一の LLM、単一のトランスポート、または単一のフロントエンドに強く依存しています。Dive MCP Host はその逆です。あらゆる MCP サーバーの集合を単一のエージェントバックエンドに変換する、トランスポート非依存、モデル非依存のランタイムです。

• 🧠 あらゆる LLM — OpenAI、Anthropic、Google、AWS Bedrock、Mistral、DeepSeek、Ollama、Azure OpenAI など、LangChain が対応するものなら何でも利用できます。
• 🔌 あらゆる MCP サーバー — stdio、sse、streamable-http、websocket に加え、「起動して接続する」ローカル HTTP モードにも対応しています。
• 🛰 3 つの利用方法 — SDK を埋め込む、HTTP API を使う、または CLI から操作できます。
• 🧩 仕様に準拠した機能ネゴシエーション — サーバーが機能を通知した場合にのみ tools/list / prompts/list を呼び出し、「Method not found」にも適切に対処します。
• 💬 MCP プロンプトを第一級の機能として提供 — notifications/prompts/list_changed に応じて、一覧表示、取得、レンダリング、更新ができます。
• 🔐 OAuth とエリシテーションを標準搭載 — サーバーごとの個別対応なしで、対話型フローをホストに伝達します。
• 🗃 永続スレッド — LangGraph を介した SQLite または Postgres のチェックポイントにより、メッセージ、OAuth トークン、会話状態が再起動後も保持されます。

🏗 アーキテクチャの概要

flowchart LR
    subgraph Clients
        UI[Dive Desktop<br/>Electron / Tauri]
        CLI[dive_cli]
        SDK[Python SDK<br/>DiveMcpHost]
    end

    subgraph Host[dive-mcp-host]
        HTTP[FastAPI<br/>dive_httpd]
        Core[DiveMcpHost<br/>+ ToolManager<br/>+ Chat / LangGraph]
        DB[(SQLite / Postgres<br/>messages • OAuth • checkpoints)]
    end

    subgraph LLMs
        OAI[OpenAI]
        Anthropic[Anthropic]
        Ollama[Ollama]
        Etc[…and more]
    end

    subgraph MCPServers[MCP Servers]
        Stdio[stdio<br/>local subprocess]
        SSE[SSE]
        StreamHTTP[streamable-http]
        WS[websocket]
    end

    UI --> HTTP
    CLI --> Core
    SDK --> Core
    HTTP --> Core
    Core --> LLMs
    Core --> MCPServers
    Core --> DB

3 つのエントリーポイントすべてで、同じ DiveMcpHost コアを再利用します。HTTP レイヤーは薄い FastAPI ラッパーで、CLI と SDK はさらに薄い構成です。

ライフサイクル

すべてが非同期コンテキストマネージャー（ContextProtocol）です。リソースは厳密にネストされるため、クリーンアップが確実に行われます。

sequenceDiagram
    participant App
    participant Host as DiveMcpHost
    participant TM as ToolManager
    participant Srv as McpServer × N
    participant Chat

    App->>Host: async with DiveMcpHost(config)
    Host->>TM: enter
    TM->>Srv: spawn / connect each server (parallel)
    Srv->>Srv: initialize() → read capabilities
    Srv-->>Srv: tools/list (if advertised)
    Srv-->>Srv: prompts/list (if advertised)
    App->>Host: host.chat(chat_id=...)
    Host->>Chat: build LangGraph agent over tools
    App->>Chat: query("hello")
    Chat-->>App: stream events
    App->>Host: __aexit__
    Host->>TM: shutdown all servers

🚀 クイックスタート

インストール

# Recommended: uv (respects uv.lock)
uv sync --frozen

# Or with pip
pip install -e .

# With dev tools (pytest, ruff, …)
uv sync --extra dev --frozen

Python 3.12+ が必要です。

HTTP サービスを実行する

dive_httpd

デフォルトでは 0.0.0.0:61990 でサービスを提供します。dive_httpd.json で設定できます（DB、チェックポインター、CORS）。

CLI を試す

dive_cli "Summarize today's news"
dive_cli -c CHAT_ID "and what about tech?"   # resume a thread

Python に埋め込む

from dive_mcp_host.host.host import DiveMcpHost
from dive_mcp_host.host.conf import HostConfig

config = HostConfig(...)  # see model_config.json / mcp_config.json samples

async with DiveMcpHost(config) as host:
    async with host.chat(chat_id="demo") as chat:
        async for event in chat.query("hello"):
            print(event)

⚙️ 設定

サービスは 3 つの JSON ファイルで設定します。サンプルはリポジトリのルートにあります。

{
  "mcpServers": {
    "fetch": {
      "transport": "stdio",
      "command": "uvx",
      "args": ["mcp-server-fetch@latest"]
    },
    "weather": {
      "transport": "streamable",
      "url": "https://example.com/mcp"
    }
  }
}

{
  "activeProvider": "ollama",
  "configs": {
    "openai":     { "modelProvider": "openai",    "model": "gpt-4o-mini", "apiKey": "..." },
    "anthropic":  { "modelProvider": "anthropic", "model": "claude-sonnet-4-5" },
    "ollama":     { "modelProvider": "ollama",    "model": "qwen2.5:14b",
                    "configuration": { "baseURL": "http://localhost:11434" } }
  }
}

{
  "db":           { "uri": "sqlite:///db.sqlite", "async_uri": "sqlite+aiosqlite:///db.sqlite", "migrate": true },
  "checkpointer": { "uri": "sqlite:///db.sqlite" },
  "cors_origin":  "http://localhost:5173"
}

🧩 MCP の機能サポート

Dive はMCP の仕様に従って機能をネゴシエートします。各サーバーの initialize レスポンスを確認し、通知されたエンドポイントのみを 照会します。これにより、「サーバーが X を実装していないため ホストがクラッシュする」という種類のバグをすべて防ぎます。

Prompts HTTP API

GET  /api/tools/{server}/prompts          # list (?refresh=true bypasses cache)
POST /api/tools/{server}/prompts/get      # body: {"name": "...", "arguments": {...}}

両エンドポイントは、リポジトリ標準の DataResult[T] エンベロープ （{success, message, data}）を返します。data は、チャットスレッドに 追加できる状態のプロンプト一覧、またはレンダリング済みの GetPromptResult（説明と順序付けられた PromptMessage）です。

🔭 HTTP API 一覧

🧪 開発

# Install dev deps
uv sync --extra dev --frozen

# (Optional) local Postgres for tests/dev
./scripts/run_pg.sh

# Run the full suite
pytest

# Single test
pytest tests/test_tools.py::test_mcp_server_info

# Integration tests only
pytest -m integration

# Lint & format (ruff is the only tool you need)
ruff check .
ruff format .

# DB migrations
alembic upgrade head
alembic revision --autogenerate -m "describe change"

venv を有効化せずに実行する場合：

uv run --extra dev --frozen pytest

🤝 貢献

このリポジトリは、Dive デスクトップアプリ の Python バックエンドです。ワイヤー 形式を変更する PR は、リリース済みの Dive ビルドとの後方互換性を維持する必要があります。 既存の機能を壊す変更ではなく、フィールドや新しいエンドポイントの追加を優先してください。

📜 ライセンス

MIT — LICENSE を参照してください。