rm-hull / dot-block / 29264584838

62%

Build Type

push

github

Committed by web-flow

Commit Message

feat: add sequence numbers to SSE broadcast events (#193)

* feat: add sequence numbers to SSE broadcast events

Refactored the `Broadcaster` to handle `Event` structs instead of raw
bytes, enabling the inclusion of a `sequence` field. This allows clients
 to track message ordering and detect missed events in the stream.

```mermaid
sequenceDiagram
    participant D as Dispatcher
    participant B as Broadcaster
    participant C as SSE Client

    D->>B: Broadcast(Event{Domain: "example.com"})
    Note over B: Set Sequence = N++
    B->>C: Push Event(Sequence: N, ...)
```

* refactor: optimize SSE event broadcasting and serialization

- Use `atomic.Uint64` for sequence generation to remove lock contention
  in the `Broadcast` path.
- Refactor `Event` struct fields for brevity in JSON payloads.
- Align `Timestamp` field naming across the codebase.

```mermaid
sequenceDiagram
    participant D as Dispatcher
    participant B as Broadcaster
    participant S as Subscribers

    D->>B: Broadcast(event)
    B->>B: Increment sequence (atomic)
    B->>S: Fan-out event via RLock
```

Coverage Stats

14 of 16 new or added lines in 3 files covered. (87.5%)

1 existing line in 1 file now uncovered.

1600 of 2554 relevant lines covered (62.65%)

682.17 hits per line