apply same prettier config

.prettierrc.json

@@ -0,0 +1,3 @@
+{
+  "trailingComma": "es5"
+}

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

@@ -379,8 +379,8 @@ export class SocketWithoutUpgrade extends Emitter<
       (typeof location !== "undefined" && location.port
         ? location.port
         : this.secure
-        ? "443"
-        : "80");
+          ? "443"
+          : "80");
 
     this.transports = [];
     this._transportsByName = {};

packages/engine.io-parser/lib/decodePacket.browser.ts

@@ -11,7 +11,7 @@ const withNativeArrayBuffer = typeof ArrayBuffer === "function";
 
 export const decodePacket = (
   encodedPacket: RawData,
-  binaryType?: BinaryType,
+  binaryType?: BinaryType
 ): Packet => {
   if (typeof encodedPacket !== "string") {
     return {

packages/engine.io-parser/lib/decodePacket.ts

@@ -8,7 +8,7 @@ import {
 
 export const decodePacket = (
   encodedPacket: RawData,
-  binaryType?: BinaryType,
+  binaryType?: BinaryType
 ): Packet => {
   if (typeof encodedPacket !== "string") {
     return {
@@ -47,7 +47,7 @@ const mapBinary = (data: RawData, binaryType?: BinaryType) => {
         // from HTTP long-polling
         return data.buffer.slice(
           data.byteOffset,
-          data.byteOffset + data.byteLength,
+          data.byteOffset + data.byteLength
         );
       } else {
         // from WebTransport (Uint8Array)

packages/engine.io-parser/lib/encodePacket.browser.ts

@@ -16,7 +16,7 @@ const isView = (obj) => {
 const encodePacket = (
   { type, data }: Packet,
   supportsBinary: boolean,
-  callback: (encodedPacket: RawData) => void,
+  callback: (encodedPacket: RawData) => void
 ) => {
   if (withNativeBlob && data instanceof Blob) {
     if (supportsBinary) {
@@ -40,7 +40,7 @@ const encodePacket = (
 
 const encodeBlobAsBase64 = (
   data: Blob,
-  callback: (encodedPacket: RawData) => void,
+  callback: (encodedPacket: RawData) => void
 ) => {
   const fileReader = new FileReader();
   fileReader.onload = function () {
@@ -64,7 +64,7 @@ let TEXT_ENCODER;
 
 export function encodePacketToBinary(
   packet: Packet,
-  callback: (encodedPacket: RawData) => void,
+  callback: (encodedPacket: RawData) => void
 ) {
   if (withNativeBlob && packet.data instanceof Blob) {
     return packet.data.arrayBuffer().then(toArray).then(callback);

packages/engine.io-parser/lib/encodePacket.ts

@@ -3,11 +3,11 @@ import { PACKET_TYPES, Packet, RawData } from "./commons.js";
 export const encodePacket = (
   { type, data }: Packet,
   supportsBinary: boolean,
-  callback: (encodedPacket: RawData) => void,
+  callback: (encodedPacket: RawData) => void
 ) => {
   if (data instanceof ArrayBuffer || ArrayBuffer.isView(data)) {
     return callback(
-      supportsBinary ? data : "b" + toBuffer(data, true).toString("base64"),
+      supportsBinary ? data : "b" + toBuffer(data, true).toString("base64")
     );
   }
   // plain string
@@ -31,7 +31,7 @@ let TEXT_ENCODER;
 
 export function encodePacketToBinary(
   packet: Packet,
-  callback: (encodedPacket: RawData) => void,
+  callback: (encodedPacket: RawData) => void
 ) {
   if (packet.data instanceof ArrayBuffer || ArrayBuffer.isView(packet.data)) {
     return callback(toBuffer(packet.data, false));

packages/engine.io-parser/lib/index.ts

@@ -12,7 +12,7 @@ const SEPARATOR = String.fromCharCode(30); // see https://en.wikipedia.org/wiki/
 
 const encodePayload = (
   packets: Packet[],
-  callback: (encodedPayload: string) => void,
+  callback: (encodedPayload: string) => void
 ) => {
   // some packets may be added to the array while encoding, so the initial length must be saved
   const length = packets.length;
@@ -32,7 +32,7 @@ const encodePayload = (
 
 const decodePayload = (
   encodedPayload: string,
-  binaryType?: BinaryType,
+  binaryType?: BinaryType
 ): Packet[] => {
   const encodedPackets = encodedPayload.split(SEPARATOR);
   const packets = [];
@@ -112,7 +112,7 @@ const enum State {
 
 export function createPacketDecoderStream(
   maxPayload: number,
-  binaryType: BinaryType,
+  binaryType: BinaryType
 ): any {
   if (!TEXT_DECODER) {
     TEXT_DECODER = new TextDecoder();
@@ -148,7 +148,7 @@ export function createPacketDecoderStream(
           expectedLength = new DataView(
             headerArray.buffer,
             headerArray.byteOffset,
-            headerArray.length,
+            headerArray.length
           ).getUint16(0);
           state = State.READ_PAYLOAD;
         } else if (state === State.READ_EXTENDED_LENGTH_64) {
@@ -160,7 +160,7 @@ export function createPacketDecoderStream(
           const view = new DataView(
             headerArray.buffer,
             headerArray.byteOffset,
-            headerArray.length,
+            headerArray.length
           );
 
           const n = view.getUint32(0);
@@ -181,8 +181,8 @@ export function createPacketDecoderStream(
           controller.enqueue(
             decodePacket(
               isBinary ? data : TEXT_DECODER.decode(data),
-              binaryType,
-            ),
+              binaryType
+            )
           );
           state = State.READ_HEADER;
         }

packages/engine.io-parser/test/index.ts

@@ -176,7 +176,7 @@ describe("engine.io-parser", () => {
 
         const header = await reader.read();
         expect(header.value).to.eql(
-          Uint8Array.of(255, 0, 0, 0, 0, 7, 91, 205, 21),
+          Uint8Array.of(255, 0, 0, 0, 0, 7, 91, 205, 21)
         );
 
         const payload = await reader.read();

packages/engine.io/lib/server.ts

@@ -632,7 +632,10 @@ export abstract class BaseServer extends EventEmitter {
  * @see https://nodejs.org/api/http.html#class-httpserverresponse
  */
 class WebSocketResponse {
-  constructor(readonly req, readonly socket: Duplex) {
+  constructor(
+    readonly req,
+    readonly socket: Duplex
+  ) {
     // temporarily store the response headers on the req object (see the "headers" event)
     req[kResponseHeaders] = {};
   }

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

@@ -10,7 +10,11 @@ const debug = debugModule("engine:webtransport");
 export class WebTransport extends Transport {
   private readonly writer;
 
-  constructor(private readonly session, stream, reader) {
+  constructor(
+    private readonly session,
+    stream,
+    reader
+  ) {
     super({ _query: { EIO: "4" } });
 
     const transformStream = createPacketEncoderStream();

packages/socket.io-adapter/test/cluster-adapter.ts

@@ -16,7 +16,10 @@ const NODES_COUNT = 3;
 class EventEmitterAdapter extends ClusterAdapterWithHeartbeat {
   private offset = 1;
 
-  constructor(nsp, readonly eventBus) {
+  constructor(
+    nsp,
+    readonly eventBus
+  ) {
     super(nsp, {});
     this.eventBus.on("message", (message) => {
       this.onMessage(message as ClusterMessage);

packages/socket.io-client/lib/index.ts

@@ -25,11 +25,11 @@ const cache: Record<string, Manager> = {};
 function lookup(opts?: Partial<ManagerOptions & SocketOptions>): Socket;
 function lookup(
   uri: string,
-  opts?: Partial<ManagerOptions & SocketOptions>,
+  opts?: Partial<ManagerOptions & SocketOptions>
 ): Socket;
 function lookup(
   uri?: string | Partial<ManagerOptions & SocketOptions>,
-  opts?: Partial<ManagerOptions & SocketOptions>,
+  opts?: Partial<ManagerOptions & SocketOptions>
 ): Socket {
   if (typeof uri === "object") {
     opts = uri;

packages/socket.io-client/lib/manager.ts

@@ -152,11 +152,11 @@ export class Manager<
   constructor(uri?: string, opts?: Partial<ManagerOptions>);
   constructor(
     uri?: string | Partial<ManagerOptions>,
-    opts?: Partial<ManagerOptions>,
+    opts?: Partial<ManagerOptions>
   );
   constructor(
     uri?: string | Partial<ManagerOptions>,
-    opts?: Partial<ManagerOptions>,
+    opts?: Partial<ManagerOptions>
   ) {
     super();
     if (uri && "object" === typeof uri) {
@@ -405,7 +405,7 @@ export class Manager<
       on(socket, "error", this.onerror.bind(this)),
       on(socket, "close", this.onclose.bind(this)),
       // @ts-ignore
-      on(this.decoder, "decoded", this.ondecoded.bind(this)),
+      on(this.decoder, "decoded", this.ondecoded.bind(this))
     );
   }
 

packages/socket.io-client/lib/on.ts

@@ -3,7 +3,7 @@ import { Emitter } from "@socket.io/component-emitter";
 export function on(
   obj: Emitter<any, any>,
   ev: string,
-  fn: (err?: any) => any,
+  fn: (err?: any) => any
 ): VoidFunction {
   obj.on(ev, fn);
   return function subDestroy(): void {

packages/socket.io-client/lib/socket.ts

@@ -116,7 +116,7 @@ interface SocketReservedEvents {
   connect_error: (err: Error) => void;
   disconnect: (
     reason: Socket.DisconnectReason,
-    description?: DisconnectDescription,
+    description?: DisconnectDescription
   ) => void;
 }
 
@@ -554,7 +554,7 @@ export class Socket<
           debug(
             "packet [%d] is discarded after %d tries",
             packet.id,
-            packet.tryCount,
+            packet.tryCount
           );
           this._queue.shift();
           if (ack) {
@@ -591,7 +591,7 @@ export class Socket<
     if (packet.pending && !force) {
       debug(
         "packet [%d] has already been sent and is waiting for an ack",
-        packet.id,
+        packet.id
       );
       return;
     }
@@ -665,7 +665,7 @@ export class Socket<
    */
   private onclose(
     reason: Socket.DisconnectReason,
-    description?: DisconnectDescription,
+    description?: DisconnectDescription
   ): void {
     debug("close (%s)", reason);
     this.connected = false;
@@ -683,7 +683,7 @@ export class Socket<
   private _clearAcks() {
     Object.keys(this.acks).forEach((id) => {
       const isBuffered = this.sendBuffer.some(
-        (packet) => String(packet.id) === id,
+        (packet) => String(packet.id) === id
       );
       if (!isBuffered) {
         // note: handlers that do not accept an error as first argument are ignored here
@@ -716,8 +716,8 @@ export class Socket<
           this.emitReserved(
             "connect_error",
             new Error(
-              "It seems you are trying to reach a Socket.IO server in v2.x with a v3.x client, but they are not compatible (more information here: https://socket.io/docs/v3/migrating-from-2-x-to-3-0/)",
-            ),
+              "It seems you are trying to reach a Socket.IO server in v2.x with a v3.x client, but they are not compatible (more information here: https://socket.io/docs/v3/migrating-from-2-x-to-3-0/)"
+            )
           );
         }
         break;
@@ -967,7 +967,7 @@ export class Socket<
    * @returns self
    */
   public timeout(
-    timeout: number,
+    timeout: number
   ): Socket<ListenEvents, DecorateAcknowledgements<EmitEvents>> {
     this.flags.timeout = timeout;
     return this;

packages/socket.io-client/lib/url.ts

@@ -39,7 +39,7 @@ type ParsedUrl = {
 export function url(
   uri: string | ParsedUrl,
   path: string = "",
-  loc?: Location,
+  loc?: Location
 ): ParsedUrl {
   let obj = uri as ParsedUrl;
 

packages/socket.io-client/test/connection.ts

@@ -576,7 +576,7 @@ describe("connection", () => {
           reconnectionAttempts: 2,
         });
         let delay = Math.floor(
-          manager.reconnectionDelay() * manager.randomizationFactor() * 0.5,
+          manager.reconnectionDelay() * manager.randomizationFactor() * 0.5
         );
         delay = Math.max(delay, 10);
 

packages/socket.io-client/test/socket.ts

@@ -336,7 +336,7 @@ describe("socket", () => {
     const socket = io(BASE_URL + "/no", { forceNew: true });
 
     expect(() => socket.emit("disconnecting", "goodbye")).to.throwException(
-      /"disconnecting" is a reserved event name/,
+      /"disconnecting" is a reserved event name/
     );
   });
 

packages/socket.io-client/test/typed-events.test-d.ts

@@ -92,7 +92,7 @@ describe("typed events", () => {
         const value = await socket.emitWithAck(
           "ackFromClientSingleArg",
           "1",
-          2,
+          2
         );
         expectType<any>(value);
 
@@ -155,12 +155,12 @@ describe("typed events", () => {
       ackFromClient: (
         a: string,
         b: number,
-        ack: (c: string, d: boolean) => void,
+        ack: (c: string, d: boolean) => void
       ) => void;
       ackFromClientSingleArg: (
         a: string,
         b: number,
-        ack: (c: string) => void,
+        ack: (c: string) => void
       ) => void;
       ackFromClientNoArg: (ack: () => void) => void;
     }
@@ -232,7 +232,7 @@ describe("typed events", () => {
         const value = await socket.emitWithAck(
           "ackFromClientSingleArg",
           "1",
-          2,
+          2
         );
         expectType<string>(value);
 

packages/socket.io-client/wdio.conf.js

@@ -79,7 +79,7 @@ if (process.env.CI === "true") {
         {
           appiumVersion: "2.0.0",
         },
-        BASE_SAUCE_OPTIONS,
+        BASE_SAUCE_OPTIONS
       ),
     },
     {
@@ -92,7 +92,7 @@ if (process.env.CI === "true") {
         {
           appiumVersion: "2.0.0",
         },
-        BASE_SAUCE_OPTIONS,
+        BASE_SAUCE_OPTIONS
       ),
     },
   ];

packages/socket.io-cluster-engine/test/in-memory.ts

@@ -7,7 +7,10 @@ import { type ServerOptions } from "engine.io";
 import { url, handshake } from "./util";
 
 class InMemoryEngine extends ClusterEngine {
-  constructor(readonly eventBus: EventEmitter, opts?: ServerOptions) {
+  constructor(
+    readonly eventBus: EventEmitter,
+    opts?: ServerOptions
+  ) {
     super(opts);
     eventBus.on("message", (message) => this.onMessage(message));
   }