dsh-peak-valley-queue

输入框左侧一个开关：打开后，聊天消息不再直接发送，而是进入任务队列；在谷段（DeepSeek API 低费率时段）自动按序派发执行。 A composer switch: when on, chat input goes into a task queue instead of being sent directly; tasks auto-dispatch in order during valley windows (DeepSeek off-peak pricing).

DeepSeek Harness 双半区插件（Host + Client）：Host 拦截输入入队、按时段调度、精确判定任务完成；Client 提供开关与队列面板（状态行、时段配置、任务列表）。 A DeepSeek Harness plugin (Host + Client halves): the Host intercepts input into a queue, schedules by peak/valley windows and judges completion precisely; the Client provides the switch and the queue panel (status, window config, task list).

功能 / Features

• 一键开关：输入框左侧「峰谷排队」按钮；开启后输入入队，关闭后消息直发。开关带队列数角标。
• 谷段自动执行：队列按序（FIFO，可拖拽改序）派发；距下一峰段超过 x 分钟 才自动执行（余量保护）。
• 峰谷双向倒计时：谷段显示「距下一峰段」，峰段显示「距下一谷段」。
• 可配置峰段列表：默认 DeepSeek 官方规则（工作日 09:00–12:00 / 14:00–18:00 为峰段，其余为谷段）；时段可增删、支持重叠；可设周末是否算峰段、时区（本机 / 固定偏移）；清空列表 = 全天谷段。
• 队列管理：面板直接添加任务；编辑 / 删除 / 拖拽排序 / 合并相邻任务 / 手动「送出」；执行中可「强制完成」兜底。
• 精确完成判定（4 态）：按轮次生命周期区分 已完成后移除 / 被打断（取消、输出截断）/ 失败 / 阻塞；多信号冗余（turn/end + 空闲 + watchdog + 客户端轮询），任一事件漏发都不会卡住队列。
• 待确认任务（dsh-todo 集成）：回复中含 <!-- dsh-todo:start --> 决策清单标记时，任务不判完成，转为「待确认」并暂停队列，等待用户决策（配套安装 dsh-todo-enhancer 提供清单面板）；「继续任务」不会自动重跑待确认任务。
• 失败暂停 + 恢复：失败 / 打断 / 阻塞时队列暂停并提醒（浏览器系统通知 + 可选自定义命令，每 30 分钟重复）；点「继续任务」清暂停并按序重排；暂停期间新输入照常入队，绝不静默丢弃。
• 严格完成校验（可选）：派发时注入完成约定，要求回复末尾输出 __TASK_DONE__；未检测到则视为未完成。
• 多会话独立队列：每个会话（含不同工作区的会话）都有各自的开关与队列，互不干扰、各自持久化（状态文件按会话 id 分文件）。
• 本地持久化：队列与配置写入 DSH 数据目录 ~/.dsh/peak-valley-queue/（$DSH_HOME 优先），绝不写入用户工作区文件（Web 工作区根目录常是桌面）；会话归属锁定 owner.json。

使用场景 / Use cases

• 压低 DeepSeek API 成本：把不紧急、可延后的任务（批量改写、批量摘要、巡检清单、报表生成）攒到谷段统一执行，享受低费率。
• 峰段高峰期自动排队：工作日上午 / 下午高峰时段的输入先入队，谷段一到自动按序执行，无需人工值守。
• 批量任务保持顺序：多轮任务按队列顺序串行执行，避免并发串扰、保证上下文连贯。
• 失败可见、可控重试：任务失败自动暂停并通知，人工确认「继续任务」后才重排，不会无限重跑。
• 长任务安全：没有强制超时 / 强制移除，任务跑多久都可以；空闲兜底只清理「代理已空闲但完成信号未到」的卡死。

不适用场景 / When NOT to use

• 需要立即回复的实时对话：排队会延迟响应（除非手动「送出」）。
• 高峰期的紧急任务：会一直等到谷段才自动执行。
• 强交互式调试：每一步都要立刻看到模型输出再继续的流程，不适合无人值守的队列。
• 依赖实时人工确认的任务：队列在谷段自动派发，没人盯着也会执行。
• 需要消息留在聊天区的场景：消息一旦入队即归队列所有，聊天区不会出现该消息（这是拦截设计的预期行为；若希望消息留在聊天区，请关闭开关）。

安装 / Install

支持从 GitHub 直接安装（公开仓库，需能访问 github.com；公开克隆无需登录，若本机 git 配置要求凭据则按 Git Credential Manager 授权即可）：

dsh plugin --profile web add github:EmptyCollin/dsh-peak-valley-queue github:EmptyCollin/dsh-todo-enhancer

必须一条命令同时安装两个插件：决策清单面板由独立的 dsh-todo-enhancer 提供，而 dsh plugin 只把直接依赖中声明 dsh.bundle 的包加入 bundle 层——只装 pvq 时 todo-enhancer 只会作为传递依赖被拉取、不会挂载，面板不会出现。

• 安装后重启 dsh 服务（bundle 层在启动时加载），并刷新浏览器页面（重新拉取插件清单）。
• 其他 profile 把 web 换成对应 profile 名。
• 离线 / 尚未推送 GitHub 时，用本地路径安装（效果相同）：

  dsh plugin --profile web add D:\dsh-plugin\dsh-peak-valley-queue D:\dsh-plugin\dsh-todo-enhancer

