dsh-a2a

dsh-a2a

English | 中文文档

一个 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）。

功能

协议能力（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 连接）

• 出站 Agent：列出本 DSH 连接的远程 Agent（名称、连接状态、AgentCard URL、技能/工具数、最近活动），每个 Agent 支持 重连 / 启用 / 禁用 / 删除。添加 Agent 时可填 Bearer Token（可选），导入与后续 JSON-RPC 调用都会带上 Authorization: Bearer …，并随 Agent 一起持久化到 a2a.json。
• 入站连接：谁在调用本 DSH（来源、地址、首/末次连接、任务数、流式标记），支持关闭。
• A2A 服务：入站服务的运行状态，上线 / 下线开关，端点与技能一览；并显示 入站任务由谁执行（自定义 executor / 本 DSH agent 会话 / 未配置），以及 入站鉴权 开关——可设置或清除保护入站端点的共享 Bearer Token（持久化到 a2a.json，实时生效）。
• 面板每 3 秒自动刷新；/a2a/api 提供 JSON 快照与控制接口，受 loopback/same-origin 保护（token 值不会通过快照回传，只暴露「是否已配置」）。

运行时配置（a2a.json）

配置以 a2a.json（按 profile 存放，UI 可编辑）为准，无需改动组合配置即可管理 Agent。文件定位不依赖启动目录：插件解析进程命令行里的 --profile <name>，读写 ~/.dsh/profiles/<name>/a2a.json。

截图

出站 Agent（本 DSH 连接了谁）	入站连接（谁在调用本 DSH）

含真实记录的入站	A2A 服务状态面板

安装

方式一：从 npm 安装（推荐）

插件发布到 npm 后，一行命令装进目标 profile，重启即生效：

dsh plugin --profile <profile> add @ryubyte/dsh-a2a
dsh --profile <profile>

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

方式二：从仓库安装（开发调试）

用于改代码调试，需要 Node.js >= 22 与 pnpm：

# 1. 克隆仓库
git clone https://github.com/ryubyte/dsh-a2a.git
cd dsh-a2a

# 2. 安装依赖并构建
npm install
npm run build

# 3. 链接进目标 profile
dsh plugin --profile <profile> add link:$(pwd)

# 4. 重启
dsh --profile <profile>

改完源码后重跑 npm run build 再重启即可。

使用

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」里输入 AgentCard URL 导入并连接，配置会写回 a2a.json。

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

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

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

同样在 a2a.json 里开启 server 模式：

{
  "mode": "server",
  "server": {
    "enabled": true,             // 显式开启入站服务
    // "baseUrl": "http://127.0.0.1:3080",   // 可选；默认从 webServer 监听地址推导
    "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"] }
    ]
  }
}

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

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

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

1. 显式 execute（编程接入时注入）—— 用你的。
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。

3. 编程接入

import { A2AClient, A2AServer, TaskStore } from '@ryubyte/dsh-a2a';

// 出站：连接远程 Agent
const client = await A2AClient.connect('https://agent.example.com');
const { task } = await client.sendMessage({
  messageId: crypto.randomUUID(),
  role: 'ROLE_USER',
  parts: [{ text: 'Draft a report' }],
});
for await (const ev of client.streamMessage({ messageId: crypto.randomUUID(), role: 'ROLE_USER', parts: [{ text: 'hi' }] })) {
  // ev.statusUpdate | ev.artifactUpdate | ev.task | ev.message
}

// 入站：自定义 executor 接入 DSH agent 循环
const store = new TaskStore();
const server = new A2AServer({
  baseUrl: 'http://127.0.0.1:3080',
  agentName: 'My DSH',
  agentDescription: '...',
  agentVersion: '1.0.0',
  execute: async ({ message }) => ({
    messageId: crypto.randomUUID(),
    role: 'ROLE_AGENT',
    parts: [{ text: await myAgentRun(message.parts) }],
  }),
}, store);

目录结构

src/
  protocol.ts        # A2A v1.0 类型与常量
  card.ts            # AgentCard 发现 / 校验
  jsonrpc.ts         # JSON-RPC 2.0 + SSE 传输
  client.ts          # 出站客户端（A2AClient）
  server.ts          # 入站服务 + TaskStore（A2AServer）
  outbound.ts        # skill → 模型工具桥（registerAgentTools）
  dashboard.ts       # 连接注册表 + 控制
  a2a-config.ts      # 运行时 a2a.json 解析 / 持久化
  index.ts           # Cordis 插件入口（client / server 两种模式）
  client/
    index.ts         # 浏览器半区：设置页「A2A 连接」面板
lib/                 # 构建产物（index.js + client.js + types/）
scripts/
  build-client.mjs   # 客户端 bundle 包装（__ModuleLoader__）
  capture-shots.mjs  # README 截图抓取（headless Chrome + CDP）
cordis.patch.yml     # 插件注册行（bundle 自挂载，无需手动配置）
package.json         # dsh.bundle.patch + dsh.client 清单

工作原理

• 插件在 ctx.inject(...) / ctx.effect(...) 内读取 ctx.webServer 与 ctx.tools（原生 Cordis 模式，与 dsh-client-hmr 等 bundle 一致）；缺少任一半的组合只会闲置该半区，不会崩溃。
• server 模式 baseUrl 可选：省略时 AgentCard 公布 webServer 的真实监听地址，临时端口不会发布过期 URL；仅在反向代理前置时才需显式设置。
• 客户端模式的连接生命周期钩子（onReady / onDispose）上报到进程级共享注册表；多个实例（client + server）共用，/a2a/api 每个进程注册一次。
• 所有注册 fiber 作用域化：插件停止 / 更新时由 Cordis 自动清理。
• 禁用（enabled:false）的 Agent 显示为灰化占位卡，不自动连接，直到重新启用。

已知限制

• 面板 API（/a2a/api）只监听 loopback / same-origin，供运维可见性使用，不承载机密。
• 入站服务的执行策略见入站任务由谁执行：有 agent 循环时默认由本 DSH 会话执行（绑定工作目录 cwd），否则（且未注入 executor）拒绝执行并返回「no executor configured」。shellExecutor 仅限本地自测。无论哪种 executor，都切勿向不受信网络暴露 server 模式（默认无鉴权，除非配置 authToken）。
• A2A 规范要求生产 AgentInterface.url 使用 HTTPS；DSH webServer 默认仅绑 loopback，对外暴露前需自行加 TLS。
• Bearer token（出站按 Agent 配置的、入站保护端点的 authToken）均明文存于 a2a.json，请自行保证该文件权限。

开发

npm install
npm run build    # tsc(types) + tsdown(lib) + wrap client → lib/client.js
npm test         # node:test + tsx（单元 / 集成）+ client-bundle smoke