MCP 和 A2A 协议

┌─────────────┐      MCP       ┌─────────────┐
│   LibreFang │ ◄─────────────► │  MCP Server │
│   (Client)  │   JSON-RPC 2.0  │  (Server)   │
└─────────────┘                  └─────────────┘

[[mcp_servers]]
name = "filesystem"
transport = { type = "stdio", command = "npx", args = ["-y", "@modelcontextprotocol/server-filesystem", "/tmp"] }

[[mcp_servers]]
name = "github"
transport = { type = "stdio", command = "npx", args = ["-y", "@modelcontextprotocol/server-github"] }
env = ["GITHUB_TOKEN"]

[[mcp_servers]]
name = "everyapi"
transport = { type = "stdio", command = "everyapi", args = ["mcp"] }
timeout_secs = 30
env = []

mcp_servers = ["everyapi"]

id = "everyapi"
name = "EveryAPI"
description = "Inspect and operate an EveryAPI gateway account — quota, seller channels, edge nodes — through the everyapi CLI's built-in MCP server"
category = "cloud"
icon = "lucide:gauge"
tags = ["everyapi", "gateway", "quota", "billing", "marketplace"]

[transport]
type = "stdio"
command = "everyapi"
args = ["mcp"]

[health_check]
interval_secs = 60
unhealthy_threshold = 3

setup_instructions = """
1. Install the EveryAPI CLI and run `everyapi login`, which writes ~/.config/everyapi/credentials.json.
2. Run `librefang mcp add everyapi`.
3. Add "everyapi" to the agent's mcp_servers list in its agent.toml.

No credential needs to be entered into LibreFang. The MCP server reads the gateway credentials file itself.
"""

[i18n.zh]
name = "EveryAPI"
description = "通过 everyapi CLI 内置的 MCP 服务器检视与操作 EveryAPI 网关账户 —— 配额、卖家渠道、边缘节点。"

everyapi_status  →  mcp_everyapi_everyapi_status

# ~/.librefang/config.toml
[approval]
require_approval = [
  "mcp_everyapi_everyapi_seller_add_*",        # add_key + 4 个 OAuth 工具
  "mcp_everyapi_everyapi_seller_withdraw",
  "mcp_everyapi_everyapi_admin_marketplace_set",
  "mcp_everyapi_everyapi_edge_remove",
]

Account: alice (alice@example.com)
Quota:    $12.34 remaining   $87.66 used
Requests: 1420
Top-up:   https://api.everyapi.ai/wallet

mcp_{server}_{tool}

[[mcp_servers]]
name = "custom"
transport = { type = "stdio", command = "python", args = ["./mcp_server.py"] }

from mcp.server import Server
from mcp.types import Tool, TextContent

app = Server("my-server")

@app.list_tools()
async def list_tools():
    return [
        Tool(
            name="my_tool",
            description="My custom tool",
            inputSchema={"type": "object", "properties": {}}
        )
    ]

@app.call_tool()
async def call_tool(name: str, arguments: dict):
    return [TextContent(type="text", text="result")]

# config.toml —— 按 tool 名模式全局 mute
[[mcp_taint_policy]]
tool = "mcp__github__create_pr"
skip_rules = ["AuthorizationLiteral"]   # 允许 GitHub MCP 转发 bearer token

┌─────────────┐      A2A       ┌─────────────┐
│   Agent A   │ ◄─────────────► │   Agent B   │
└─────────────┘   JSON over    └─────────────┘
                  HTTP/WebSocket

{
  "name": "researcher",
  "description": "Deep research agent",
  "url": "http://localhost:4545/api/a2a",
  "version": "1.0.0",
  "capabilities": {
    "streaming": true,
    "pushNotifications": false
  },
  "skills": [
    { "id": "research", "name": "Research" }
  ]
}

# 发现外部 agent
curl -X POST http://localhost:4545/api/a2a/discover \
  -H "Content-Type: application/json" \
  -d '{"url": "http://other-agent:4545"}'

# 向外部 agent 发送任务
curl -X POST http://localhost:4545/api/a2a/send \
  -H "Content-Type: application/json" \
  -d '{
    "agent_url": "http://other-agent:4545",
    "message": "Research AI trends and summarize"
  }'

# 查询任务状态
curl http://localhost:4545/api/a2a/tasks/task-123/status

# 外部 agent 向本实例发送任务
curl -X POST http://localhost:4545/api/a2a/tasks \
  -H "Content-Type: application/json" \
  -d '{
    "id": "task-456",
    "message": {
      "role": "user",
      "parts": [{ "type": "text", "text": "Research AI trends" }]
    }
  }'

# 轮询结果
curl http://localhost:4545/api/a2a/tasks/task-456

# 或使用 SSE 流式接收
curl -N http://localhost:4545/api/a2a/tasks/task-456/events

# MCP 服务器
[[mcp_servers]]
name = "filesystem"
transport = { type = "stdio", command = "npx", args = ["-y", "@modelcontextprotocol/server-filesystem", "/workspace"] }

[[mcp_servers]]
name = "github"
transport = { type = "stdio", command = "npx", args = ["-y", "@modelcontextprotocol/server-github"] }

# A2A 配置
[a2a]
enabled = true
listen_path = "/a2a"

# 列出 MCP 服务器
librefang mcp list

# 测试 MCP 服务器
librefang mcp test filesystem

# 启动 MCP 模式
librefang mcp