chore: debug broadcastMessage on prod

fastrodev · Dec 7, 2024 · c95f3da · c95f3da
1 parent e1afc11
commit c95f3da
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/core/server/mod.ts b/core/server/mod.ts
@@ -84,11 +84,9 @@ export default class Server implements Fastro {
     this.serverOptions = options ?? {};
     this.#handler = this.#createHandler();
     this.#addPropsEndpoint();
+    this.#nonce = ulid();
   }
   getNonce(): string {
-    if (this.#nonce === "") {
-      this.#nonce = ulid();
-    }
     return this.#nonce;
   }
   get(

diff --git a/modules/socket/mod.ts b/modules/socket/mod.ts
@@ -25,7 +25,7 @@ export default function socketModule(s: Fastro) {
     for (const key in entries) {
       const [, { socket }] = entries[key];
       if (socket.readyState === WebSocket.OPEN) {
-        console.log("s.getNonce:", s.getNonce());
+        // console.log("s.getNonce:", s.getNonce());
         socket.send(message);
       } else {
         socket.close();
@@ -38,6 +38,7 @@ export default function socketModule(s: Fastro) {
     socket: WebSocket,
   ) {
     connected.set(data.user, { data, socket });
+    console.log(`connected ${s.getNonce()}:`, connected);
     const entries = connected.entries().toArray();
     const cc = Array.from(entries).map(([, { data }]) => ({
       username: data.username,
@@ -48,7 +49,7 @@ export default function socketModule(s: Fastro) {
     for (const key in entries) {
       const [, { socket }] = entries[key];
       if (socket.readyState === WebSocket.OPEN) {
-        console.log("s.getNonce:", s.getNonce());
+        // console.log("s.getNonce:", s.getNonce());
         socket.send(JSON.stringify(cc));
       } else {
         socket.close();