Struct WsSseNotifier 

pub struct WsSseNotifier {
    pub ws: Arc<WsHub>,
    pub sse: Arc<SseHub>,
}

Bridges WebSocket + SSE hubs to the router’s [ChangeNotifier] trait.

Fields

ws: Arc<WsHub>

sse: Arc<SseHub>

Trait Implementations

impl ChangeNotifier for WsSseNotifier

fn notify_crdt(&self, entity: &str, row_id: &str, snapshot: &[u8])

Encode a CRDT broadcast frame (1-byte type + length-prefixed entity + length-prefixed row_id + Loro snapshot bytes) and ship it to clients SUBSCRIBED to this row. SSE is text-only so it gets skipped — clients on the SSE transport stay on the JSON change-event path until a future SSE-friendly encoding (base64 or hex-encoded chunks) lands.

Filtering by subscription instead of broadcasting to every WS client matters once more than a handful of rows are in flight: a 50-channel app with 100 connected users would otherwise fan 100x for every keystroke in a single channel. Now each binary frame goes only to the (typically small) set of tabs that asked to mirror that specific row.

If no clients are subscribed (empty list) the frame is dropped silently — the JSON change event from notify already told every connected client a write happened, so non-subscribed clients can re-fetch via the regular query path if they care.

Authz: the policy check happens at SUBSCRIBE TIME (in start_ws_server’s SnapshotFetcher closure) — clients on the subscriber list have already passed check_entity_read for the row at that moment. We don’t re-check on every broadcast because the broadcast hot path runs from the write thread without per-client auth context. A consequence: if a client is already subscribed and their permissions change mid-session (e.g. they’re removed from a private channel), they’ll keep receiving CRDT frames for that row until they disconnect. Future work: index subscribers by auth context so the broadcast can re-check, or invalidate subscriptions on policy changes.

Frame-encode failure (entity / row_id over the 16-bit length header) gets logged and dropped — the row’s regular JSON change event already shipped via notify, so clients still see the write happened, they just don’t get the binary CRDT delta.

fn notify(&self, event: &ChangeEvent)

fn notify_presence(&self, json: &str)