dsh-plugin-autoqueue

autoqueue — DSH 任务队列与调度中心

在 DSH 中管理任务、调度和批量自动化执行。支持看板操作、HTTP API、AI 工具调用和文件丢入等多种创建方式；引擎自动处理派发、反阻塞、重试、结算与归档。

核心设计：调度器（Scheduler）与任务（Task）分离。

• 调度器：带 cron 或 schedule 的条目，到点时自动创建即时任务，自身不执行、不进入状态机。可独立启用/禁用。
• 任务：即时执行的一次性条目，有完整的 status、phase、executions 生命周期，受并发控制与状态机管理。

两个设计目标始终不变：正常任务不打扰用户；队列任务不改变 DSH 普通前台会话的运行状态。

功能概览

• 看板 UI：任务/调度器/归档三栏管理、状态筛选、批量操作、实时 SSE、详情抽屉、运行设置和进程控制。
• 多种创建入口：看板新建、HTTP API、丢 md 文件、DSH 对话中直接调用 19 个 autoqueue_* Host AI 工具。
• 调度系统：cron 循环、schedule 一次性定时、deadline 截止窗口。
• 模板库：预置任务模板、参数化创建、模板管理。
• 进程守护：watchdog 异常退出自动重启 DSH、端口残留清理。
• 外部 AI 接入：机器发现（Capabilities + OpenAPI 3.1）、带鉴权 HTTP API、紧凑状态投影。
• 省Token工具：透明代理拦截所有 LLM 请求，RTK 自动压缩 git diff/grep/ls 等工具输出，可选 prompt injection（电报体/最小实现）节省对话 token；默认关闭，按需开启。
• 智能执行引擎：反阻塞 steering、指数退避重试、超时检测、空转检测、幂等护栏。

兼容基线

• 本版本逐项审计和自测的精确基线是 `@deepseek-ai/dsh 0.2.0-rc.2`。
• 插件清单接受 >=0.1.1-rc.2，已验证兼容 0.2.x 系列；升级 DSH 后仍应重新跑单元测试和 Playwright。
• @deepseek-ai/dsh-sandbox-policy、@deepseek-ai/dsh-tools 与 @deepseek-ai/dsh-user-approval 跟随 dsh 引擎版本范围。

无人值守安全边界

autoqueue 不是普通会话的全局自动化开关。每次执行都遵守以下边界：

1. 每次 attempt 先在账本中持久化一个 autoqueue-session- 专属会话 ID；runner 拒绝读取或修改不属于该命名空间的会话。
2. 每次 attempt 使用独立运行目录，并通过 sessions.create({ sessionId, cwd, ... }) 把 cwd 绑定到该会话；不会创建、选择或切换 Host 全局工作区。
3. 执行模式只由引擎在插件自有、带版本号的 preset 中选择：autoqueue-unattended-v2。v1 内容保留且绝不覆盖，但不再被新执行选择。v2 要求 [autoqueue:unattended-discipline:v2] 完整匹配，并禁用提问、jobs、subagent/fork/control/list、workflow、Ralph；bash/pwsh 强制 enableRunInBackground:false，禁止 detached/daemon/background 工作逃离 owned session。已有 v2 若 marker 缺失或内容被改动，插件启动失败，不覆盖外部内容。
4. 会话创建后、goals.create 前，插件把该专属会话的 approvalPolicy 固化为 never，持久化并回读验证。失败时不投递 goal，并尝试取消该会话。
5. 任务正文只通过一次完整的 goals.create.objective 入场。不会调用 workspace.create、不会调用 session.selectModel，也不会再发送一条重复的初始 queue prompt。
6. DSH 原生 agent/status、owned goal/changed 与 session/disposed 事件只负责唤醒权威对账；每轮仍读取 sessions.list / history。存在活跃普通会话或列表不可信时拒绝新派发，运行中的 owned goal 先持久化 pause、再暂停并协作取消 turn；连续两次可信空闲后才无 prompt 恢复。
7. 手动停止、deadline、超时和清理先持久化取消意图。sessions.cancel 成功只代表 DSH 受理请求；ownership 会一直保留到受理之后连续两次权威 idle/缺席观察，再结算或重试。
8. 默认最大并发为 1、终态自动归档关闭、浏览器通知关闭。插件加载后会向普通 Host 会话自动注册 19 个 autoqueue_* 工具；它们不会自行执行或改变普通会话状态，且在 autoqueue-session-* 自有任务 Agent 中被隐藏并由执行 guard 拒绝。

