client (browser) emitting events to server

dist/events.js

@@ -9,6 +9,7 @@ const warnAboutMemoryLeak = (eventName, count) =>
 export default class EventEmitter {
   constructor() {
     this.events = new Map();
+    this.globalListeners = new Set();
     this.maxListenersCount = 10;
   }
 
@@ -33,6 +34,16 @@ export default class EventEmitter {
     }
   }
 
+  onAny(fn) {
+    const tooManyListeners = this.globalListeners.size > this.maxListenersCount;
+    if (tooManyListeners) warnAboutMemoryLeak('*', this.globalListeners.size);
+    this.globalListeners.add(fn);
+  }
+
+  clearGlobalListeners() {
+    this.globalListeners.clear();
+  }
+
   once(name, fn) {
     const dispose = (...args) => {
       this.remove(name, dispose);
@@ -43,10 +54,13 @@ export default class EventEmitter {
 
   emit(name, ...args) {
     const event = this.events.get(name);
-    if (!event) return;
+    if (!event && !this.globalListeners.size) return;
     for (const fn of event.values()) {
       fn(...args);
     }
+    for (const fn of this.globalListeners.values()) {
+      fn(name, ...args);
+    }
   }
 
   remove(name, fn) {

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.onAny((eventName, data) => {
+        const target = `${interfaceName}/${eventName}`;
+        const packet = { event: ++this.eventId, [target]: data };
+        this.send(JSON.stringify(packet));
+      });
       this.api[interfaceName] = methods;
     }
   }