Socket.IO Postgres emitter

The @socket.io/postgres-emitter package allows you to easily communicate with a group of Socket.IO servers from another Node.js process (server-side).

It must be used in conjunction with @socket.io/posgres-adapter.

Supported features:

• broadcasting
• utility methods
  • socketsJoin
  • socketsLeave
  • disconnectSockets
  • serverSideEmit

Table of contents

• Installation
• Usage
• API
• Known errors
• License

Installation

npm install @socket.io/postgres-emitter pg

For TypeScript users, you might also need @types/pg.

Usage

1const { Emitter } = require("@socket.io/postgres-emitter");
2const { Pool } = require("pg");
3
4const pool = new Pool({
5  user: "postgres",
6  host: "localhost",
7  database: "postgres",
8  password: "changeit",
9  port: 5432,
10});
11
12const io = new Emitter(pool);
13
14setInterval(() => {
15  io.emit("ping", new Date());
16}, 1000);

API

Emitter(pool[, nsp][, opts])

1const io = new Emitter(pool);

The pool argument is a Pool object from the pg package.

Emitter#to(room:string):BroadcastOperator

Emitter#in(room:string):BroadcastOperator

Specifies a specific room that you want to emit to.

1io.to("room1").emit("hello");

Emitter#except(room:string):BroadcastOperator

Specifies a specific room that you want to exclude from broadcasting.

1io.except("room2").emit("hello");

Emitter#of(namespace:string):Emitter

Specifies a specific namespace that you want to emit to.

1const customNamespace = io.of("/custom");
2
3customNamespace.emit("hello");

Emitter#socketsJoin(rooms:string|string[])

Makes the matching socket instances join the specified rooms:

1// make all Socket instances join the "room1" room
2io.socketsJoin("room1");
3
4// make all Socket instances of the "admin" namespace in the "room1" room join the "room2" room
5io.of("/admin").in("room1").socketsJoin("room2");

Emitter#socketsLeave(rooms:string|string[])

Makes the matching socket instances leave the specified rooms:

1// make all Socket instances leave the "room1" room
2io.socketsLeave("room1");
3
4// make all Socket instances of the "admin" namespace in the "room1" room leave the "room2" room
5io.of("/admin").in("room1").socketsLeave("room2");

Emitter#disconnectSockets(close:boolean)

Makes the matching socket instances disconnect:

1// make all Socket instances disconnect
2io.disconnectSockets();
3
4// make all Socket instances of the "admin" namespace in the "room1" room disconnect
5io.of("/admin").in("room1").disconnectSockets();
6
7// this also works with a single socket ID
8io.of("/admin").in(theSocketId).disconnectSockets();

Emitter#serverSideEmit(ev:string[,...args:any[]])

Emits an event that will be received by each Socket.IO server of the cluster.

1io.serverSideEmit("ping");

License

MIT