umputun / stash / 20687729226

84%

Build Type

push

github

Committed by web-flow

Commit Message

feat(sse): add real-time key change subscriptions via Server-Sent Events (#58)

* docs: add key subscription (SSE) implementation plan

add plan for real-time key change notifications via Server-Sent Events.
clients can subscribe to specific keys or prefix patterns and receive
events on create/update/delete operations.

* feat(sse): add real-time key change subscriptions via Server-Sent Events

- add SSE service with topic-based pub/sub for key change events
- support exact key (/subscribe/key) and prefix patterns (/subscribe/prefix/ or /subscribe/prefix/*)
- use http.ResponseController to disable WriteTimeout for long-lived connections
- publish create/update/delete events from API and web handlers
- add Go client library with Subscribe, SubscribePrefix, SubscribeAll methods
- integrate with auth system for permission-based filtering
- add integration tests for SSE subscriptions

* fix: properly terminate SSE subscription connections on Close

- Subscription.Close() now cancels the HTTP request context instead of
  just signaling a done channel, ensuring connections do not leak
- Added test verifying Close() terminates server connection and closes
  both channels
- Increased SSE test sleep times to 200ms for CI robustness

* fix(sse): address code review findings

- skip SSE endpoints in audit middleware (long-lived connections)
- split shutdown timeout between SSE and HTTP server
- fix duplicate topic for empty key in keyToTopics
- rename Auth to AuthProvider for consistency
- remove "failed to" prefix from error messages
- add Subscribe methods documentation to client README

* fix(sse): add tests and improve error handling

- add shutdown test with active SSE connection
- add EventPublisher tests for Set/Delete handlers
- log debug message when write deadline fallback fails
- document sse package in CLAUDE.md project structure
- document retry behavior in Go client README

* docs(sse): update subscription docs and add integration tests

- Document... (continued)

Run Details

319 of 398 new or added lines in 11 files covered. (80.15%)

3 existing lines in 2 files now uncovered.

4054 of 4852 relevant lines covered (83.55%)

76.56 hits per line