@xemahq/realtime-stream

NestJS SSE edge for the unified realtime stream

Overview

A NestJS module that owns the unified realtime SSE channel. It handles scope subscriptions, a dedicated session escape-hatch, per-user / per-project / per-session authorization, and multi-scope cursor resumption via the last-event-id header. It consumes an upstream event source through a pluggable interface and fans frames out to connected clients. Pairs with the browser-side realtime client.

When to use it

• Use it in a NestJS service that needs to host the realtime SSE edge.

Installation

pnpm add @xemahq/realtime-stream

Usage

import { RealtimeStreamModule } from '@xemahq/realtime-stream';

@Module({
  imports: [RealtimeStreamModule.forRoot(options)],
})
export class AppModule {}

Peer requirements

• @nestjs/common >=10, @nestjs/core >=10, @nestjs/swagger >=7
• @xemahq/event-hub-client
• class-transformer >=0.5, class-validator >=0.14, rxjs >=7

License

Apache-2.0 © Xema — xema.dev