prettier

Author: Septias

backend/instance.ts

@@ -134,10 +134,7 @@ export class Instances {
           instance.webXdc.sendRealtimeData(parsed.data);
         } else if (isSetRealtimeListenerMessage(parsed)) {
           instance.webXdc.connectRealtime((data) => {
-            return broadcast(
-              wss,
-              JSON.stringify({ type: "realtime", data }),
-            );
+            return broadcast(wss, JSON.stringify({ type: "realtime", data }));
           });
         } else if (isSetUpdateListenerMessage(parsed)) {
           instance.webXdc.connect(

backend/message.test.ts

@@ -62,18 +62,22 @@ test("Send realtime", () => {
   const client0Heard: string[] = [];
   const client1Heard: string[] = [];
 
-  const decoder = new TextDecoder()
-  client0.connectRealtime((data) => { client0Heard.push(decoder.decode(data)); return true })
-  client1.connectRealtime((data) => { client1Heard.push(decoder.decode(data)); return true })
+  const decoder = new TextDecoder();
+  client0.connectRealtime((data) => {
+    client0Heard.push(decoder.decode(data));
+    return true;
+  });
+  client1.connectRealtime((data) => {
+    client1Heard.push(decoder.decode(data));
+    return true;
+  });
 
-  const encoder = new TextEncoder()
+  const encoder = new TextEncoder();
 
-  client0.sendRealtimeData(new Uint8Array(encoder.encode("hi")))
+  client0.sendRealtimeData(new Uint8Array(encoder.encode("hi")));
 
-  expect(client1Heard).toMatchObject([
-    "hi"
-  ])
-  expect(client0Heard).toMatchObject([])
+  expect(client1Heard).toMatchObject(["hi"]);
+  expect(client0Heard).toMatchObject([]);
 });
 
 test("distribute to self and other", () => {

backend/message.ts

@@ -51,7 +51,7 @@ class Client implements WebXdcMulti {
     this.processor.distribute(this.id, update);
   }
 
-  sendRealtimeData(data: Uint8Array){
+  sendRealtimeData(data: Uint8Array) {
     this.processor.distributeRealtime(this.id, data);
   }
 

sim/create.ts

@@ -1,4 +1,8 @@
-import { Webxdc, ReceivedStatusUpdate, RealtimeListener as WebxdcRealtimeListener } from "@webxdc/types";
+import {
+  Webxdc,
+  ReceivedStatusUpdate,
+  RealtimeListener as WebxdcRealtimeListener,
+} from "@webxdc/types";
 type UpdatesMessage = {
   type: "updates";
   updates: ReceivedStatusUpdate<any>[];
@@ -54,13 +58,13 @@ type Log = (...args: any[]) => void;
 
 export class RealtimeListener implements WebxdcRealtimeListener {
   private trashed = false;
-  private listener: (data: Uint8Array) => void = () => { };
+  private listener: (data: Uint8Array) => void = () => {};
 
   constructor(
-    public sendHook: (data: Uint8Array) => void = () => { },
-    public setListenerHook: () => void = () => { },
-    private leaveHook: () => void = () => { },
-  ) { }
+    public sendHook: (data: Uint8Array) => void = () => {},
+    public setListenerHook: () => void = () => {},
+    private leaveHook: () => void = () => {},
+  ) {}
 
   is_trashed(): boolean {
     return this.trashed;
@@ -95,7 +99,7 @@ export class RealtimeListener implements WebxdcRealtimeListener {
 
 export function createWebXdc(
   transport: Transport,
-  log: Log = () => { },
+  log: Log = () => {},
 ): Webxdc<any> {
   let resolveUpdateListenerPromise: (() => void) | null = null;
   let realtime: RealtimeListener | null = null;
@@ -118,7 +122,7 @@ export function createWebXdc(
           }
         } else if (isRealtimeMessage(message)) {
           if (realtime === null) {
-            return
+            return;
           }
           // Conversion to any because the actual data is a dict representation of Uint8Array
           // This is due to JSON.stringify conversion.
@@ -201,11 +205,13 @@ export function createWebXdc(
           );
         }
       }
-      const msg = `The app would now close and the user would select a chat to send this message:\nText: ${content.text ? `"${content.text}"` : "No Text"
-        }\nFile: ${content.file
+      const msg = `The app would now close and the user would select a chat to send this message:\nText: ${
+        content.text ? `"${content.text}"` : "No Text"
+      }\nFile: ${
+        content.file
           ? `${content.file.name} - ${base64Content.length} bytes`
           : "No File"
-        }`;
+      }`;
       if (content.file) {
         const confirmed = confirm(
           msg + "\n\nDownload the file in the browser instead?",
@@ -250,46 +256,48 @@ export function createWebXdc(
 
     joinRealtimeChannel: () => {
       if (!transport.hasMessageListener()) {
-        // we can only have one message listener with the current implementation, 
+        // we can only have one message listener with the current implementation,
         // so we need to set it here to receive realtime data. When `setUpdateListener`
-        // is called, the callback is overwritten but the new value also looks for 
+        // is called, the callback is overwritten but the new value also looks for
         // realtime data.
         transport.onMessage((message) => {
           if (isRealtimeMessage(message)) {
             if (realtime === null) {
-              return
+              return;
             }
-            realtime!.receive(new Uint8Array(Object.values(message.data as any)));
+            realtime!.receive(
+              new Uint8Array(Object.values(message.data as any)),
+            );
           }
-        })
+        });
       }
-      let should_create = false
+      let should_create = false;
       realtime = new RealtimeListener(
-        () => { },
+        () => {},
         () => {
-          should_create = true
+          should_create = true;
         },
         () => {
-          should_create = false
-          realtime = null
+          should_create = false;
+          realtime = null;
         },
       );
       transport.onConnect(() => {
         if (!realtime) {
-          return
+          return;
         }
-        
+
         if (should_create) {
           transport.send({ type: "setRealtimeListener" });
         }
-        
+
         realtime.sendHook = (data) => {
           transport.send({ type: "sendRealtime", data });
           log("send realtime", { data });
         };
         realtime.setListenerHook = () => {
           transport.send({ type: "setRealtimeListener" });
-        }
+        };
       });
       return realtime;
     },

sim/webxdc.test.ts

@@ -33,15 +33,14 @@ class FakeTransport implements Transport {
       this.client.sendRealtimeData(data.data);
     } else if (data.type === "setRealtimeListener") {
       this.client.connectRealtime((data) => {
-          if (this.messageCallback != null) {
-            this.messageCallback({
-              type: "realtime",
-              data
-            });
-          }
-          return true;
-      })    
-  
+        if (this.messageCallback != null) {
+          this.messageCallback({
+            type: "realtime",
+            data,
+          });
+        }
+        return true;
+      });
     } else if (data.type === "setUpdateListener") {
       this.client.connect(
         (updates) => {

sim/webxdc.ts

@@ -40,9 +40,9 @@ export class DevServerTransport implements Transport {
 
     this.socket.addEventListener("message", listener);
   }
-  
-  hasMessageListener(){
-    return this.messageListener !== null
+
+  hasMessageListener() {
+    return this.messageListener !== null;
   }
 
   onConnect(callback: TransportConnectCallback): void {