dsh-assistant-stream
把 DeepSeek Harness 的流式输出导出成 NDJSON。
为网关、桌面端与调试工具提供可实时消费的 assistant 流。
简体中文 · English
> [!NOTE]
> 这是一个 DSH bundle。`dsh plugin add` 即可安装，插件行由随包的 `cordis.patch.yml` 注入，无需手写 profile 配置。
## 为什么做这个插件
DeepSeek Harness 的 assistant 输出是事件流：文本与推理增量、块结束、消息提交、轮次边界、工具调用围栏。宿主内部可以直接订阅，但外部进程（网关、Web 前端、录制工具）拿不到稳定的消费格式。
这个插件把这条事件流翻译成一行一个 JSON 的 NDJSON，写到你指定的 sink。外部进程只需要按行读取，就能实时重建一次回答的完整过程，并保证提交顺序与围栏顺序一致。
```mermaid
flowchart LR
A[DSH session] --> B[agent/assistant-stream 事件]
B --> C[dsh-assistant-stream]
C --> D[NDJSON sink]
D --> E[网关预览]
D --> F[Web 前端]
D --> G[录制与回放]
```
## 核心能力
| 能力 | 使用体验 |
| --- | --- |
| 统一帧格式 | 每行一个 JSON 对象，固定前缀 `ASSISTANT_STREAM_V1 `，便于逐行切分 |
| 完整时序 | `start`、`delta`、`block`、`commit`、`end` 覆盖一次尝试的完整生命周期 |
| 轮次边界 | `turn-start` / `turn-end` 由会话事件驱动，外部可以按轮次聚合 |
| 顺序围栏 | 工具调用、工具结果与用量提交各有一个递增 fence，便于对齐 |
| 子代理隔离 | 子会话（`parentSession` 或 `origin: subagent`）不会写入 sink |
| 自定义输出 | 默认写 stderr，也可以通过 `write` 交给内存、文件或 socket |
## 帧类型
| `op` | 含义 |
| --- | --- |
| `turn-start` / `turn-end` | 轮次开始与结束，仅导出根会话 |
| `start` | 一次模型尝试开始，`seq` 归零 |
| `delta` | `text` 或 `reasoning` 的增量文本 |
| `block` | 一个文本或推理块结束 |
| `commit` | 本次尝试提交的 assistant 消息 |
| `event-fence` | 工具调用、工具结果、用量提交的顺序标记 |
| `end` | 本次尝试结束，携带 `outcome` |
## 安装
从 npm 安装：
```sh
dsh plugin --profile