lint

Author: darrachequesne

packages/socket.io-postgres-adapter/lib/adapter.ts

@@ -51,7 +51,7 @@ export interface PostgresAdapterOptions {
  */
 export function createAdapter(
   pool: Pool,
-  opts: PostgresAdapterOptions & ClusterAdapterOptions = {}
+  opts: PostgresAdapterOptions & ClusterAdapterOptions = {},
 ) {
   const options = Object.assign(
     {
@@ -61,7 +61,7 @@ export function createAdapter(
       cleanupInterval: 30_000,
       errorHandler: (err: Error) => debug(err),
     },
-    opts
+    opts,
   );
 
   const namespaces = new Map<string, PostgresAdapter>();
@@ -74,7 +74,7 @@ export function createAdapter(
     },
     (msg) => {
       namespaces.get(msg.nsp)?.onMessage(msg);
-    }
+    },
   );
 
   return function (nsp: any) {
@@ -112,7 +112,7 @@ export class PostgresAdapter extends ClusterAdapterWithHeartbeat {
   constructor(
     nsp: any,
     opts: ClusterAdapterOptions,
-    private readonly client: PubSubClient
+    private readonly client: PubSubClient,
   ) {
     super(nsp, opts);
   }
@@ -126,7 +126,7 @@ export class PostgresAdapter extends ClusterAdapterWithHeartbeat {
 
   protected override doPublishResponse(
     _requesterUid: ServerId,
-    response: ClusterResponse
+    response: ClusterResponse,
   ) {
     return this.client.publish(response);
   }

packages/socket.io-postgres-adapter/lib/node-cluster.ts

@@ -15,7 +15,7 @@ function ignoreError() {}
 
 export function setupPrimary(
   pool: Pool,
-  opts: PostgresAdapterOptions & ClusterAdapterOptions = {}
+  opts: PostgresAdapterOptions & ClusterAdapterOptions = {},
 ) {
   if (!cluster.isPrimary) {
     throw "not primary";
@@ -29,7 +29,7 @@ export function setupPrimary(
       cleanupInterval: 30_000,
       errorHandler: (err: Error) => debug(err),
     },
-    opts
+    opts,
   );
 
   const nodeId = randomId();
@@ -45,7 +45,7 @@ export function setupPrimary(
       for (const workerId in cluster.workers) {
         cluster.workers[workerId]?.send(msg, ignoreError);
       }
-    }
+    },
   );
 
   cluster.on("message", async (worker, msg: ClusterMessage) => {

packages/socket.io-postgres-adapter/lib/util.ts

@@ -63,15 +63,15 @@ export class PubSubClient {
     private readonly pool: Pool,
     private readonly opts: Required<PostgresAdapterOptions>,
     private readonly isFromSelf: (msg: ExtendedClusterMessage) => boolean,
-    private readonly onMessage: (msg: ClusterMessage) => void
+    private readonly onMessage: (msg: ClusterMessage) => void,
   ) {
     this.initClient().then(() => {}); // ignore error
 
     this.cleanupTimer = setInterval(async () => {
       try {
         debug("removing old events");
         await pool.query(
-          `DELETE FROM ${opts.tableName} WHERE created_at < now() - interval '${opts.cleanupInterval} milliseconds'`
+          `DELETE FROM ${opts.tableName} WHERE created_at < now() - interval '${opts.cleanupInterval} milliseconds'`,
         );
       } catch (err) {
         opts.errorHandler(err as Error);
@@ -84,7 +84,7 @@ export class PubSubClient {
     debug("reconnection in %d ms", reconnectionDelay);
     this.reconnectTimer = setTimeout(
       () => this.initClient(),
-      reconnectionDelay
+      reconnectionDelay,
     );
   }
 
@@ -97,7 +97,7 @@ export class PubSubClient {
       client.on("notification", async (msg: Notification) => {
         try {
           let message = JSON.parse(
-            msg.payload as string
+            msg.payload as string,
           ) as ExtendedClusterMessage;
 
           if (this.isFromSelf(message)) {
@@ -107,10 +107,10 @@ export class PubSubClient {
           if (message.attachmentId) {
             const result = await this.pool.query(
               `SELECT payload FROM ${this.opts.tableName} WHERE id = $1`,
-              [message.attachmentId]
+              [message.attachmentId],
             );
             const fullMessage = decode(
-              result.rows[0].payload
+              result.rows[0].payload,
             ) as ExtendedClusterMessage;
             this.onMessage(fullMessage);
           } else {
@@ -184,19 +184,19 @@ export class PubSubClient {
   }
 
   private async publishWithAttachment(
-    message: ClusterMessage | ClusterResponse
+    message: ClusterMessage | ClusterResponse,
   ) {
     const payload = encode(message);
     const channel = `${this.opts.channelPrefix}#${message.nsp}`;
 
     debug(
       "sending event of type %s with attachment to channel %s",
       message.type,
-      channel
+      channel,
     );
     const result = await this.pool.query(
       `INSERT INTO ${this.opts.tableName} (payload) VALUES ($1) RETURNING id;`,
-      [payload]
+      [payload],
     );
     const attachmentId = result.rows[0].id;
     const headerPayload = JSON.stringify({