DSH rc.2 的公开选择接口会持久化 Host 默认路由，因此任务和运行时配置都不能覆盖工作区或任意 Agent preset。GET /api/queue/options 会明确返回三类空数组和隔离锁，而不是枚举 Host 状态。

这里的“不影响主进程”是会话、选择状态、审批和调度边界：插件不修改或取消普通会话，并在前台活动时让行。插件仍加载在同一个 DSH Host 进程内，不是 cgroup/容器级资源隔离；若要求对 CPU、内存或插件崩溃做内核级硬隔离，应把队列运行时部署到独立 DSH Host。

快速开始

从 npm 安装

dsh plugin --profile web add -w @alintever/dsh-plugin-autoqueue@latest

本地开发时可以改为链接当前工作区：

dsh plugin --profile web add -w "link:$PWD"

安装后，在 DSH Web 侧边栏打开「任务工作台」看板，也可以直接对 AI 说「帮我创建一个任务」。

打开看板

安装后，在 DSH Web 侧边栏点击「任务工作台」。看板关闭时不会预加载队列数据，也不会维持 SSE 连接；只有用户主动打开后才初始化状态、配置和事件订阅。

看板是队列的完整操作面：新建任务、管理调度器、调整运行设置、批量归档、查看执行报告，全部可以在 UI 内完成。

从 DSH 对话创建

插件安装后，普通 Host 会话会自动获得 19 个 autoqueue_* 工具。你可以直接对 AI 说：

"创建一个任务，key 叫 daily-report，内容是收集今天的工作数据并输出 report.md"

AI 会调用 autoqueue_create_task 完成创建；你也可以在对话中要求查看任务列表、停止任务、重跑失败任务或归档已完成任务。这些工具不会自行执行，也不会改变普通会话的状态。

创建即时任务

curl -X POST http://127.0.0.1:3080/api/queue/task \
  -H 'Content-Type: application/json' \
  -d '{
    "requestId": "my-001",
    "key": "daily-report",
    "content": "# 生成日报\n\n收集今天的工作数据，输出 report.md",
    "priority": 5,
    "autoArchive": true,
    "enableNotifications": false
  }'

创建调度器

带 cron 或 schedule 即创建调度器：

curl -X POST http://127.0.0.1:3080/api/queue/task \
  -H 'Content-Type: application/json' \
  -d '{
    "requestId": "my-002",
    "key": "weekly-insight",
    "content": "# 生成周报\n\n汇总本周代码提交与 issue 进展",
    "cron": "0 9 * * 1",
    "priority": 5
  }'

调度器在到点时自动创建即时任务，即时任务继承调度器的配置，并通过 schedulerKey 关联回源调度器。

丢文件

echo "# 生成日报" > ~/.dsh/queue/tasks/daily-report.md

文件名就是 key，正文就是任务。文件头可声明一次性调度、循环调度和截止窗口：

# 每日工作报告

schedule 与 cron 二选一；deadline 可以和任一方式共存。

带 schedule 或 cron 的文件会被识别为调度器，自身不直接执行；不带则为即时任务。看板中「任务」和「调度」是独立的两栏。

看板功能面

看板不是只读监控，而是队列的完整操作面。React 工作台已暴露安全业务能力的所有入口：

• 导航：任务、调度、归档三个独立标签页。任务页按状态筛选（全部/运行中/待执行/失败/已完成）；调度页按启用状态筛选（全部/启用中/已禁用）；归档页展示已归档任务。
• 列表展示：以 body 中的 # 标题 作为主标题（直观可读），key 作为副标题灰色展示；调度器额外展示 cron/schedule 摘要。
• 运行态：紧凑展示隔离状态、前台优先和并发占用；完整的原生事件、权威对账、扫描时间和兜底检查按需展开。
• 原生监控：显示 DSH runtime 原生事件、权威 session 对账、收件箱扫描、foreground gate 与 10 秒 watchdog；SSE 连接状态单独展示，不拿网络在线冒充核心隔离健康。
• 任务操作：新建、编辑（非 running）、停止、重跑、归档、恢复、删除 pending、标记未读、跳转插件自有 DSH 会话、立即检查任务。
• 调度器操作：启用、禁用、编辑、删除。调度器不进入状态机，因此没有停止/归档/重跑。
• 任务详情：概览、执行记录、结果和最终报告、调度与恢复设置；打开终态详情会标记已读。由调度器创建的任务会显示「来源调度器」。
• 调度器详情：概览、策略；展示启用状态、下次运行时间、最近创建的任务。
• 运行设置：并发、任务超时、Goal 轮数、反阻塞次数、派发尝试、不可达阈值、退避、默认优先级、默认截止、Webhook、自动归档、浏览器通知和进程守护（watchdog）；队列目录只读。
• 省Token面板：侧边栏闪电图标打开，可开启/关闭透明代理、RTK 压缩和 prompt injection 策略；默认全部关闭。
• 进程控制：看板右上角提供重启 DSH 和关闭 DSH 按钮（均仅限 loopback），并展示 watchdog 守护状态。关闭前需确认。
• 外部接入：独立的「AI / API 接入」抽屉实时读取 Capabilities，展示正式名称/别称、19 个工具、中文资源与限制、隔离状态、OpenAPI 3.1 和 compact 查询示例；本机可直连，远程必须携带 token，页面从不回显 token。
• 交互与可访问性：统一字号和颜色层级，支持响应式导航、抽屉/弹窗、危险操作确认、键盘焦点锁定与恢复、ESC 关闭和实时错误提示。

