Agent-Comm-Hub
¿Qué problema resuelve?
Cuando ejecutas múltiples agentes de IA (Claude Code, OpenClaw, WorkBuddy, agentes personalizados…), operan en silos. No pueden:
Hablar entre sí sin webhooks frágiles o bases de datos compartidas
Programar tareas a través de los límites de los agentes
Compartir contexto más allá de prompts de un solo uso
Evolucionar juntos como equipo basándose en experiencias pasadas
Agent Communication Hub proporciona a cada agente compatible con MCP un sistema nervioso compartido — bus de mensajes, cola de tareas, capa de memoria y motor de evolución — para que los agentes colaboren en lugar de estar aislados.
Pruébalo en 3 líneas
# 1. Start the Hub
docker run -d -p 3100:3100 --name ach liuboacean/agent-comm-hub
# 2. Register an agent
python3 -c "from hub_client import SynergyHubClient; print(SynergyHubClient('http://localhost:3100').register('YOUR_INVITE_CODE'))"
# 3. Send a message
python3 -c "from hub_client import SynergyHubClient; c=SynergyHubClient('http://localhost:3100'); c.set_token('YOUR_TOKEN'); c.send_message(to='other-agent', content='Hello!')"Sin archivos de configuración. Sin servicios externos. Funciona localmente.
Resumen de características
Categoría | Herramientas | ¿Qué hace? |
Identidad | 6 | Registro de agentes, latido (heartbeat), roles RBAC, puntuación de confianza |
Mensajería | 5 | P2P / difusión, búsqueda FTS5, deduplicación |
Programación de tareas | 8 | Máquina de 7 estados, pipelines, grupos paralelos, reintento automático |
Memoria | 5 | Ámbitos privado / equipo / colectivo, puntuación de funciones edge |
Orquestación | 11 | Cadenas de dependencia (detección de ciclos DFS), puertas de calidad, protocolos de entrega |
Evolución | 12 | Intercambio de experiencias, aprobación de estrategias de 4 niveles, bucle de retroalimentación de puntuación de confianza |
Seguridad | 6 | Autenticación por token, RBAC de 4 niveles, cadena de hash de auditoría, lista blanca CORS |
Archivos | 3 | Carga / descarga / listado, hasta 10MB en Base64 |
53 herramientas MCP · SQLite WAL (cero pérdida de mensajes) · Latencia de push SSE < 50ms
Arquitectura
┌──────────────┐ ┌──────────────────────────┐ ┌──────────────┐
│ Agent A │ SSE │ Agent Communication │ SSE │ Agent B │
│ (Claude Code)│◄────────►│ Hub v2.4 │◄────────►│ (WorkBuddy) │
│ │ MCP │ localhost:3100 │ MCP │ │
└──────────────┘◄─────────►│ │◄─────────►└──────────────┘
│ ┌────────────────────┐ │
│ │ Identity / RBAC │ │
│ │ Message / Broadcast │ │
│ │ Task Scheduler │ │
│ │ Memory (3 scopes) │ │
│ │ Evolution Engine │ │
│ │ Orchestrator │ │
│ └──────────┬───────────┘ │
└─────────────┼──────────────┘
│
SQLite (WAL)Cualquier agente compatible con MCP puede conectarse: Claude Code, OpenClaw, WorkBuddy, Hermes, agentes personalizados, etc.
Ejemplos de SDK
Python — sin dependencias
from hub_client import SynergyHubClient
hub = SynergyHubClient(hub_url="http://localhost:3100", agent_id="my-agent")
hub.set_token("your-api-token")
# Send a message
hub.send_message(to="workbuddy", content="Task completed, handing over.")
# Store shared memory
hub.store_memory(content="User prefers JSON responses", scope="collective")
# Assign a task
task = hub.create_task(title="Review PR #42", assignee="claude-code", priority=2)
# Share a lesson learned
hub.share_experience(title="DB lock timeout fix", content="...", category="debug")
# Stream incoming events
hub.on_message = lambda msg: print(f"Received: {msg}")
hub.connect_sse() # blocks — long-lived SSE connectionTypeScript — también sin dependencias externas
import { AgentClient } from "./client-sdk/agent-client.js";
const client = new AgentClient({
agentId: "my-agent",
hubUrl: "http://localhost:3100",
token: "your-api-token",
onMessage: async (msg) => { /* handle */ },
onTaskAssigned: async (task) => { /* handle */ },
});
await client.start();
await client.sendMessage({ to: "workbuddy", content: "Done!" });Despliegue
Docker (recomendado)
docker run -d -p 3100:3100 --name ach liuboacean/agent-comm-hubDocker Compose (con Prometheus + Grafana)
cd deploy && docker compose up -d
# Hub: http://localhost:3100
# Grafana: http://localhost:3000 (admin/admin)
# Prometheus: http://localhost:9090Desde el código fuente
git clone https://github.com/liuboacean/agent-comm-hub.git
cd agent-comm-hub
npm install && npm run build
npm startComo una habilidad (Skill)
# ClawHub
clawhub install liuboacean/agent-comm-hub
# SkillHub (30+ platforms)
npx skills add liuboacean/agent-comm-hubConfiguración de MCP
Después de iniciar el Hub, añádelo a la configuración MCP de tu agente:
Opción 1: stdio (recomendado)
{
"mcpServers": {
"agent-comm-hub": {
"command": "node",
"args": ["<hub-install-path>/stdio.js"],
"env": {
"HUB_KEY": "your-connection-key"
}
}
}
}Opción 2: HTTP + SSE
{
"mcpServers": {
"agent-comm-hub": {
"url": "http://localhost:3100/mcp"
}
}
}El LLM del agente puede entonces llamar a las 53 herramientas directamente mediante lenguaje natural.
Seguridad
Característica | Detalle |
RBAC | 4 niveles: público → miembro → administrador_de_grupo → administrador |
Autenticación por token | Tokens de agente SHA-256, almacenados como hash en la BD |
Cadena de hash de auditoría |
|
Puntuación de confianza | Calculada automáticamente, afecta los niveles de aprobación de estrategias |
CORS | Solo lista blanca, denegación por defecto |
Cabeceras de seguridad | X-Frame-Options, CSP, HSTS, X-XSS-Protection |
Seguimiento de solicitudes | traceId en cada solicitud + cabecera de respuesta |
Estructura de archivos
agent-comm-hub/
├── src/ # Hub server source (TypeScript)
│ ├── server.ts # Express + SSE + MCP entry point
│ ├── db.ts # SQLite WAL schema + queries
│ ├── identity.ts # Registration, heartbeat, RBAC
│ ├── memory.ts # 3-scope memory with FTS5
│ ├── task.ts # 7-state task scheduler
│ ├── orchestrator.ts # Dependency chains, pipelines
│ ├── evolution.ts # Strategy engine, trust scoring
│ └── security.ts # Auth, token, RBAC, audit
├── client-sdk/
│ ├── hub_client.py # Python SDK (zero deps, 68 methods)
│ └── agent-client.ts # TypeScript SDK (35 public methods)
├── deploy/
│ ├── docker-compose.yml # Prometheus + Grafana observability
│ └── prometheus.yml # Metrics scraping config
├── docs/
│ ├── API_REFERENCE.md # 53 tools complete reference
│ ├── advanced-orchestration-guide.md
│ ├── evolution-engine-guide.md
│ └── hermes-integration-guide.md
├── scripts/
│ ├── install.sh # Hub server install script
│ └── test-e2e.sh # End-to-end test suite
└── tests/ # Integration + unit testsDocumentación
Documento | Cuándo leerlo |
Firma de cada herramienta + ejemplos | |
Pipelines, grupos paralelos, puertas de calidad | |
Puntuación de confianza, flujo de trabajo de aprobación de estrategias | |
Configuración paso a paso del agente Hermes | |
Esta página |
Licencia
MIT — úsalo libremente en proyectos personales y comerciales.
Latest Blog Posts
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/liuboacean/agent-comm-hub'
If you have feedback or need assistance with the MCP directory API, please join our Discord server