make prettier happier

Author: jokester

packages/engine.io/lib/engine.io.ts

@@ -4,7 +4,12 @@ import transports from "./transports/index";
 import * as parser from "engine.io-parser";
 
 export { Server, transports, listen, attach, parser };
-export type { AttachOptions, ServerOptions, BaseServer, ErrorCallback } from "./server";
+export type {
+  AttachOptions,
+  ServerOptions,
+  BaseServer,
+  ErrorCallback,
+} from "./server";
 export { uServer } from "./userver";
 export { Socket } from "./socket";
 export { Transport } from "./transport";
@@ -51,7 +56,10 @@ function listen(
  * @return engine.io server
  */
 
-function attach(server: HttpServer, options: AttachOptions & ServerOptions): Server {
+function attach(
+  server: HttpServer,
+  options: AttachOptions & ServerOptions,
+): Server {
   const engine = new Server(options);
   engine.attach(server, options);
   return engine;

packages/engine.io/lib/server.ts

@@ -609,7 +609,10 @@ export abstract class BaseServer extends EventEmitter {
     }
   }
 
-  protected abstract createTransport(transportName: Transport, req: EngineRequest);
+  protected abstract createTransport(
+    transportName: Transport,
+    req: EngineRequest,
+  );
 
   /**
    * Protocol errors mappings.
@@ -879,7 +882,7 @@ export class Server extends BaseServer {
 
         const transport: TransportImpl = this.createTransport(
           req._query.transport as Transport,
-          req
+          req,
         );
         // @ts-expect-error this option is only for WebSocket impl
         transport.perMessageDeflate = this.opts.perMessageDeflate;

packages/engine.io/lib/socket.ts

@@ -538,7 +538,9 @@ export class Socket extends EventEmitter {
    */
   private getAvailableUpgrades() {
     const availableUpgrades = [];
-    const allUpgrades = this.server.upgrades(this.transport.name as keyof typeof transports);
+    const allUpgrades = this.server.upgrades(
+      this.transport.name as keyof typeof transports,
+    );
     for (let i = 0; i < allUpgrades.length; ++i) {
       const upg = allUpgrades[i] as keyof typeof transports;
       if (this.server.opts.transports.indexOf(upg) !== -1) {

packages/engine.io/lib/transports-uws/polling.ts

@@ -273,7 +273,11 @@ export class Polling extends Transport {
     };
 
     if (this.protocol === 3) {
-      (this.parser as typeof parser_v3).encodePayload(packets, this.supportsBinary, doWrite);
+      (this.parser as typeof parser_v3).encodePayload(
+        packets,
+        this.supportsBinary,
+        doWrite,
+      );
     } else {
       (this.parser as typeof parser_v4).encodePayload(packets, doWrite);
     }

packages/engine.io/lib/transports/polling.ts

@@ -235,7 +235,11 @@ export class Polling extends Transport {
     };
 
     if (this.protocol === 3) {
-      (this.parser as typeof parser_v3).encodePayload(packets, this.supportsBinary, doWrite);
+      (this.parser as typeof parser_v3).encodePayload(
+        packets,
+        this.supportsBinary,
+        doWrite,
+      );
     } else {
       (this.parser as typeof parser_v4).encodePayload(packets, doWrite);
     }

packages/engine.io/lib/transports/websocket.ts

@@ -1,7 +1,7 @@
 import { EngineRequest, Transport } from "../transport";
 import debugModule from "debug";
 import type { Packet, RawData } from "engine.io-parser";
-import type { PerMessageDeflateOptions, WebSocket as WsWebSocket } from 'ws';
+import type { PerMessageDeflateOptions, WebSocket as WsWebSocket } from "ws";
 
 const debug = debugModule("engine:ws");
 

packages/engine.io/lib/userver.ts

@@ -125,7 +125,7 @@ export class uServer extends BaseServer {
     req: HttpRequest & { res: any; _query: any },
   ) {
     debug('handling "%s" http request "%s"', req.getMethod(), req.getUrl());
-    this.prepare(req as unknown as (HttpRequest & EngineRequest), res);
+    this.prepare(req as unknown as HttpRequest & EngineRequest, res);
 
     req.res = res;
 
@@ -148,15 +148,23 @@ export class uServer extends BaseServer {
       } else {
         const closeConnection = (errorCode, errorContext) =>
           this.abortRequest(res, errorCode, errorContext);
-        this.handshake(req._query.transport, req as unknown as EngineRequest, closeConnection);
+        this.handshake(
+          req._query.transport,
+          req as unknown as EngineRequest,
+          closeConnection,
+        );
       }
     };
 
     this._applyMiddlewares(req, res, (err) => {
       if (err) {
         callback(Server.errors.BAD_REQUEST, { name: "MIDDLEWARE_FAILURE" });
       } else {
-        this.verify(req as unknown as (HttpRequest & EngineRequest), false, callback);
+        this.verify(
+          req as unknown as HttpRequest & EngineRequest,
+          false,
+          callback,
+        );
       }
     });
   }
@@ -168,7 +176,7 @@ export class uServer extends BaseServer {
   ) {
     debug("on upgrade");
 
-    this.prepare(req as unknown as (HttpRequest & EngineRequest),  res);
+    this.prepare(req as unknown as HttpRequest & EngineRequest, res);
 
     req.res = res;
 
@@ -200,7 +208,10 @@ export class uServer extends BaseServer {
           return res.close();
         } else {
           debug("upgrading existing transport");
-          transport = this.createTransport(req._query.transport, req as unknown as EngineRequest);
+          transport = this.createTransport(
+            req._query.transport,
+            req as unknown as EngineRequest,
+          );
           client._maybeUpgrade(transport);
         }
       } else {
@@ -241,7 +252,7 @@ export class uServer extends BaseServer {
   private abortRequest(
     res: HttpResponse | ResponseWrapper,
     errorCode: number,
-    errorContext?: {message?: string},
+    errorContext?: { message?: string },
   ) {
     const statusCode =
       errorCode === Server.errors.FORBIDDEN

packages/socket.io-cluster-engine/lib/engine.ts

@@ -1,4 +1,10 @@
-import { Server, type ServerOptions, type ErrorCallback, Socket, type Transport } from "engine.io";
+import {
+  Server,
+  type ServerOptions,
+  type ErrorCallback,
+  Socket,
+  type Transport,
+} from "engine.io";
 import { randomBytes } from "node:crypto";
 import { setTimeout, clearTimeout } from "node:timers";
 import { type IncomingMessage } from "node:http";
@@ -392,7 +398,7 @@ export abstract class ClusterEngine extends Server {
   override verify(
     req: IncomingMessage & { _query: Record<string, string> },
     upgrade: boolean,
-    fn: ErrorCallback
+    fn: ErrorCallback,
   ): void {
     super.verify(req, upgrade, (errorCode, errorContext) => {
       if (errorCode !== Server.errors.UNKNOWN_SID) {