atomk-hermes-skills/skills/archived/a2a-inbox-handler/SKILL.md

name, description, version, tags

name	description	version	tags
a2a-inbox-handler	A2A消息自动响应机制 — webhook接收 + inotify实时监听 + cron兜底轮询	1.0	a2a inbox webhook inotify cron

A2A Inbox Handler

HAgent201 自动响应其他Agent通过A2A Gateway发来的消息。

架构

方案一：Gateway /route → 本地 Webhook :8788 → ~/.hermes/a2a/inbox/ → inotify watcher → hermes chat
方案二：cron scanner (5min) 轮询主动拉取 Gateway GET /inbox/{agent_id}/messages → hermes chat → PATCH 标记已读

文件结构

~/.hermes/a2a/
├── webhook_receiver.py   # HTTP服务，POST /a2a/inbox 接收消息
├── inbox_watcher.py      # inotify实时监听，新消息触发hermes chat
├── inbox_scanner.py      # cron兜底，扫描inbox处理漏网消息
├── a2a_handler.sh        # 统一管理脚本 (start/stop/status/test/restart)
├── inbox/                # 待处理消息
├── processed/            # 已处理消息
└── logs/                 # webhook.log, watcher.log, scanner.log

管理

# 启动/停止
~/.hermes/a2a/a2a_handler.sh start
~/.hermes/a2a/a2a_handler.sh stop
~/.hermes/a2a/a2a_handler.sh restart
~/.hermes/a2a/a2a_handler.sh status

# 测试
~/.hermes/a2a/a2a_handler.sh test

# 手动扫描
python3 ~/.hermes/a2a/inbox_scanner.py

开机自启

systemd service: a2a-handler.service (enabled)

Cron兜底

cronjob ID: cf0afc951a01, 每5分钟执行 inbox_scanner.py

端口

• Webhook: 8788 (POST /a2a/inbox, GET /health)

消息格式

Webhook接收的JSON：

{
  "source_agent_id": "custom_xxx",
  "payload": {"message": "...", "action": "chat"}
}

处理后移至 processed/ 目录。

注意

• Gateway 目前没有原生inbox端点，/route是即发即弃
• 如果要实现Gateway → Webhook转发，需在Gateway端配置消息路由
• inbox_watcher依赖 pyinotify（已安装到hermes-agent venv）