Client (browser) emitting events to server

dist/events.js

@@ -9,9 +9,9 @@ const warnAboutMemoryLeak = (eventName, count) =>
 export default class EventEmitter {
   constructor() {
     this.events = new Map();
+    this.events.set('*', new Set());
     this.maxListenersCount = 10;
   }
-
   getMaxListeners() {
     return this.maxListenersCount;
   }
@@ -42,10 +42,20 @@ export default class EventEmitter {
   }
 
   emit(name, ...args) {
+    if (name === '*') {
+      throw new Error('Cannot emit reserved "*" global listeners.');
+    }
     const event = this.events.get(name);
-    if (!event) return;
-    for (const fn of event.values()) {
-      fn(...args);
+    if (event) {
+      for (const fn of event.values()) {
+        fn(...args);
+      }
+    }
+    const globalListeners = this.events.get('*');
+    if (globalListeners.size) {
+      for (const fn of globalListeners.values()) {
+        fn(name, ...args);
+      }
     }
   }
 
@@ -58,7 +68,13 @@ export default class EventEmitter {
   }
 
   clear(name) {
-    if (name) this.events.delete(name);
-    else this.events.clear();
+    const globalListeners = this.events.get(this.globalEventName);
+    if (!name) {
+      this.events.clear();
+      globalListeners.clear();
+      return;
+    }
+    if (name === '*') globalListeners.clear();
+    else this.events.delete(name);
   }
 }

dist/metacom.js

@@ -36,6 +36,7 @@ export class Metacom extends EventEmitter {
     this.calls = new Map();
     this.streams = new Map();
     this.streamId = 0;
+    this.eventId = 0;
     this.active = false;
     this.connected = false;
     this.opening = null;
@@ -157,6 +158,11 @@ export class Metacom extends EventEmitter {
       for (const methodName of methodNames) {
         methods[methodName] = request(methodName);
       }
+      methods.on('*', (eventName, data) => {
+        const target = `${interfaceName}/${eventName}`;
+        const packet = { event: ++this.eventId, [target]: data };
+        this.send(JSON.stringify(packet));
+      });
       this.api[interfaceName] = methods;
     }
   }