@ryubyte/dsh-a2a

dsh plugin --profile web add @ryubyte/dsh-a2a

dsh-a2a

[English](./README.en.md) | 中文文档

一个 DeepSeek Harness (DSH) 插件，实现 Agent2Agent (A2A) 协议 v1.0（Linux 基金会，a2aproject/A2A，Apache-2.0）。

让一个 DSH 实例成为完整的 A2A 双端节点：

• Client 模式（出站）——通过远程 Agent 的 AgentCard 发现它，把每个 skill 映射为 DSH 模型工具（a2a__<name>__<skill>），通过 A2A JSON-RPC 执行远程任务。
• Server 模式（入站）——把本 DSH 暴露给其他 Agent：在 DSH webserver 上提供 /.well-known/agent-card.json 与 JSON-RPC 端点（SendMessage、GetTask、ListTasks、CancelTask、基于 SSE 的 SendStreamingMessage）。

兼容 DSH 0.1.7-rc.2、0.2.0-rc.1～2、0.2.1-alpha.1～5 与 0.2.1-rc.1～5，共 13 个版本；CI 和发布流程逐版本验证。[兼容性说明](docs/dsh-compat.md)。

安装

一行命令装进 profile，重启即生效：

dsh plugin --profile web add @ryubyte/dsh-a2a

dsh --profile web

dsh plugin 会把包装进 profile 并自动加入插件层（本包在 package.json 里声明了 dsh.bundle.patch），无需手动改任何配置。

截图

连接的 Agent（本 DSH 作为客户端） · 对外服务（本 DSH 作为 Agent）

 · 

功能

协议能力（A2A v1.0）

• 发现：GET /.well-known/agent-card.json（优先 well-known，配置的 URL 兜底）
• 单次调用：SendMessage、GetTask、ListTasks、CancelTask、GetExtendedAgentCard
• 流式：SendStreamingMessage（SSE）/ SubscribeToTask，含 TaskStatusUpdateEvent + TaskArtifactUpdateEvent
• 任务生命周期：SUBMITTED → WORKING → COMPLETED / FAILED / CANCELED / REJECTED / INPUT_REQUIRED / AUTH_REQUIRED
• 鉴权：出站按 Agent 配置 Bearer Token（Authorization: Bearer …）；入站可选共享 Bearer Token 保护端点——配置后 AgentCard 声明 bearerAuth 安全方案，未带/错误 token 的请求返回 401（单次调用与 SSE 流均生效）
• 类型：Task、Message、Part（text/raw/url/data）、Artifact、AgentCard、安全方案、扩展

连接面板（设置 → A2A 连接）

面板按角色分为两个 tab，全部配置都可在 UI 里完成，无需手改 a2a.json：

「连接的 Agent」（本 DSH 作为客户端，出站）

• 列出已连接的远程 Agent（名称、连接状态、AgentCard URL、技能/工具数、最近活动），展开可看每个 skill 的名称/标签/描述；每个 Agent 支持 重连 / 设置 / 禁用 / 删除（已禁用的 Agent 显示为灰化占位卡，操作按钮变为 启用）。
• 设置：就地编辑该 Agent 的 超时（timeoutMs）、技能拆分（mapSkills）、Bearer Token，保存后自动以新配置重连生效。
• 添加 Agent：填 AgentCard URL（可选 Bearer Token）→「导入」预览远端名称/描述/技能 →「连接」。配置写回 a2a.json。

「对外服务」（本 DSH 作为 Agent 对外，入站）

• 服务身份可视化编辑：只读展示服务名/描述/版本、端点、Agent Card URL（一键复制）与 Skills；点「编辑」就地改这些字段并完整增删改 Skills，保存即时重建 AgentCard 生效（无需重启）。
• 引导式初始化：全新安装（无 a2a.json）时，本页显示预填好合理默认值的表单，用户按需修改后点「创建并上线」即可发布服务——一步生成 a2a.json 并启动。
• 上线 / 下线 开关；显示 入站任务由谁执行（自定义 executor / 本 DSH agent 会话 / 未配置）。
• 入站鉴权：设置或清除保护入站端点的共享 Bearer Token（持久化到 a2a.json，实时生效）。
• 入站连接：谁在调用本 DSH（来源、地址、首/末次连接、任务数、流式标记），支持关闭。
• 面板每 3 秒自动刷新；/a2a/api 提供 JSON 快照与控制接口，受 loopback/same-origin 保护（token 值不会通过快照回传，只暴露「是否已配置」）。

运行时配置（a2a.json）

配置以 a2a.json（按 profile 存放，可完全通过 UI 管理）为准，无需改动组合配置即可管理 Agent 与对外服务。文件定位不依赖启动目录：插件解析进程命令行里的 --profile <name>（dsh web 别名同样识别为 web profile），读写 ~/.dsh/profiles/<name>/a2a.json——UI 首次生成的配置也会写到该 profile 目录，从任意工作目录启动都能读到。手写 a2a.json 仍然支持（见下文），但新用户完全靠 UI 即可完成配置与上线。

