微信消息队列 SteelUnion/dsh-wechat-queue

dsh-wechat-queue

把微信接入 DeepSeek Harness —— 带一个落盘的串行消息队列。

用微信和你的 DSH 智能体对话：发文字、发图、发文件、发视频，它在微信里回你。
一条回完才处理下一条，进程死了重启接着干。

它解决什么

| 问题 | 老插件 | 本插件 |
| 收不到 | listAccounts()[0] 取最旧的僵尸账号 | 登录时清空旧记录，永远只有一个 |
| 中途发 | 每个 assistant/message 都发一段 | 攒到 turn/end，一次发完 |
| 卡死 | runExclusive 无超时 + catch {} 静默 | 三层超时，任何终态都推进队列 |

功能

- 严格串行：一条回完才取下一条，不会在 inbox 里堆成多个 turn
- 落盘队列：JSONL 存盘，进程死了重启接着处理
- 对方正在输入：轮次开始上报，结束收掉；它坏了不影响主流程
- DSH 原生命令转发：/compact、/goal 等进队列执行，与普通消息同序
- 接收图片 / 文件 / 视频：失败不丢文字，只在那条附件上留一句说明
- 发送文件：回复里提到 deliverables/ 下的文件就会发过去
- 附件声明：告诉智能体附件的名字、大小、uid，它不用翻目录猜
- 扫码登录面板：单账号，登录时清空旧记录

安装

dsh plugin --profile desktop add <解压后的目录>

装完完全退出 DSH 再启动，宿主才能发现插件。

首次使用需要在 GUI 插件页扫码登录，或者用环境变量临时登录：

$env:DSH_WECHAT_QUEUE_TOKEN = "<accountId>:<token>"

配置

- id: wechat-queue
config:
enabled: true

会话工作目录。决定微信那边读到的是谁的人格。
cwd: 'C:\path\to\your\workspace'

权限：管「能不能碰文件」 permission: 'danger-full-access'

Agent 预设：管「有没有工具可用」 agentPreset: 'cordis'

deliverTimeoutMs: 600000
turnTimeoutMs: 600000
queueAckText: ''

⚠️ permission 和 agentPreset 是两件事

| 配了什么 | 结果 |
| 只给 permission | 权限全开，但智能体一个工具都没有 |
| 两个都给 | 权限全开 + 工具齐全 |

只给 permission 时，智能体会说「我没有工具，请你手动跑这条命令」，而且它说的是实话。

agentPreset 不要留空串 —— 空串会回落到配置档的默认预设，不一定是你在用的那个。

微信内命令

| 命令 | 作用 |
| /stop | 中止当前这一轮（写标记，不会卡住） |
| /status | 队列状态 |
| /new | 开一段新对话 |
| /help | 帮助，含 DSH 原生命令列表 |

其他 /xxx 如果 DSH 认识，会进队列在轮到时执行。

发文件给微信

把文件放进 <cwd>/deliverables/，然后在回复里提到它。

<你的工作区>/ └─ deliverables/ └─ 报告.pdf ← 放这里,提到就会发

只有 deliverables/ 下的文件才会被自动发送。

不加这个限制的话，模型说「我读了 SOUL.md、USER.md」就会把那些文件也发出去 —— 列举路径不等于要发文件。

数据在哪

| 内容 | 位置 |
| 队列记录 | <DSH_HOME>/wechat-queue/queue-YYYY-MM-DD.jsonl |
| 运行日志 | <DSH_HOME>/wechat-queue/wechat-queue-YYYY-MM-DD.log |
| 轮询游标 | <DSH_HOME>/wechat-queue/cursor.txt |
| 启动错误 | <DSH_HOME>/wechat-queue/startup-error.txt |
| 账号凭证 | .credentials.yaml 的 wechat-queue/account |
排查先看运行日志。 GUI 启动没有终端，console.error 的输出没人看得见。

消息状态

received → queued → delivered → running → replied
├→ failed （带 stage + error） ├→ timeout （带 stage） └→ stopped （被 /stop）

任何终态都会让队列推进到下一条。 这是「永不堵死」的来源。

测试

node test/zz-all.mjs

548 项，18 个套件，0 失败。

覆盖：串行与超时、状态机、JSONL 存储、四种媒体（图片/文件/视频/语音）、文件发送与上传、预设挂载契约、事件竞态、扫码登录。

打包

node pack.mjs # 输出 dist/dsh-wechat-queue-v<version>.zip
node pack.mjs --list # 只列清单

零运行时依赖。 peerDependencies 只声明 @deepseek-ai/cordis， DSH 本体版本要求写在 engines.dsh。

技术要点

为什么不用 ctx.get() 做软探测：它不是软探测，用到的服务必须写进 inject，否则直接抛。

为什么 agentPresets.resolve() 必须 await：它是 async 的。不 await 会拿到一个 Promise， preset?.id 永远是 undefined，于是预设从未挂载 —— 这就是「权限全开但一个工具都没有」的原因。

为什么媒体要「先下载完再入队」：worker 是独立循环，enqueue 一完成它就可能取走交付。
图片几十毫秒赶得上，视频几秒就赶不上 —— 附件会丢掉，而且队列记录看起来一切正常。

这些坑和更多细节都在 NOTES.md。

来源声明

协议层（lib/protocol/）搬自 dsh-channel-wechat v0.2.5（MIT）。
lib/protocol/qrcode.js 是 vendored 的 qrcode-generator 2.0.4（MIT）。

详见 THIRD_PARTY_NOTICES.md。

队列层、worker、桥接层、命令转发、typing 指示器、媒体处理是本插件自己的实现。

许可

MIT。全文见 LICENSE。