 DrSmoothl
|
29a792cfdf
|
refactor(core): extract sseResponse helper for the three WebUI SSE endpoints
/api/debug/stream、/api/state/stream、/api/logs/stream 各自逐字复制同一套 ~40 行
SSE 生命周期骨架（TextEncoder + closed 守卫 + 15s heartbeat + teardown + safe
enqueue + abort listener + event-stream headers）；改一处 heartbeat 间隔/teardown
顺序/headers 要同步改三处，漏一处会 listener 泄漏。
- 新增 webui/sse-response.ts：sseResponse(c, start) 封装传输壳，给 start 回调一个
channel { raw, encode, send, onClose, isClosed, desiredSize }。各端点特有的订阅/
背压 framePusher/初始快照留在回调里。
- 三端点收敛：debug/state 用 createFramePusher(背压丢帧) + onClose 注册订阅；logs
直接 ch.send；state 的 503 守卫留在 helper 外。
- 新增 sse-response.test.ts（4 例）为这三个原本无生命周期测试的端点建立安全网。
行为严格不变：core 471 全绿、typecheck 干净；对抗性 Agent 逐字对比 HEAD 确认
helper 骨架与三端点等价、无时序/守卫回归。
|
2026-07-01 18:53:34 +08:00 |
|