JianFeeeee
b4a8f74ae5
现象：dsh 的邮件通道全断。老会话读不出来 ⇒ 桥报 SessionQueryError ⇒ 按"不在磁盘"
处理 ⇒ 再 create 撞 `already exists`。修好读路径之后又立刻暴露下一层
`message "undefined" is already pending`。
根因一（历史数据，dsh 侧）：v0 会话的 `agent/inbox/spliced.inserted[]` 缺 `id`/`role`，
v0→v1 迁移第一步就拒绝。40 个真 mail-* 会话全部命中。
根因二（**仍在写**，本仓侧）：`plugins/dsh-mail-bridge/lib/message.js` 的
`userMessage()` 只产出 `{content, source}`。DSH 0.1.5 的 inbox 按 `message.id` 去重
（`dsh-agent-loop` 的投影 apply() 与 mutate() 各维护一个 Set），id 全是 undefined
⇒ **第二条消息必挂**。日志里最早的同类记录在 2026-09-07，累计 50+ 次。
官方形状在 `@deepseek-ai/dsh-llm` 的 `createMessage()`（{id, role, content, source}），
同一份 dsh 里其它插件都用官方的 createUserMessage()，只有这个桥手搓。
以前没炸是因为读路径先坏，根本走不到 followup。
本次改动
- message.js/.d.ts: userMessage() 补 id: randomUUID() 与 role:'user'
- test/message.test.mjs: 钉住「id 非空」「两条消息 id 必须不同」，用官方 inbox
去重逻辑逐字复刻验证（修复前 message "undefined" is already pending，修复后 20 封全唯一）
- scripts/: repair-legacy-spliced-ids.mjs（v0，默认 dry-run）、
repair-v3-usermessage-ids.mjs（v3）、verify-mail-sessions-readable.mjs
（走生产真读路径 JsonlSessionPersistence.open，而非解码器口径）、两个 apply driver
- docs/DSH-0.1.5-MAIL-CHANNEL-ROOTCAUSE.md: 补执行结果与两处新事实
执行与验收（详见文档 §9-§15）
- v0 修 40 个、v3 修 2 个；逐文件解压后与备份 `cmp` **逐字节相等**，事件数 40/40 一致，
零丢失（25.2MB→12.5MB 是单帧改 500 行/帧的重压缩，不是丢数据）
- 真 mail-* 会话最终 **41/41 可读**
- journal 里同一会话从 `already exists` 变为 `resume 续谈`，且持续增长
（22647→22685 事件），最新 user/message 带真实 UUID；修复上线后 already pending 计数为 0
- 已在生产部署（deploy/redeploy-plugin.sh dsh，快照+原子软链+重启+后置验证全绿）
两个必须记住的坑
1. **校验与落盘不能共用同一批对象**：createRestore().decodeRow() 会原地改写入参
（补全 dt 数组），污染后写出去会报 `released Session row N has seq gap`。
这曾让 dry-run 说"40 个可修"、apply 只说"3 个"。
2. **判定磁盘健康只认 open()**：readSession() 走 SessionCorpus.load，命中有 live 会话时
直接返回内存快照、不校验磁盘；open() 才走 validateStoredEvents。两条路径结论相反
是设计使然，不是矛盾。
114 lines
4.5 KiB
JavaScript
114 lines
4.5 KiB
JavaScript
/**
|
||
* DSH 消息与会话日志的纯函数工具。
|
||
*
|
||
* 单独放一个模块是为了能被单测覆盖 —— 其中 userMessage() 的形状曾让整个插件
|
||
* 卡了一下午（见该函数注释），这种「错了不报错、只在深处炸一个无关的类型错误」
|
||
* 的约定必须被测试钉住。
|
||
*/
|
||
|
||
import { randomUUID } from 'node:crypto';
|
||
|
||
/**
|
||
* 构造 DSH 的 UserMessage。
|
||
*
|
||
* **这是 followup()/steer() 唯一接受的形状。** DSH 的 `agent.followup(message)`
|
||
* 要的是完整的 UserMessage（`content` + `source`），不是 opencode 那种 parts 数组。
|
||
* 传数组进去不会当场报错：agent-loop 会一路走到 preStep 里读 `message.source.kind`，
|
||
* 然后抛 `Cannot read properties of undefined (reading 'kind')` —— 错误信息落在
|
||
* agent-loop 内部，完全不指向调用点。
|
||
*
|
||
* ## 为什么必须带 `id` 和 `role`（2026-09-19 补）
|
||
*
|
||
* DSH 0.1.5 的 inbox 把「待处理消息」按 `message.id` 去重：
|
||
* `dsh-agent-loop/lib/index.js` 的投影（splice apply）与 `mutate()` 各维护一个
|
||
* `Set`，一旦 `ids.has(message.id)` 就抛 `message "${message.id}" is already pending`。
|
||
* 而这里原先**不产出 id**，于是每条消息的 `message.id` 都是 `undefined`：
|
||
*
|
||
* - 第二条消息进 inbox 时，`Set` 里已经有 `undefined` ⇒ 抛
|
||
* `message "undefined" is already pending`；
|
||
* - 该错误由投影抛出，会话日志的 replay 也随之失败。
|
||
*
|
||
* 症状因此是「第一条能处理、第二条起全挂」，且错误信息里的 `undefined` 不指向
|
||
* 调用点。日志里最早的同类记录在 2026-09-07，累计 50+ 次。
|
||
*
|
||
* 官方形状由 `@deepseek-ai/dsh-llm` 的 `createMessage()` 给出：
|
||
* `{ id: brandString(randomUUID()), role, content, source }`。这里不能直接 import
|
||
* 它（plugins 不解析 dsh 内部包），所以按同一形状本地实现。
|
||
*
|
||
* `role` 同样是必需的：`assertMessageEventShape()`（dsh-session）会校验
|
||
* `user/message` 的 `role === 'user'`，缺了就报 `message must have role "user"`。
|
||
*
|
||
* @param {string} text 正文
|
||
* @returns {{id: string, role: 'user', content: {type: 'text', text: string}[], source: {kind: 'user'}}}
|
||
*/
|
||
export function userMessage(text) {
|
||
return {
|
||
id: randomUUID(),
|
||
role: 'user',
|
||
content: [{ type: 'text', text: String(text) }],
|
||
source: { kind: 'user' },
|
||
};
|
||
}
|
||
|
||
/** 去掉已有的 Re: 前缀，避免 Re: Re: Re: 无限叠加。 */
|
||
export function stripRe(subject) {
|
||
return String(subject ?? '').replace(/^(\s*Re:\s*)+/i, '');
|
||
}
|
||
|
||
/**
|
||
* 回信主题：原主题前加一个 Re:，空主题给一个兜底。
|
||
* @param {string} subject 来信主题
|
||
* @param {string} fallback 主题为空时用的标题
|
||
*/
|
||
export function replySubject(subject, fallback = 'DSH 回复') {
|
||
const base = stripRe(subject).trim();
|
||
return base ? `Re: ${base}` : fallback;
|
||
}
|
||
|
||
/**
|
||
* 从会话事件日志里取最后一条 assistant 消息的可见文本。
|
||
*
|
||
* 只取 `type === 'text'` 的块：reasoning 块是模型的思考过程，不该出现在邮件里。
|
||
*
|
||
* @param {readonly any[]} events session.events
|
||
* @returns {string} 文本，找不到时为空串
|
||
*/
|
||
export function lastAssistantText(events) {
|
||
const list = Array.isArray(events) ? events : [];
|
||
for (let i = list.length - 1; i >= 0; i--) {
|
||
const ev = list[i];
|
||
if (ev?.type !== 'assistant/message') continue;
|
||
const blocks = ev.data?.message?.content;
|
||
if (!Array.isArray(blocks)) return '';
|
||
return blocks
|
||
.filter((b) => b?.type === 'text' && typeof b.text === 'string')
|
||
.map((b) => b.text)
|
||
.join('\n')
|
||
.trim();
|
||
}
|
||
return '';
|
||
}
|
||
|
||
/**
|
||
* 从会话事件日志里取最后一次 session/title 的标题。
|
||
*
|
||
* DSH 首轮结束后由模型生成摘要标题，之前是 `source.kind === 'fallback'` 的占位
|
||
* （内容就是用户第一句话的截断）。占位标题不值得回写给 AgentMail，会把
|
||
* 「你收到一封新邮件（AgentMail）」这种插件自己的提示词当成会话标题。
|
||
*
|
||
* @param {readonly any[]} events session.events
|
||
* @returns {string} 模型生成的标题，没有则空串
|
||
*/
|
||
export function modelTitle(events) {
|
||
const list = Array.isArray(events) ? events : [];
|
||
for (let i = list.length - 1; i >= 0; i--) {
|
||
const ev = list[i];
|
||
if (ev?.type !== 'session/title') continue;
|
||
const kind = ev.data?.source?.kind;
|
||
if (kind === 'fallback') return '';
|
||
const title = ev.data?.title;
|
||
return typeof title === 'string' ? title.trim() : '';
|
||
}
|
||
return '';
|
||
}
|