weichenandCursor 0531462acc fix(sse): bound heartbeat lifetime and reuse idempotent task streams ...

- Wait for the chat SSE heartbeat goroutine to exit before the handler
  returns, so it cannot write a recycled connection
- Extend /tasks/run write deadline to 75m so long sync runs are not cut
  by the global 120s WriteTimeout before the response is written
- Reuse an existing task run on the SSE path when the idempotency key
  already belongs to the same user/session/project
- Log stale fencing on event ack so unbounded replay is observable

Co-authored-by: Cursor <cursoragent@cursor.com>

2026-09-19 07:49:01 +00:00

..

bus.go

feat(events): add durable envelope delivery and drop commit OnOutbox

2026-09-14 15:59:24 +00:00

cutover_script_test.go

feat(events): gate shared-dev consumer mode changes

2026-09-15 14:11:44 +00:00

cutover_test.go

feat(events): gate shared-dev consumer mode changes

2026-09-15 14:11:44 +00:00

cutover.go

feat(events): gate shared-dev consumer mode changes

2026-09-15 14:11:44 +00:00

dispatcher_pg_test.go

test(events): prove WriterLive off/shadow/live hook matrix

2026-09-15 10:17:26 +00:00

dispatcher_test.go

test(events): prove WriterLive off/shadow/live hook matrix

2026-09-15 10:17:26 +00:00

dispatcher.go

feat(events): skip in-process writers when a consumer is live

2026-09-15 10:17:09 +00:00

envelope_test.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

envelope.go

feat(events): gate shared-dev consumer mode changes

2026-09-15 14:11:44 +00:00

inventory_store.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

inventory_test.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

inventory.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

pg_test.go

feat(events): replace SELECT-only claim with fenced atomic leases

2026-09-15 09:08:15 +00:00

pg.go

feat(events): replace SELECT-only claim with fenced atomic leases

2026-09-15 09:08:15 +00:00

principal_test.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

principal.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

registry_test.go

feat(events): register intent.plan contracts and table owners

2026-09-15 16:20:19 +00:00

registry.go

feat(events): register intent.plan contracts and table owners

2026-09-15 16:20:19 +00:00

replay_test.go

test(events): reject replay apply without approval ref

2026-09-15 13:26:20 +00:00

replay.go

feat(events): fail-closed scope, static registry, inventory, and replay digest

2026-09-15 08:52:30 +00:00

worker.go

fix(sse): bound heartbeat lifetime and reuse idempotent task streams

2026-09-19 07:49:01 +00:00