lint

Author: darrachequesne

package-lock.json

@@ -30,6 +30,7 @@
     "@rollup/plugin-commonjs": "^26.0.1",
     "@rollup/plugin-node-resolve": "^15.2.3",
     "@sinonjs/fake-timers": "^11.2.2",
+    "@socket.io/postgres-adapter": "^0.1.0",
     "@types/debug": "^4.1.12",
     "@types/expect.js": "^0.3.32",
     "@types/mocha": "^10.0.7",

package.json

@@ -83,7 +83,7 @@ export interface PostgresEmitterOptions {
 
 export class Emitter<
   EmitEvents extends EventsMap = DefaultEventsMap,
-  ServerSideEvents extends EventsMap = DefaultEventsMap
+  ServerSideEvents extends EventsMap = DefaultEventsMap,
 > {
   public readonly channel: string;
   public readonly tableName: string;
@@ -92,7 +92,7 @@ export class Emitter<
   constructor(
     readonly pool: any,
     readonly nsp: string = "/",
-    opts: Partial<PostgresEmitterOptions> = {}
+    opts: Partial<PostgresEmitterOptions> = {},
   ) {
     const channelPrefix = opts.channelPrefix || "socket.io";
     this.channel = `${channelPrefix}#${nsp}`;
@@ -122,7 +122,7 @@ export class Emitter<
   ): true {
     return new BroadcastOperator<EmitEvents, ServerSideEvents>(this).emit(
       ev,
-      ...args
+      ...args,
     );
   }
 
@@ -134,7 +134,7 @@ export class Emitter<
    * @public
    */
   public to(
-    room: string | string[]
+    room: string | string[],
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     return new BroadcastOperator(this).to(room);
   }
@@ -147,7 +147,7 @@ export class Emitter<
    * @public
    */
   public in(
-    room: string | string[]
+    room: string | string[],
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     return new BroadcastOperator(this).in(room);
   }
@@ -160,7 +160,7 @@ export class Emitter<
    * @public
    */
   public except(
-    room: string | string[]
+    room: string | string[],
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     return new BroadcastOperator(this).except(room);
   }
@@ -185,7 +185,7 @@ export class Emitter<
    * @public
    */
   public compress(
-    compress: boolean
+    compress: boolean,
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     return new BroadcastOperator(this).compress(compress);
   }
@@ -231,7 +231,7 @@ export class Emitter<
     ...args: EventParams<ServerSideEvents, Ev>
   ): void {
     return new BroadcastOperator<EmitEvents, ServerSideEvents>(
-      this
+      this,
     ).serverSideEmit(ev, ...args);
   }
 }
@@ -247,13 +247,14 @@ export const RESERVED_EVENTS: ReadonlySet<string | Symbol> = new Set(<const>[
 
 export class BroadcastOperator<
   EmitEvents extends EventsMap,
-  ServerSideEvents extends EventsMap
-> implements TypedEventBroadcaster<EmitEvents> {
+  ServerSideEvents extends EventsMap,
+> implements TypedEventBroadcaster<EmitEvents>
+{
   constructor(
     private readonly emitter: Emitter,
     private readonly rooms: Set<string> = new Set<string>(),
     private readonly exceptRooms: Set<string> = new Set<string>(),
-    private readonly flags: BroadcastFlags = {}
+    private readonly flags: BroadcastFlags = {},
   ) {}
 
   /**
@@ -264,7 +265,7 @@ export class BroadcastOperator<
    * @public
    */
   public to(
-    room: string | string[]
+    room: string | string[],
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     const rooms = new Set(this.rooms);
     if (Array.isArray(room)) {
@@ -276,7 +277,7 @@ export class BroadcastOperator<
       this.emitter,
       rooms,
       this.exceptRooms,
-      this.flags
+      this.flags,
     );
   }
 
@@ -288,7 +289,7 @@ export class BroadcastOperator<
    * @public
    */
   public in(
-    room: string | string[]
+    room: string | string[],
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     return this.to(room);
   }
@@ -301,7 +302,7 @@ export class BroadcastOperator<
    * @public
    */
   public except(
-    room: string | string[]
+    room: string | string[],
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     const exceptRooms = new Set(this.exceptRooms);
     if (Array.isArray(room)) {
@@ -313,7 +314,7 @@ export class BroadcastOperator<
       this.emitter,
       this.rooms,
       exceptRooms,
-      this.flags
+      this.flags,
     );
   }
 
@@ -325,14 +326,14 @@ export class BroadcastOperator<
    * @public
    */
   public compress(
-    compress: boolean
+    compress: boolean,
   ): BroadcastOperator<EmitEvents, ServerSideEvents> {
     const flags = Object.assign({}, this.flags, { compress });
     return new BroadcastOperator(
       this.emitter,
       this.rooms,
       this.exceptRooms,
-      flags
+      flags,
     );
   }
 
@@ -350,7 +351,7 @@ export class BroadcastOperator<
       this.emitter,
       this.rooms,
       this.exceptRooms,
-      flags
+      flags,
     );
   }
 
@@ -377,10 +378,10 @@ export class BroadcastOperator<
       debug(
         "sending event of type %s to channel %s",
         document.type,
-        this.emitter.channel
+        this.emitter.channel,
       );
       await this.emitter.pool.query(
-        `NOTIFY "${this.emitter.channel}", '${payload}'`
+        `NOTIFY "${this.emitter.channel}", '${payload}'`,
       );
     } catch (err) {
       // @ts-ignore
@@ -394,11 +395,11 @@ export class BroadcastOperator<
     debug(
       "sending event of type %s with attachment to channel %s",
       document.type,
-      this.emitter.channel
+      this.emitter.channel,
     );
     const result = await this.emitter.pool.query(
       `INSERT INTO ${this.emitter.tableName} (payload) VALUES ($1) RETURNING id;`,
-      [payload]
+      [payload],
     );
     const attachmentId = result.rows[0].id;
     const headerPayload = JSON.stringify({
@@ -407,7 +408,7 @@ export class BroadcastOperator<
       attachmentId,
     });
     this.emitter.pool.query(
-      `NOTIFY "${this.emitter.channel}", '${headerPayload}'`
+      `NOTIFY "${this.emitter.channel}", '${headerPayload}'`,
     );
   }
 
@@ -422,7 +423,7 @@ export class BroadcastOperator<
     ...args: EventParams<EmitEvents, Ev>
   ): true {
     if (RESERVED_EVENTS.has(ev)) {
-      throw new Error(`"${ev}" is a reserved event name`);
+      throw new Error(`"${String(ev)}" is a reserved event name`);
     }
 
     // set up packet object

packages/socket.io-postgres-emitter/lib/index.ts

@@ -22,7 +22,7 @@ export type EventNames<Map extends EventsMap> = keyof Map & (string | symbol);
 /** The tuple type representing the parameters of an event listener */
 export type EventParams<
   Map extends EventsMap,
-  Ev extends EventNames<Map>
+  Ev extends EventNames<Map>,
 > = Parameters<Map[Ev]>;
 
 /**

packages/socket.io-postgres-emitter/lib/typed-events.ts

@@ -37,7 +37,7 @@ describe("@socket.io/postgres-emitter", () => {
           payload     bytea
       );
     `,
-      () => {}
+      () => {},
     );
 
     emitter = new Emitter(pool);