2 Commits

Author	SHA1	Message	Date
Blizzard	0378a770ca	fix(hitl): resume 记录 KV 键不可含冒号（NATS: invalid key） ... live NATS 联调发现：resume 记录键用 "pending:"+taskID，冒号是 NATS JetStream KV 非法字符（仅允许 [-/_=.a-zA-Z0-9]）→ 中断时 persistResume 的 Put 静默失败、决定 到达时 loadResume 报 "nats: invalid key"，任务永卡 waiting、无法恢复。内存桩接受 任意键，故单测漏过——正是只有 live NATS 才暴露的那类。 - pendingKey: "pending:"+id → "pending_"+id（合法键）。 - persistResume: Put 失败改 log.Printf 大声告警（不止 exec 轨迹），关键失败可见。 - 回归测试 TestPendingKeyIsNATSValid：直接钉键形匹配 NATS KV 字符集，绕开内存桩盲区。 live 验证（devnats + 真链路）：提交 HITL 任务→waiting→杀 dispatcher→离线批准→ 重启→1s waiting→2s running→3s done，deepseek 真实出稿。证明 checkpoint 抗重启 + 决定经 JetStream 抗离线 + 断点恢复。 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>	2026-06-29 14:25:47 +08:00
Blizzard	f3bf42c432	feat(hitl): 增量1 —— JetStream KV checkpoint store（持久化中断地基） ... HITL 持久化中断/恢复的地基：compose checkpoint 需要一个可持久化、抗重启的 存储后端。dispatcher 是"只说 NATS、无 DB"的纯净设计，故复用既有 JetStream （bus.js）开 KV 桶，不引 Redis、不破坏架构原则。 - shared/bus: 新增 KVHandle + Bus.Checkpoints(bucket, ttl)。薄封装把 NATS 细节（ErrKeyNotFound→ok=false、Delete 幂等）挡在 bus 内，对外是朴素 Get/Put/Delete；bus 无需反向依赖 eino。File 存储 + 桶级 TTL 兜底清理。 - dispatcher/eino: checkpointStore 把 CheckpointKV 适配成 compose.CheckPointStore （Get/Set + 可选 Delete）。CheckpointKV 是最小接口，bus.KVHandle 结构化满足。 - 测试: 内存桩往返（Set→Get→Delete→miss）+ 编译期契约断言 `var _ CheckpointKV = (*bus.KVHandle)(nil)` 钉死 bus↔eino 隐式契约。 零爆炸半径（纯新增）。go test ./... 全绿。 下一步增量2：审批节点改 compose.Interrupt + Orchestrator 识别中断置 waiting。 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>	2026-06-29 11:39:20 +08:00