npm package discovery and stats viewer.

Discover Tips

  • General search

    [free text search, go nuts!]

  • Package details

    pkg:[package-name]

  • User packages

    @[username]

Sponsor

Optimize Toolset

I’ve always been into building performant and accessible sites, but lately I’ve been taking it extremely seriously. So much so that I’ve been building a tool to help me optimize and monitor the sites that I build to make sure that I’m making an attempt to offer the best experience to those who visit them. If you’re into performant, accessible and SEO friendly sites, you might like it too! You can check it out at Optimize Toolset.

About

Hi, 👋, I’m Ryan Hefner  and I built this site for me, and you! The goal of this site was to provide an easy way for me to check the stats on my npm packages, both for prioritizing issues and updates, and to give me a little kick in the pants to keep up on stuff.

As I was building it, I realized that I was actually using the tool to build the tool, and figured I might as well put this out there and hopefully others will find it to be a fast and useful way to search and browse npm packages as I have.

If you’re interested in other things I’m working on, follow me on Twitter or check out the open source projects I’ve been publishing on GitHub.

I am also working on a Twitter bot for this site to tweet the most popular, newest, random packages from npm. Please follow that account now and it will start sending out packages soon–ish.

Open Software & Tools

This site wouldn’t be possible without the immense generosity and tireless efforts from the people who make contributions to the world and share their work via open source initiatives. Thank you 🙏

© 2024 – Pkg Stats / Ryan Hefner

sse-service

v1.0.9

Published

Lightweight, fast and framework-agnostic Server-Sent Events (SSE) service for NodeJS

Downloads

26

Readme

Server-Sent Events (SSE) service

Lightweight, fast and framework-agnostic SSE service for NodeJS

Written on TS.

Features

  • Could be embedded to Express, Fastify, Nest, etc. implemantation
  • Easy to manage connections by providing a groups feature of user conections
  • Allows a few connections per user (from different devices for example), so you can send data to every user connection providing the user id
  • Allows to pass through original response headers(headers that were added by your framework, for example) to end up response stream

Basic usages examples

Fastify


import { connectSSE } from 'sse-service';
import { fastify } from 'fastify';

const server = fastify({ logger: true });

server.route({
  method: 'GET',
  url: '/sse',
  handler: async (req, res) => {
    connectSSE({
      clientId: 'unique id', // this is a primary key of how your client connection could be retrieved, could be ommited, library will take care of creating unique id  
      // client id could be retrieved from the JWT token for example
      req: req.raw, // here we link to raw NodeJS request object, because its wrapped by Fastify
      res: res.raw, // the same as for request
      originalResHeaders: res.getHeaders(), // sometimes you need to pass through response headers added by Fastify, this headers will be added to raw NodeJS response stream
      onDisconnectCb: () => {
        // ....
      }, // sometimes you need to perform some actions when user disconnects
    });
  },
});

Then you can use it like this in some other place where you receive updates from some message queue for instance:

// someService.ts

import { sendSSEToClient } from 'sse-service';

// ....

// some function that handles update from message queue or whatever
const processUpdate = (update) => {
  const { userId, ...payload } = update;
  
  // userId equals to value you passed as clientId in connectSSE method
  sendSSEToClient(userId, payload); // this will send payload to every connection that user with userId has
  
  // OR send update to all connected users:

  sendSSEToAll(payload);
}; 


Nest

Take a note that Nest has built-in SSE implementation: https://docs.nestjs.com/techniques/server-sent-events

So maybe for you goals it will be enough using it

// sse.controller.ts

import { connectSSE } from 'sse-service';

// ...

export class SseController {

    // ...
  
    public sse(@Req() req, @Res() res) {
      connectSSE({
        clientId: req.user.id, // this is a primary key of how your client connection could be retrieved, could be ommited, library will take care of creating unique id  
        // client id could be retrieved from the JWT token for example
        req,
        res,
        originalResHeaders: res.getHeaders(), // sometimes you need to pass through response headers added by Nest (actually it is Fastify or Express under the hood), this headers will be added to raw NodeJS response stream
        onDisconnectCb: () => {
          // ... 
        }, // sometimes you need to perform some actions when user disconnects
      });
    }
}

Then you can use it like this in some other place where you receive updates from some message queue for instance:

// someService.ts

import { sendSSEToClient } from 'sse-service';

// ....

// some function that handles update from message queue or whatever
const processUpdate = (update) => {
  const { userId, ...payload } = update;
  
  // userId equals to value you passed as clientId in connectSSE method
  sendSSEToClient(userId, payload); // this will send payload to every connection that user with userId has

  // OR send update to all:

  sendSSEToAll(payload);
}; 

Express

var express = require('express')
var app = express()

app.get('/sse', function (req, res) {
  connectSSE({
    clientId: req.user.id, // this is a primary key of how your client connection could be retrieved, could be ommited, library will take care of creating unique id  
    // client id could be retrieved from the JWT token for example
    req,
    res,
    originalResHeaders: res.getHeaders(), // sometimes you need to pass through response headers added by Express, this headers will be added to raw NodeJS response stream
    onDisconnectCb: () => {
      // ... 
    }, // sometimes you need to perform some actions when user disconnects
  });
})

app.listen(3000);

Then you can use it like this in some other place where you receive updates from some message queue for instance:

// someService.ts

import { sendSSEToClient } from 'sse-service';

// ....