• Host 半区：lib/index.js（注册 /pvq/* HTTP 路由）；Client 半区：lib/client.bundle.js（模块加载器 bundle，产物已提交、无 prepare 脚本，安装无需构建）。
• 代码改动经 link 依赖随重启生效（本地方式）；GitHub 方式更新发布后重新 add 即可。
• 开发期也可用动态方式（cordis_define / cordis_run）加载 lib/dynamic-host-body.txt / lib/dynamic-client-body.txt，无需重启；注意两种方式不要同时启用（会重复拦截）。

快速开始 / Quick start

1. 安装并重启后，输入框左侧出现「峰谷排队」开关；点击开启（面板自动打开）。
2. 正常在输入框发消息——消息不会直接发送，而是进入队列。
3. 谷段（且距下一峰段超过 x 分钟）时队列自动按序执行；峰段则等待。
4. 面板可随时：查看倒计时 / 手动添加任务 / 编辑、删除、拖拽排序、合并 / 手动「送出」/ 点「继续任务」恢复暂停。

配置说明 / Configuration

面板「时段与配置」区：

时段改动若导致「峰段 → 谷段」翻转且队列非空，会弹窗确认（避免误触发批量执行）。

任务状态判定 / Task lifecycle

以轮次生命周期（turn/end reason：completed | aborted | error | max-tokens | blocked + agent/error）精确区分；完成判定为冗余多信号（turn/end 精确原因 + agent/status→idle + turn-stopping + 10s watchdog + 客户端 10s 轮询兜底），任一事件漏发都不会让任务卡在「执行中」。

工作原理 / How it works

• Host：监听 agent/inbox/inserted 拦截用户输入（inbox.remove + 入队），用 agent.followup 以 rpcId: pvq:<taskId> 派发；按消息 id 去重，授权恢复 / 循环重投递的同一条消息只消费、不重复入队。完成信号来自 session/event（turn/end、assistant/message）、agent/status、agent/turn-stopping。
• Client：注册 conversation.input.left（开关）与队列面板（有 sidebar tab 能力则注册页签，否则 shell.overlay 自建浮动侧边板）；1s 轮询 get-state 刷新状态；RPC 走 POST /pvq/<method>（动态形式走 host.call）。
• 面板 / 开关 / 样式全部随插件卸载自动回收。

目录结构 / Structure

cordis.patch.yml      # dsh.bundle 补丁：把本包插入 profile 的 bundle 层
lib/
  index.js            # Host 静态入口（webServer 路由 /pvq/*，导出 { name, inject, apply }）
  client.js           # Client 静态入口（import React + fetch RPC）
  client.bundle.js    # Client bundle（__ModuleLoader__ 自注册，由 client.js 生成，产物已提交）
  host-core.js        # Host 核心（纯 JS，动态/静态共用）
  client-core.js      # Client 核心（纯 JS，动态/静态共用）
  dynamic-host.js / dynamic-host-body.txt   # 动态运行器 Host 函数体（cordis_define 用）
  dynamic-client.js / dynamic-client-body.txt # 动态运行器 Client 函数体
scripts/
  build-dynamic.mjs   # 由 host-core/client-core 重新生成动态体
  build-bundle.mjs    # 由 client-core 生成 lib/client.bundle.js
  compact-dynamic.mjs # 生成去注释 compact 体（cordis_define 传输用）
  smoke-host.mjs      # Host 核心回归（mock ctx/agents，112 项）
  smoke-bundle.mjs    # Client bundle 冒烟（槽位注册 / 侧边板迁移）

开发 / Development

npm run check    # 语法检查（全部入口 node --check）
npm run build    # 重新生成动态体 + client bundle + 冒烟
npm run smoke    # 仅跑冒烟（smoke-bundle + smoke-host）

变更记录 / Changelog

• 重启重放防护（v0.1.1）：修复「重启服务后旧任务被自动发出」与「输入被静默吞掉 / 被当作过期的待确认回答」两类严重问题。
  • 根因一：DSH 的 agent Inbox 会在会话恢复时从持久化的 agent/inbox/spliced 事件重水合遗留的待处理消息——重启前仍在 inbox 里的派发消息（rpcId: pvq:...）会在重启后被 agent 循环当作新输入处理，即使开关是关闭的也会自动发出。现在 set-session / reload-state / 10s 调度器都会清扫这类过期的 pvq- 消息（保留当前执行中任务的那一条）；agent/inbox/inserted 拦截也改为：当前执行中消息放行、过期 pvq- 消息移除（开关关闭时同样生效）。
  • 根因二：重启后 loadState 会把「执行中 / 待确认」任务原样恢复，导致旧的待确认任务劫持重启后的第一条输入（当成回答），或旧任务被悄悄重跑。现在重启时执行中 / 待确认 → 打断（「服务重启，任务未完成」）并清除过期的 task-confirming 暂停，只有用户显式「继续任务 / 编辑 / 送出」才会重跑；排队中的 pending 任务保留，但只在用户重新开启开关（且处于谷段）时才派发。
  • 顺带修复：开关点击偶尔需要两次才生效（会话注册与切换 RPC 的竞态）——现在一次点击必生效且面板立即打开；reload-state 不再把开关重置为关闭；拦截时以 inbox.remove 的返回值判重，即使静态/动态两种挂载方式被同时启用，每条输入也只入队一次（不再重复添加同一个任务）。

License

MIT