隔离字段不会出现在新建、编辑或运行设置表单中；UI 只展示“已锁定”的安全说明。

外部 AI 与 HTTP API

DSH 普通会话默认可直接调用自动注入的 Host 工具；DSH 进程外的 AI 使用带鉴权的 HTTP API：

AI 自然语言中的正式名称是「任务队列」，「老登」是同一能力的别称；例如“交给老登执行”和“加入任务队列”都会映射到现有 autoqueue_* 工具。别称不新增工具名、HTTP 路径或第二套控制面。

# 1. 发现能力
curl http://127.0.0.1:3080/api/autoqueue/capabilities

# 2. 读取 OpenAPI 接口描述
curl http://127.0.0.1:3080/api/autoqueue/openapi.json

# 3. 用紧凑投影列任务和调度器，避免把正文和 executions 放进 LLM 上下文
curl 'http://127.0.0.1:3080/api/queue/state?archived=1&compact=1'

完整正文、执行历史和报告按需读取 /api/queue/detail?key=...。所有端点见 docs/api.md。

方法 · 路径 · 用途 GET · /api/autoqueue/capabilities · 能力、限制、资源地址和 Host AI 工具启用策略 GET · /api/autoqueue/openapi.json · OpenAPI 3.1 接口描述 GET · /api/queue/state · 快照；返回 tasks + schedulers；支持 archived=1、compact=1 POST · /api/queue/task · 创建任务或调度器（含 cron/schedule 时创建调度器） POST · /api/queue/action · stop/archive/restore/delete/rerun/update/force-scan/set-concurrency GET · /api/queue/detail?key= · 正文、执行记录和报告（任务或调度器） GET · /api/queue/options · 三类空数组与严格隔离锁 GET\ · POST · /api/queue/config · 安全运行时配置 GET\ · POST · /api/queue/token-saver · 省Token配置与统计 POST · /api/queue/restart · 重启 DSH（仅限 loopback） POST · /api/queue/shutdown · 关闭 DSH（仅限 loopback） GET · /api/queue/watchdog · 查询 watchdog 守护状态 POST · /api/queue/mark-read · 标记已读/未读 GET · /api/queue/events · compact SSE 快照

鉴权

未配置 token 时，只有连接端地址和请求 Host 同时为 loopback 的本机直连免 token。远程或反向代理部署必须配置允许的 Host 和 token：

config:
  allowedHosts:
    - queue.example.com
  apiToken: "replace-with-a-long-random-secret"

也可以通过 DSH_AUTOQUEUE_TOKEN 或 AUTOQUEUE_API_TOKEN 环境变量提供 token。一旦设置 token，localhost 也必须鉴权。客户端发送：

Authorization: Bearer <token>

或：

X-Autoqueue-Token: <token>

Capabilities、OpenAPI、业务 API 和 SSE 使用相同鉴权；任何响应都不会包含 token 值。

调度与生命周期

调度器与任务类型

类型 · 触发方式 · 生命周期 · 可执行 即时任务 · 立即派发 或 schedule 一次性到点 · 完整状态机：pending → running → terminal · 是 循环调度器 · cron 匹配分钟触发 · 不进入状态机；到点时创建即时任务 · 否（自身不执行）

任务状态机

包含六个值：pending、running、done、failed、stopped、interrupted。其中 done / failed / stopped / interrupted 都属于 terminal；archivedAt 是独立归档标志，不是状态。

goal 报告 blocked 时，引擎先注入 steering 指令，再 goals.resume，最多执行 maxBlockedResumes 次。前台忙碌时，运行中的 goal 使用持久化 pause-before-cancel 流程让行；恢复前做两次可信空闲确认，不注入重复任务正文。会话不可达、超时、截止、限流和启动不确定性采用不同的恢复/隔离路径；关键 mutation 在远端调用前先持久化 ownership/admission marker，避免自动创建第二个 Agent。

