A2A 任务派发桥 hsiu1214/a2a-dsh-dispatch

a2a-dsh-dispatch

用 A2A 协议（Google Agent2Agent，JSON-RPC 2.0 over HTTP）把本机的 DeepSeek Harness (dsh) 包成一个可寻址的 remote agent，让任何 A2A client 都能「派任务给 dsh、收回结果」。

dsh 本身不是 A2A server；这个项目加一层薄桥接：server.py 收 A2A 请求 → 调用本机 dsh headless → 把 dsh 的输出包成 A2A artifact 返回。

[A2A client] --HTTP JSON-RPC--> [server.py] --headless--> [dsh] --> DeepSeek API
client.py 或 (本桥接) (本机) 结果包成任意 A2A agent artifact 返回

功能

- A2A 标准三件套：Agent Card（/.well-known/agent.json）、tasks/send、tasks/get。
- 异步派发：tasks/send 立刻回 submitted，dsh 在后台执行，长任务不会卡住 HTTP。
- SSE 串流：tasks/sendSubscribe 一边推送任务状态直到完成（client 用 --stream）。
- 结构化 envelope：支持 from/to/action/payload/reply_to/timeout_ms 消息格式，内置 translate/code/chat/general 动作路由。
- 生产化：任务状态落地 .a2a_tasks.json（重启可恢复）、失败自动重试、超时控制。
- 零依赖：纯 Python 标准库，无需 pip 安装任何包。

需求

- Python 3.8+（仅用标准库）
- Node.js（用来跑 dsh 的 lib/bin.js）
- 本机已安装 DeepSeek Harness (dsh) 并完成登录（key 由 dsh 自读 ~/.dsh/.credentials.yaml，不需要另外设 DEEPSEEK_API_KEY）

安装（作为 WorkBuddy / CodeBuddy skill）

把整个文件夹放到 skill 目录：

WorkBuddy
cp -r a2a-dsh-dispatch ~/.workbuddy/skills/
CodeBuddy
cp -r a2a-dsh-dispatch ~/.codebuddy/skills/

之后对 agent 说「派任务给 dsh：…」即会触发。

使用

启动服务端

cd scripts
python server.py # 监听 0.0.0.0:8080

Windows 也可编辑 scripts/start_server.bat 后双击执行。

健康检查（零成本、不连模型）：

curl http://127.0.0.1:8080/health
→ dsh_reachable / dsh_version / credentials_ok

派任务（另一个终端）

纯文本任务（异步轮询）
python client.py "把 hello world 翻成繁体中文"

SSE 串流（长任务实时看进度）
python client.py --stream "写一支读取 CSV 的 Python 脚本"

结构化 envelope
python client.py --envelope-file env.json
或
python client.py --stream --envelope-file env.json

envelope 格式

{
"task_id": "uuid-1",
"from": "my-agent",
"to": "dsh",
"action": "translate",
"payload": { "text": "good night", "target_lang": "zh-TW" },
"reply_to": "my-agent.callback",
"timeout_ms": 60000
}

内置 action：translate（text+target_lang）、code（language+task）、chat/general（text）；未知 action 走通用提示。

让其他电脑的 agent 使用

server.py 绑定 0.0.0.0，同一局域网的其他 agent 可把 client 指向 http://<这台电脑IP>:8080 直接调用（A2A 标准 client 亦可）。详见 references/dsh-notes.md 与下方安全警告。

配置（环境变量）

| 变量 | 默认 | 说明 |
| DSH_BIN_JS | — | dsh CLI 入口 lib/bin.js（最稳，node 直接跑，避开 npx 延迟） |
| DSH_BIN | — | 兼容旧用法：dsh / npx / 完整命令 |
| DSH_WORKSPACE | server.py 所在目录 | dsh 的工作目录 |
| DSH_ISOLATE | 0 | 1=每任务用独立子目录 |
| DSH_TIMEOUT | 1800 | 单次任务秒数上限 |
| DSH_RETRIES | 2 | dsh 失败重试次数 |

文件

a2a-dsh-dispatch/
├── SKILL.md # skill 触发条件与操作流程 ├── scripts/ │ ├── server.py # A2A 服务端（桥接 dsh） │ ├── client.py # A2A 客户端（--stream / --envelope-file） │ ├── agent_card.json # A2A v1.0 Agent Card │ └── start_server.bat # Windows 一键启动 └── references/ └── dsh-notes.md # dsh 调用细节、疑难排解、envelope 格式

安全警告（重要）

- server.py 没有任何认证。一旦绑定 0.0.0.0 并对外暴露，任何连得上的人都能派任务、耗用你的 DeepSeek API 额度。
- 对外（局域网以外）使用前，请自行加上 bearer token 认证，并建议通过 HTTPS 反向代理（如 Caddy/nginx）暴露，避免 token 明文传输。
- 本仓库不含任何密钥；dsh 的凭证由 dsh 自管于 ~/.dsh/.credentials.yaml。

授权

MIT