fix: broadcastBrowser defaults to true

CoCreate-app · Oct 19, 2023 · 4ea5a08 · 4ea5a08
1 parent 238ba86
commit 4ea5a08
Showing 1 changed file with 10 additions and 11 deletions.
diff --git a/src/index.js b/src/index.js
@@ -248,15 +248,15 @@
                         if (message && message.uid) {
                             if (isBrowser) {
                                 var event = new window.CustomEvent(message.uid, {
-                                    detail: data
+                                    detail: message
                                 });
                                 window.dispatchEvent(event);
                             } else {
                                 process.emit(message.uid, message);
                             }
                         }
 
-                        self.__fireListeners(message.method, message)
+                        self.__fireListeners(message)
                     } catch (e) {
                         console.log(e);
                     }
@@ -265,11 +265,8 @@
             }
         },
 
-        __fireListeners(action, data) {
-            const listeners = this.listeners.get(action);
-            if (!listeners) {
-                return;
-            }
+        __fireListeners(data) {
+            const listeners = this.listeners.get(data.method) || [];
             listeners.forEach(listener => {
                 listener(data);
             });
@@ -349,10 +346,12 @@
                     delete data.room;
 
                 let broadcastBrowser = false
-                if (data['broadcastBrowser'] && data['broadcastBrowser'] !== 'false') {
+                if (data['broadcastBrowser'] === 'false' && data['broadcastBrowser'] === false)
+                    broadcastBrowser = false;
+                else
                     broadcastBrowser = true;
-                    delete data['broadcastBrowser']
-                }
+
+                delete data['broadcastBrowser']
 
                 const uid = data['uid'];
                 const sockets = await this.getSockets(data);
@@ -507,7 +506,7 @@
         },
 
         sendLocalMessage(data) {
-            this.__fireListeners(data.method, data)
+            this.__fireListeners(data)
         },
 
         // TODO: add to ObjectId function