agent-comm-hub

Files (114)

• origin.json · .clawhub/
• API_REFERENCE.md
• HERMES-SETUP.md
• README.md
• SKILL.md
• _meta.json
• agent-client.d.ts · client-sdk/
• agent-client.js · client-sdk/
• agent-client.ts · client-sdk/
• hermes-integration.d.ts · client-sdk/
• hermes-integration.js · client-sdk/
• hermes-integration.ts · client-sdk/
• hub_client.py · client-sdk/
• workbuddy-integration.d.ts · client-sdk/
• workbuddy-integration.js · client-sdk/
• workbuddy-integration.ts · client-sdk/
• docker-compose.yml · deploy/
• dashboard.json · deploy/grafana/
• dashboards.yml · deploy/grafana/provisioning/dashboards/
• prometheus.yml · deploy/grafana/provisioning/datasources/
• prometheus.yml · deploy/
• advanced-orchestration-guide.md · docs/
• evolution-engine-guide.md · docs/
• hermes-integration-guide.md · docs/
• package-lock.json
• package.json
• hub_task_runner.py · scripts/
• hub_watcher.py · scripts/
• install.sh · scripts/
• migrate_evolution_db.py · scripts/
• migrate_from_agent.js · scripts/
• wb_task_trigger.py · scripts/
• db.d.ts · src/
• db.js · src/
• db.ts · src/
• dedup.d.ts · src/
• dedup.js · src/
• dedup.ts · src/
• errors.ts · src/
• evolution.d.ts · src/
• evolution.js · src/
• evolution.ts · src/
• identity.d.ts · src/
• identity.js · src/
• identity.ts · src/
• logger.d.ts · src/
• logger.js · src/
• logger.ts · src/
• memory.d.ts · src/
• memory.js · src/
• memory.ts · src/
• metrics.d.ts · src/
• metrics.js · src/
• metrics.ts · src/
• orchestrator.d.ts · src/
• orchestrator.js · src/
• orchestrator.ts · src/
• interfaces.d.ts · src/repo/
• interfaces.js · src/repo/
• interfaces.ts · src/repo/
• …and 54 more

SKILL.md (first lines)

# Agent Communication Hub

> 多智能体实时通信与任务调度基础设施 — **v2.4.2**

让两个或多个独立 AI 智能体之间实现**实时双向通信**、**任务自动调度**、**记忆共享**和**策略进化**。基于 MCP 协议 + SSE 推送，消息零丢失，延迟 < 50ms。

## 架构概览

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

**三层协议**：

| 层 | 协议 | 用途 | 延迟 |
|----|------|------|------|
| MCP 工具层 | stdio / HTTP POST + JSON-RPC | 结构化操作（发消息、分配任务、查状态） | <50ms |
| SSE 推送层 | Server-Sent Events | 实时事件通知（新消息、新任务、策略审批） | <50ms |
| REST API 层 | HTTP GET/PATCH | 轻量查询（运维监控、自动化脚本） | <50ms |

## 核心能力

### 53 个 MCP 工具（v2.4.2）

#### Identity 身份 (6)

| 工具 | 功能 |
|------|------|
| `register_agent` | 注册新 Agent，获取 agent_id 和 API token（public，无需认证） |
| `heartbeat` | Agent 心跳上报，维持在线状态，每 3 次连续心跳 trust_score +1 |
| `query_agents` | 查询 Agent 列表，支持状态/角色筛选 |
| `revoke_token` | 吊销指定 Agent 的 API token（admin） |
| `set_trust_score` | 调整 Agent 信任分数（admin） |
| `get_online_agents` | 获取当前在线 Agent 列表 |

#### Message 消息 (5)

| 工具 | 功能 |
|------|------|
| `send_message` | Agent 间点对点消息，支持 Markdown，自动去重（sha256） |
| `broadcast_message` | 群发消息给多个 Agent |
| `acknowledge_message` | 确认已读消息，防止重复出现 |
| `search_messages` | 全文搜索消息历史 |
| `batch_acknowledge_messages` | 批量确认消息（1-500 条/次），用于清理消息积压 |

#### File 文件 (3)

| 工具 | 功能 |
|------|------|
| `upload_file` | 上传文件附件（Base64，10MB 限制），关联到消息 |
| `download_file` | 下载附件，返回 Base64 编码内容 |
| `list_attachments` | 列出附件，支持按消息/Agent 筛选 |

#### Task 任务 (3)

| 工具 | 功能 |
|------|------|
| `assign_task` | 创建并分配任务，支持上下文传递 |
| `update_task_status` | 更新任务状态（inbox→assigned→in_progress→completed/failed） |
| `get_task_status` | 查询任务详情，含依赖、Pipeline、Handoff 信息 |

#### Memory 记忆 (5)

| 工具 | 功能 |
|------|------|
| `store_memory` | 存储记忆，支持 private/team/global 可见范围 |
| `recall_memory` | 语义搜索记忆 |
| `list_memories` | 列出记忆，支持范围和标签筛选 |
| `delete_memory` | 删除记忆 |
| `search_memories` | FTS5 全文搜索记忆，支持多关键词和短语搜索 |

#### Evolution 进化 (12)

| 工具 | 功能 |
|------|------|
| `share_experience` | 分享经验（无需审批，直接发布） |
| `propose_strategy` | 提议策略（需 admin 审批） |
| `propose_strategy_tiered` | 提议策略（4 级自动分级审批：auto/peer/admin/super） |
| `list_strategies` | 列出策略，支持标签和类型筛选 |
| `search_strategies` | 全文搜索策略内容 |
| `apply_strategy` | 采纳策略，自动创建 feedback 占位，7 天无反馈自动降分 |
| `feedback_strategy` | 为已采纳策略提供反馈（positive/negative/neutral） |
| `approve_strategy` | 审批通过策略（admin） |
| `get_evolution_status` | 查看进化状态仪表盘 |
| `score_applied_strategies` | 自动评分已采纳策略：7 天前 neutral 反馈自动降为 negative（admin） |
| `check_veto_window` | 检查策略否决窗口状态 |
| `veto_strategy` | 在窗口期内撤回策略（admin） |

#### Orchestration 进阶编排 (16)

| 工具 | 功能 |
|------|------|
| `add_dependency` | 添加任务依赖关系（DFS 环检测） |
| `remove_dependency` | 删除任务依赖关系 |
| `get_task_dependencies` | 查询任务上下游依赖 |
| `create_parallel_group` | 创建并行任务组（2-10 个任务） |
| `request_handoff` | 请求任务交接 |
| `accept_handoff` | 接受任务交接 |
| `reject_handoff` | 拒绝任务交接（含理由） |
| `add_quality_gate` | 在 Pipeline 中添加质量门 |
| `evaluate_quality_gate` | 评估质量门（passed/failed） |
| `set_agent_role` | 任命/撤销 Agent 角色，含 group_admin（admin） |
| `recalculate_trust_scores` | 手动触发信任分重算（admin） |
| `create_pipeline` | 创建 Pipeline 流水线 |
| `get_pipeline` | 查询 Pipeline 详情 |
| `list_pipelines` | 列出 Pipeline |
| `add_task_to_pipeline` | 向 Pipeline 添加任务 |

#### Security 运维安全 (4)

From LeoYeAI/openclaw-master-skills, MIT.

More from LeoYeAI/openclaw-master-skills