Add JsonRpc notification support

src/mopidy.js

@@ -196,6 +196,8 @@ class Mopidy extends EventEmitter {
         this._handleResponse(data);
       } else if (Object.hasOwnProperty.call(data, "event")) {
         this._handleEvent(data);
+      } else if (Object.hasOwnProperty.call(data, "method")) {
+        this._handleJsonRpcNotification(data);
       } else {
         this._console.warn(
           `Unknown message type received. Message was: ${message.data}`
@@ -251,6 +253,12 @@ class Mopidy extends EventEmitter {
     this.emit(eventName, data);
   }
 
+  _handleJsonRpcNotification(notificaiton) {
+    const eventName = `event:${snakeToCamel(notificaiton.method)}`;
+    this.emit("event", eventName, notificaiton.params);
+    this.emit(eventName, notificaiton.params);
+  }
+
   _getApiSpec() {
     return this._send({ method: "core.describe" })
       .then(this._createApi.bind(this))

test/mopidy.test.js

@@ -788,6 +788,38 @@
   });
 });
 
+describe("._handleJsonRpcNotification", () => {
+  test("emits all server side events on 'event' event", () => {
+    const spy = jest.fn();
+    this.mopidy.on("event", spy);
+    const track = {};
+    const message = {
+      jsonrpc: "2.0",
+      method: "track_playback_started",
+      params:{track},
+    };
+
+    this.mopidy._handleJsonRpcNotification(message);
+
+    expect(spy).toBeCalledWith("event:trackPlaybackStarted", { track });
+  });
+
+  test("emits server side events on 'event:*' events", () => {
+    const spy = jest.fn();
+    this.mopidy.on("event:trackPlaybackStarted", spy);
+    const track = {};
+    const message = {
+      jsonrpc: "2.0",
+      method: "track_playback_started",
+      params:{track},
+    };
+
+    this.mopidy._handleJsonRpcNotification(message);
+
+    expect(spy).toBeCalledWith({ track });
+  });
+});
+
 describe("._getApiSpec", () => {
   test("is called on 'websocket:open' event", () => {
     const spy = jest.spyOn(this.mopidy, "_getApiSpec");