// some function that handles update from message queue or whatever
const processUpdate = (update) => {
  const { userId, ...payload } = update;
  
  // userId equals to value you passed as clientId in connectSSE method
  sendSSEToClient(userId, payload); // this will send payload to every connection that user with userId has

  // OR send update to all:

  sendSSEToAll(payload);
}; 

Installation

npm install sse-service

API

connectSSE(params)

Setups SSE connection

params:


{
  req: HttpRequest; // NodeJS raw request object
  
  res: HttpResponse; // NodeJS raw response object
  
  originalResHeaders: HttpResponseHeaders; // response headers from the response object of you framework,
  // for example Fastify wraps original response object and could add additional headers,
  // so if you want to pass them through call .getHeaders() on the framework's response object and pass here 
  
  meta?: Record<string, any>; // any metadata to be persisted in client object that will be created 
  
  clientId?: string; // this is a primary key of how your client connection could be retrieved, 
  // could be ommited, library will take care of creating unique id  
  // client id could be retrieved from the JWT token for example
  
  onDisconnectCb?: () => void; // sometimes you need to perform some actions when user disconnects
  
  groupName?: string; // this param allows you to add this user connection to some specific group(namespace)
  // so later you could send a SSE message for all users connections from this group
  // by default all connections being added to default group name
}

Method returns:


 {
    client: {
        connections: HttpResponse[]; // array of raw NodeJS responses, 
        // will contain more then one if we add few connections by the same clientId param
        meta?: Record<string, any>; // any meta you have added by meta param
        clientId: string; // client id you passed to or the one generated by lib
    };
    currConnection: HttpResponse // raw NodeJS response object that was esatablished by this specific connectSSE method call 
 }
 

sendSSEToClient(clientId, msg [, eventType [, groupName [, sseMsgId ] ] ])

Send message to specific client by id

Params:

| Param | Type/Required | Comment | |:-------------|:---------------------------------------------------------------------------------:|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------:| | clientId | Type: string Required: true | Id of the client you want send message to | | msg | Type: string or Record<string, any> or any[] Required: true | Message to send | | eventType | Type: string Required: false | Event type param in SSE message, check: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events | | groupName | Type: string Required: false | The group(namespace) where to get this client by id from, if not provided it goes to default group | | sseMsgId | Type: number Required: false | The event ID to set the EventSource object's last event ID value, check: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events |

sendSSEToConnection(connection, msg [, eventType [, sseMsgId ] ])

Send message to specific connection

Params:

| Param | Type/Required | Comment | |:--------------|:--------------------------------------------------------------------------------------:|----------------------------------------------------------------------------------------------------------------------------------------------------------------------:| | connection | Type: HttpResponse Required: true | Response object that was established for SSE | | msg | Type: string or Record<string, any> or any[] Required: true | Message to send | | eventType | Type: string Required: false | Event type param in SSE message, check: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events | | sseMsgId | Type: number Required: false | The event ID to set the EventSource object's last event ID value, check: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events |

sendSSEToAll(connection, msg [, eventType [, sseMsgId ] ])

Send message to all active clients

Params:

| Param | Type/Required | Comment | |:-------------|:---------------------------------------------------------------------------------:|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------:| | msg | Type: string or Record<string, any> or any[] Required: true | Message to send | | eventType | Type: string Required: false | Event type param in SSE message, check: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events | | groupName | Type: string Required: false | The group(namespace) where to get this client by id from, if not provided it goes to default group | | sseMsgId | Type: number Required: false | The event ID to set the EventSource object's last event ID value, check: https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events |

getClientObj(clientId [, groupName ])

Get user's active connections and his meta

Params:

| Param | Type/Required | Comment | |:----------|:--------------------------------------------:|----------------------------------------------------------------------------------------------------------------------------------------------------------------------:| | clientId | Type: string Required: true | Message to send | | groupName | Type: string Required: false | The group(namespace) where to get this client by id from, if not provided it goes to default group |

Method returns:

 {
    connections: HttpResponse[]; // array of raw NodeJS responses,
    // will contain more then one if we add few connections by the same clientId param
    meta?: Record<string, any>; // any meta you have added by meta param
    clientId: string; // client id you passed to or the one generated by lib
 };

getAllClientObjs([groupName])

Get connections and meta of all active clients

Params:

| Param | Type/Required | Comment | |:----------|:--------------------------------------------:|----------------------------------------------------------------------------------------------------:| | groupName | Type: string Required: false | The group(namespace) where to get this clients from, if not provided it goes to default group |

Method returns:

 Array<{
    connections: HttpResponse[]; // array of raw NodeJS responses,
    // will contain more then one if we add few connections by the same clientId param
    meta?: Record<string, any>; // any meta you have added by meta param
    clientId: string; // client id you passed to or the one generated by lib
 }>;

setClientMetadata(clientId [, groupName ])

Set client's meta

Params:

| Param | Type/Required | Comment | |:----------|:------------------------------------------------------:|---------------------------------------------------------------------------------------------------:| | clientId | Type: string Required: true | Id of client | | meta | Type: Record<string, any> Required: true | Some meta you need to persist for this client | | groupName | Type: string Required: false | The group(namespace) where to get this client by id from, if not provided it goes to default group |

Method returns:

 {
    connections: HttpResponse[]; // array of raw NodeJS responses,
    // will contain more then one if we add few connections by the same clientId param
    meta?: Record<string, any>; // any meta you have added by meta param
    clientId: string; // client id you passed to or the one generated by lib
 };k

License

MIT