-
Python stdlib 没有 WebSocket 支持，src/ws_subscribe.py 手写 RFC 6455 握手（hashlib+base64 算 Sec-WebSocket-Accept）+ 帧编解码（服务端帧不 加掩码，客户端帧强制解掩码），不引入 websockets 之类第三方库 （05 §5.7）。 推送用轮询而非写路径 hook：execution_event 的写入分散在十几个调用点 （org_node_trigger/work_graph_execute/work_node_run/task_create/ bug_record/...），没有单一写入路径可以插桩，backend_server.py 的 _handle_ws_subscribe 劫持 ThreadingHTTPServer 连接后每 0.5 秒按 rowid 增量查一次 execution_event（project_id/可选 task_id 过滤）， 轻松满足 REQ-12 的 ≤2 秒目标。断线重连按 03-C §3.14 走 REST 快照，不 在 WS 层做消息重放，新连接只看连接那一刻起的新事件。 daemon_threads = True 避免长连接 WS 线程阻塞进程退出。 验证：test_backend_server.py 用原始 socket 走真实握手+推送延迟断言； 另外用 Node 原生 WebSocket 客户端做跨实现互操作性验证，连真实运行的 服务器，从建连到收到 c_task_create 触发的真实推送全程走通。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
