Agent Comm Hub

┌──────────────┐         ┌──────────────────────────────┐         ┌──────────────┐
│   Agent A    │  SSE    │   Agent Communication Hub    │  SSE    │   Agent B    │
│  (Hermes)    │◄───────►│  (stdio / HTTP:3100)       │◄───────►│ (WorkBuddy)  │
│              │  MCP    │                              │  MCP    │              │
└──────────────┘◄───────►│  SQLite WAL + 30 表          │◄───────►└──────────────┘
                          │  53 MCP 工具 + 4 级权限      │
                          │  进化引擎 + 策略闭环          │
                          └──────────────┬──────────────┘
                                         │
                                    SQLite (WAL)

inbox → assigned → [waiting] → in_progress → completed / failed / cancelled

git clone https://github.com/liuboacean/agent-comm-hub.git
cd agent-comm-hub
npm install
npm run build
npm start      # HTTP 模式（port 3100）
# 或
npm run stdio  # stdio 模式（用于 MCP stdio transport）

{
  "mcpServers": {
    "agent-comm-hub": {
      "command": "node",
      "args": ["./src/stdio.js"],
      "env": {
        "HUB_AUTH_TOKEN": "your-api-token",
        "DB_PATH": "./comm_hub.db"
      }
    }
  }
}

{
  "mcpServers": {
    "agent-comm-hub": {
      "url": "http://localhost:3100/mcp"
    }
  }
}

import { AgentClient } from "./client-sdk/agent-client.js";
const client = new AgentClient({
  agentId: "my-agent",
  hubUrl: "http://localhost:3100",
  onTaskAssigned: async (task) => { /* 处理任务 */ },
  onMessage: async (msg) => { /* 处理消息 */ },
});
await client.start();

import asyncio
from hub_client import HubClient

client = HubClient(
    agent_id="my-agent",
    hub_url="http://localhost:3100",
    on_task_assigned=lambda task: print(f"收到任务: {task['description']}"),
)
await client.start()

agent-comm-hub/
├── SKILL.md                          # 本文件
├── README.md                         # 完整文档（GitHub 级别）
├── LICENSE                           # MIT 许可证
│
├── src/                              # Hub 服务器核心（TypeScript）
│   ├── server.ts                     # 主入口：Express + MCP + SSE
│   ├── stdio.ts                      # stdio 传输入口点（MCP v1.10+）
│   ├── db.ts                         # SQLite 持久化层（WAL 模式，30 表）
│   ├── tools.ts                      # MCP 工具注册入口（~30 行，调度 8 模块）
│   ├── tools/                        # 工具模块（Phase A 拆分）
│   │   ├── identity.ts               #   身份工具（6）
│   │   ├── message.ts                #   消息工具（5）
│   │   ├── memory.ts                 #   记忆工具（5）
│   │   ├── file.ts                   #   文件工具（3）
│   │   ├── evolution.ts              #   进化工具（12）
│   │   ├── orchestrator.ts           #   编排工具（16）
│   │   ├── security.ts               #   安全工具（4）
│   │   └── consumed.ts              #   消费工具（2）
│   ├── errors.ts                     # HubError 统一错误码（Phase D）
│   ├── utils.ts                      # 工具函数：mcpError/mcpFail + dedup + hash
│   ├── types.ts                      # 全局类型定义（Phase D）
│   ├── identity.ts                   # Agent 身份 + trust_score + resolveAgentId
│   ├── evolution.ts                  # 进化引擎（策略 + feedback）
│   ├── security.ts                   # RBAC + 权限矩阵
│   ├── sse.ts                        # SSE 连接管理
│   ├── logger.ts                     # 结构化 JSON 日志
│   ├── metrics.ts                    # Prometheus 指标
│   ├── dedup.ts                      # 消息去重（sha256）
│   └── tokenizer.ts                  # N-gram 分词器（FTS5）
│
├── client-sdk/                       # SDK（Python 68 方法 + TypeScript 35 方法）
│
├── deploy/                           # 部署配置
│   ├── docker-compose.yml            # Prometheus + Grafana 监控栈
│   ├── prometheus.yml                # Prometheus 采集配置
│   └── grafana/                      # Grafana 仪表盘 JSON
│
├── .github/workflows/                # CI/CD（Phase C）
│   └── ci.yml                        # typecheck + test + coverage
│
├── scripts/
│   ├── migrate_from_agent.js         # 历史数据迁移（from_agent 规范化）
│   └── migrate_evolution_db.py       # Evolution DB 迁移
│
├── tests/                            # 单元测试（vitest 100 用例）+ Python 集成测试
│
└── docs/
    ├── SETUP_GUIDE.md               # 详细配置指南
    ├── API_REFERENCE.md              # API 参考
    ├── evolution-engine-guide.md     # 进化引擎使用指南
    └── TROUBLESHOOTING.md            # 常见问题与踩坑经验