调度器行为

• 启用中的调度器每分钟检查是否到点；到点时创建即时任务并记录 lastTaskKey。
• schedule 类型调度器在任务完成后自动禁用（一次性）。
• 调度器可独立启用/禁用；禁用后不再创建新任务，但已创建的任务继续执行。
• 调度器不支持归档和重跑；不需要时直接删除。

默认配置

捆绑配置的安全默认值：

config:
  maxGoalRounds: 40
  maxBlockedResumes: 3
  autoArchive: false
  unknownThreshold: 3
  maxAttempts: 3
  taskTimeoutMs: 10800000
  enableNotifications: false
  enableHostAiTools: true
  watchdogEnabled: false
  priority: 5
  scanIntervalMs: 15000
  maxConcurrent: 1

• maxConcurrent 持久化到账本，范围 1-8；插件启动时仅在账本当前值为 1 时应用非空启动值。
• queueDir、allowedHosts、apiToken、baseUrl、enableHostAiTools 属于启动边界；queueDir 不能运行时热切换。
• watchdogEnabled 默认是 false。设为 true 后，插件会启动独立的 watchdog 进程守护 DSH；DSH 异常退出（被 kill、崩溃、非 0 退出码）时自动清理残留子进程并重启。正常重启（restart API）和关闭（shutdown API）不会触发自动重启。
• 省Token工具默认全部关闭：通过省Token面板开启后，所有 LLM 请求自动经过压缩层拦截，无需切换 provider。caveman（电报体）和 ponytail（最小实现）为可选 prompt injection 策略，会改变 AI 回复风格。
• enableHostAiTools 默认是 true：插件加载后自动把 19 个 autoqueue_* 工具和一段精简发现提示注入普通 Host 会话。设为 false 可关闭注入；外部 AI 的 HTTP/OpenAPI 接入不受影响。
• 工具默认请求 http://127.0.0.1:3080；若 DSH Web 使用其他地址或端口，必须在启动配置中把 baseUrl 设为该实例可访问的 HTTP 基地址。
• 自动注入本身不会给队列任务增加递归控制入口：autoqueue-session-* Agent 看不到这些 Host 工具，执行层 guard 也会拒绝绕过可见性的工具调用。直接 HTTP 访问仍遵循前述本机/远程鉴权边界。

架构与开发

lib/
├── index.js     插件入口、鉴权、HTTP、SSE、preset 和 approvalPolicy 固化
├── engine-v2.js 派发、前台让行、轮询、反阻塞、重试、调度器管理、admission containment
├── runner.js    所有 apiProxy 会话/goal 调用和 session ownership 守卫
├── ledger.js    原子账本、CAS generation、requestId 去重、并发和恢复
├── files.js     收件箱、调度解析、运行目录和安全报告读取
├── scheduler.js cron 解析、nextRunAt 计算、catch-up
├── ai-tool.js   默认自动注册的 19 个 Host AI 工具 HTTP 薄客户端
├── watchdog.js  DSH 进程守护：异常退出自动重启、端口残留清理、PID 回收防护
└── client.js    由 client/src/ 构建的浏览器 bundle

npm install
npm run build:client
npm run test:unit
npm run test:playwright

npm 发布

更新 package.json 版本后，先在干净依赖环境中完成完整检查：

npm ci
npm run release:check
npm publish --dry-run
npm publish

prepublishOnly 会重新构建前端并运行核心测试，prepack 会再次生成浏览器 bundle；正式包固定发布到 npm 公共 registry。Playwright 属于显式的 release:check，避免发布环境缺少浏览器时产生不清晰的生命周期错误。

分层真实验收

仓库提供两套不会走 mock 的验收 driver：

• npm run test:live:ai：从 DSH 普通对话框驱动 AI，逐项核对 19 个 autoqueue_* Host 工具；简单任务验证计算与报告，复杂任务验证隔离目录内 CSV/JSON/nonce 读写、重跑和报告。
• npm run test:live:ui：从真实 DSH 任务台创建一次性定时任务和 Cron 任务，验证详情、编辑、原生 runtime 观测、真实并发、停止双 idle、重跑、归档/恢复和删除。

每套 driver 都必须使用一份全新的空 queueDir（包括不能有归档记录）、独立 DSH profile 和专用端口。下面以 AI driver 为例；跑 UI driver 时应停止 Host，重新创建 profile/queue，再把 LIVE_CASE 改为 ui：