chore: lint and clean code

kuzzleio · Nov 20, 2024 · 12c1c1f · 12c1c1f
1 parent f278340
commit 12c1c1f
Showing 1 changed file with 30 additions and 29 deletions.
diff --git a/src/protocols/WebSocket.ts b/src/protocols/WebSocket.ts
@@ -243,9 +243,11 @@ export default class WebSocketProtocol extends BaseProtocolRealtime {
    * @param {Object} payload
    */
   send(request: RequestPayload, options: JSONObject = {}) {
-    if (this.maxPayloadSize !== null && Buffer.byteLength(JSON.stringify(request), 'utf8') > this.maxPayloadSize) {
-
-      const error: any= new Error(
+    if (
+      this.maxPayloadSize !== null &&
+      Buffer.byteLength(JSON.stringify(request), "utf8") > this.maxPayloadSize
+    ) {
+      const error: any = new Error(
         `Payload size exceeded the maximum allowed by the server ${this.maxPayloadSize} bytes`
       );
 
@@ -379,35 +381,34 @@ export default class WebSocketProtocol extends BaseProtocolRealtime {
   /**
    * Get the maximum payload size allowed by the server
    * Stores the value in `this.maxPayloadSize`
-  **/
+   **/
   async getMaxPayloadSize() {
     return new Promise((resolve, reject) => {
-        const originalOnMessage = this.client.onmessage;
-        this.client.onmessage = (payload) => {
-            try {
-                const data = JSON.parse(payload.data || payload);
-
-                // Check if the message corresponds to the `getMaxPayloadSize` response
-                if (data.result && data.result.server && data.result.server.maxRequestSize) {
-                    this.maxPayloadSize = parseSize(data.result.server.maxRequestSize);
-
-                    // Restore the original `onmessage` handler
-                    this.client.onmessage = originalOnMessage;
-                    resolve(this.maxPayloadSize);
-                    return;
-                }
-
-                // If not related to `getMaxPayloadSize`, pass to the original handler
-                if (originalOnMessage) {
-                    originalOnMessage(payload);
-                }
-            } catch (error) {
-                reject(error);
-            }
-        };
+      const originalOnMessage = this.client.onmessage;
+      this.client.onmessage = (payload) => {
+        try {
+          const data = JSON.parse(payload.data || payload);
+
+          // Check if the message corresponds to the `getMaxPayloadSize` response
+          if (
+            data.result &&
+            data.result.server &&
+            data.result.server.maxRequestSize
+          ) {
+            this.maxPayloadSize = parseSize(data.result.server.maxRequestSize);
+
+            // Restore the original `onmessage` handler
+            this.client.onmessage = originalOnMessage;
+            resolve(this.maxPayloadSize);
+            return;
+          }
+        } catch (error) {
+          reject(error);
+        }
+      };
 
-        // Send the request
-        this.send({ controller: "server", action: "getConfig" });
+      // Send the request
+      this.send({ action: "getConfig", controller: "server" });
     });
   }
 }