使用

1. 配置远程 Agent（出站）

在 profile 目录下的 a2a.json 里声明要连接的 Agent：

{
  "agents": [
    {
      "name": "research",
      "agentCardUrl": "https://research.example.com/.well-known/agent-card.json",
      // "bearerToken": "...",
      // "timeoutMs": 8000,
      // "mapSkills": true,
      // "enabled": false        // 保留条目，但不自动连接
    }
  ]
}

也可以在 Web GUI「设置 → A2A 连接 →『连接的 Agent』→ 添加 Agent」里输入 AgentCard URL 导入并连接，配置会写回 a2a.json；连接后点该 Agent 的「设置」还能调整超时、技能拆分与 Token。

连接成功后，对方 Agent 的 skills 会作为模型工具出现：a2a__<name>__<skill>。

同一个本地 agent 会话对某远程 Agent 的多次工具调用会复用同一个 A2A contextId，因此在远端落到同一会话、具备跨轮记忆；不同本地会话相互隔离，各自独立对话。

2. 对外提供 A2A 服务（入站）

推荐：直接用 UI。 打开「设置 → A2A 连接 →『对外服务』」，全新安装会显示预填好的表单，改几个字段后点「创建并上线」即可——无需手写下面的 JSON。以下为等价的手写配置，供了解字段或脚本化部署时参考。

也可以在 a2a.json 里手动开启 server 模式：

{
  "mode": "server",
  "server": {
    "enabled": true,             // 显式开启入站服务
    // "baseUrl": 省略即自动推导（见下），仅反向代理/公网域名时才需显式设置
    "agentName": "My DSH Agent",
    "agentDescription": "A DSH agent over A2A v1.0",
    "agentVersion": "0.1.0",
    "skills": [
      { "id": "coding", "name": "Coding", "description": "Execute coding and shell tasks.", "tags": ["coding", "shell"] }
    ]
  }
}

baseUrl 留空（或在 UI 里清空）时，AgentCard 会按 webServer 的真实监听地址自动推导，不会公布过期端口；仅当本 DSH 位于反向代理或公网域名之后、对外地址与本地监听不同时，才需要显式填写。

关于 mode：mode（client / server / both）控制启动时挂载哪一半，缺省为 client。它是可选的——server.enabled: true 或存在 agents 就会分别启用对应半区，所以通过 UI 生成的 a2a.json 通常不写 mode，仅靠这些字段隐式推导行为。手写时显式写 mode 更直观，二者等价。

之后其他 A2A 客户端通过自动推导出的 http://<host>:<port>/.well-known/agent-card.json 发现本 DSH，通过 /a2a 端点调用。

入站任务由谁执行（executor 优先级）

server 模式收到任务后，按以下优先级选择 executor：

1. 显式 execute（通过 composition 配置注入）—— 用你的。

2. 本 DSH 的 agent 会话（默认，当 agent 循环就位时）—— 按 A2A contextId 一个对话一个会话：某 contextId 首个任务 ctx.agents.create() 建会话（后续同 contextId 复用同一会话，历史累积；进程重启后按需 resume），把消息作为 next-turn 唤醒项发给它，等 whenIdle()，取最新 assistant 回复作为 A2A artifact。同一 contextId 的并发任务按序串行，不同 contextId 并行。会话不逐任务释放（否则无法累积上下文），插件卸载/下线时统一释放。开 server 即可「接收并处理任务」，无需写代码。

3. notConfiguredExecutor（兜底）—— 既没注入 execute、composition 里又没有可用 agent 循环（如仅 dsh-base 的最小 profile）时，返回「no executor configured — inject one」，不执行任何命令。

关于「就位」：ctx.agents（registry）存在 ≠ 能创建 agent。create() 需要 agent-loop 插件注册的 factory；缺 factory 时 create() 会 reject，此时 DSH agent executor 会把它作为可读错误返回（而非抛出）。因此最小 profile 仍需显式注入 executor。

会话与工作区：DSH 会话在创建时把 cwd 校验为绝对路径并冻结进会话头。入站会话用专用目录 <profile>/.a2a-sessions 作为 cwd（与 profile 根分开，避免入站会话挤占你的交互会话）。它们出现在会话列表的「未分组」里，并按首条消息摘要命名为 A2A: <摘要>（入站消息带 plugin 来源，DSH 的自动标题只认 human 消息，故显式命名）。命名是装饰性的，失败只记日志、绝不影响任务。

取消：CancelTask 会 abort 正在运行任务的 executor 信号，真正中止 agent 回合（不只是改任务状态）。

本机自测也可显式传入 shellExecutor（把 prompt 当作 shell 命令执行，仅限可信客户端）；生产请置于 TLS 反向代理之后并按需配 authToken。

目录结构

src/

protocol.ts # A2A v1.0 类型与常量

card.ts # AgentCard 发现 / 校验

jsonrpc.ts # JSON-RPC 2.0 + SSE 传输

client.ts # 出站客户端（A2AClient）

server.ts # 入站服务 + TaskStore（A2AServer）

…(truncated)