@tc-libs/sse

Hub semplice per Server-Sent Events.

Espone:

• SseModule
• SseHubService
• SseController

Cosa fa

SseHubService mantiene una mappa di client connessi e permette di:

• aggiungere un client con addClient
• rimuoverlo con removeClient
• inviare eventi a tutti con broadcast
• contare le connessioni con count

Uso del service

this.sseHubService.broadcast('job.completed', {
  jobId: '123',
  status: 'done',
});

Quando un client si collega riceve subito un evento hello.

Endpoint incluso

Il controller esporta un endpoint SSE su GET /sse:

@Sse('sse')
stream(@Req() req: Request): Observable<MessageEvent>

Alla chiusura della connessione il client viene rimosso automaticamente.

Note operative

• Il modulo e @Global().
• Il package non gestisce autenticazione o stanze/canali.
• Il package request esclude esplicitamente l'endpoint SSE dal timeout globale.

Sviluppo

nx build sse
nx test sse