deno fmt (lol)

Author: saragee3

client-module.js

@@ -1,3 +1,3 @@
-import SocketClient from "./client.js"
+import SocketClient from "./client.js";
 
 export { SocketClient };

client.js

@@ -103,7 +103,7 @@ class SocketClient {
   _reconnectSuccessful(previousId) {
     this.reconnectCount += 1;
     // server can react if needed to this connection id
-    this.to('reconnect', {
+    this.to("reconnect", {
       previousId,
       id: this.connection.id,
       reconnectCount: this.reconnectCount,
@@ -136,7 +136,7 @@ class SocketClient {
     });
     this.connection.addEventListener("error", (event) => {
       // send error message to server
-      this.to('error', event);
+      this.to("error", event);
     });
     this.connection.addEventListener("close", () => {
       this._connectToSocketServer(true);
@@ -152,9 +152,9 @@ class SocketClient {
    *     information about the Body mixin.
    */
   _handleEncodedMessage(message) {
-    if (typeof message === 'string' && 'ping') {
+    if (typeof message === "string" && "ping") {
       this._pongServer();
-    } else if (typeof message === 'object') {
+    } else if (typeof message === "object") {
       message.arrayBuffer().then((buffer) => {
         const decodedMessage = this.decoder.decode(buffer);
         const parsedMessage = JSON.parse(decodedMessage);
@@ -190,6 +190,6 @@ class SocketClient {
    *     Send pong message to server.
    */
   _pongServer() {
-    this.connection.send('pong')
+    this.connection.send("pong");
   }
 }

src/server.ts

@@ -71,7 +71,10 @@ export default class SocketServer extends EventEmitter {
    *
    * @return Promise<DenoServer>
    */
-  public async run(options: HTTPOptions, transmitterOptions: any = {}): Promise<DenoServer> {
+  public async run(
+    options: HTTPOptions,
+    transmitterOptions: any = {},
+  ): Promise<DenoServer> {
     if (options.hostname) {
       this.hostname = options.hostname;
     }
@@ -103,20 +106,30 @@ export default class SocketServer extends EventEmitter {
 
             try {
               for await (const ev of socket) {
-                if (ev === 'pong') {
-                  this.transmitter.handleReservedEventNames('pong', clientId, socket);
+                if (ev === "pong") {
+                  this.transmitter.handleReservedEventNames(
+                    "pong",
+                    clientId,
+                    socket,
+                  );
                 } else if (ev instanceof Uint8Array) {
                   await this.transmitter.checkEvent(ev, clientId);
                 } else if (isWebSocketCloseEvent(ev)) {
                   await super.removeClient(clientId);
-                  this.transmitter.handleReservedEventNames("disconnect", clientId);
+                  this.transmitter.handleReservedEventNames(
+                    "disconnect",
+                    clientId,
+                  );
                 }
               }
             } catch (e) {
               if (!socket.isClosed) {
                 await socket.close(1000).catch(console.error);
                 await super.removeClient(clientId);
-                this.transmitter.handleReservedEventNames("disconnect", clientId);
+                this.transmitter.handleReservedEventNames(
+                  "disconnect",
+                  clientId,
+                );
               }
             }
           })

src/transmitter.ts

@@ -2,7 +2,6 @@ import { MESSAGE_TYPE } from "./io_types.ts";
 import { RESERVED_EVENT_NAMES } from "./reserved_event_names.ts";
 
 export default class Transmitter {
-
   /**
    * @description
    *     A property to determine number of ms to wait for a pong event before closing a client connection.
@@ -28,7 +27,7 @@ export default class Transmitter {
   // FILE MARKER - CONSTRUCTOR /////////////////////////////////////////////////
 
   constructor(server: any, options: any = {}) {
-    if ('reconnect' in options) {
+    if ("reconnect" in options) {
       this.reconnect = options.reconnect;
     }
 
@@ -87,7 +86,11 @@ export default class Transmitter {
    *
    * @return void
    */
-  public handleReservedEventNames(eventName: string, clientId: number, socket?: any): void {
+  public handleReservedEventNames(
+    eventName: string,
+    clientId: number,
+    socket?: any,
+  ): void {
     switch (eventName) {
       case "connection":
       case "disconnect":
@@ -98,8 +101,8 @@ export default class Transmitter {
         }
         break;
       case "reconnect":
-          // do something on an reconnect event
-          // could be useful to add a flag to this client
+        // do something on an reconnect event
+        // could be useful to add a flag to this client
         break;
       case "pong":
         if (!this.server.clients[clientId]) {
@@ -111,7 +114,7 @@ export default class Transmitter {
         break;
       case "error":
         // do something when client errors
-      break;
+        break;
       default:
         this.server.addListener(eventName, clientId);
         break;
@@ -162,7 +165,7 @@ export default class Transmitter {
     if (this.server.clients[clientId]) {
       const client = this.server.clients[clientId];
       if (client.pong_received) {
-        client.socket.send('ping');
+        client.socket.send("ping");
         client.pong_received = false;
       } else {
         setTimeout(() => this._timeoutPing(clientId), this.pingTimeout);