allow to subscribe for any schema event

mr-rpc-methods.js

@@ -71,16 +71,8 @@ var expose = function (model, schema, opts) {
   const subscribers = {}
 
   evNames.forEach(function (evName) {
-    subscribers[evName] = new Set()
     const modelSynchronization = modelSyncFactory(evName)
     schema.on(evName, function (doc) {
-      Array.from(subscribers[evName]).forEach((socket) => {
-        socket.emit('schemaEvent', {
-          modelName: modelName,
-          evName: evName,
-          doc: doc
-        })
-      })
       modelSynchronization(doc)
     })
   })
@@ -505,7 +497,16 @@ var expose = function (model, schema, opts) {
       subscribe: function (evName) {
         const socket = this
         if (!subscribers.hasOwnProperty(evName)) {
-          throw new Error(`event ${evName} does not exist`)
+          subscribers[evName] = new Set()
+          schema.on(evName, (doc) => {
+            Array.from(subscribers[evName]).forEach((socket) => {
+              socket.emit('schemaEvent', {
+                modelName: modelName,
+                evName: evName,
+                doc: doc
+              })
+            })
+          })
         }
         opts.checkPermission(this, 'read')
         const subscribersForThisEvent = subscribers[evName]

package.json

@@ -1,6 +1,6 @@
 {
   "name": "moonridge",
-  "version": "0.9.25",
+  "version": "0.9.26",
   "main": "moonridge.js",
   "author": "Capaj <capajj@gmail.com>",
   "description": "Isomorphic library, which allows you to use Mongoose.js models via socket.io-rpc doing regular queries and liveQueries",

test/mr-rpc-methods.spec.js

@@ -22,11 +22,15 @@ describe('rpc methods', function () {
     })
     exposeCb(fakeRpcInstance)
   })
-  it('should expose a query/liveQuery method which runs middlewares on built queries', function () {
+  it.skip('should expose a query/liveQuery method which runs middlewares on built queries', function () {
     // TODO
   })
 
-  it('should delete a listener when socket disconnects', function () {
+  it.skip('should delete a listener when socket disconnects', function () {
     // TODO
   })
+
+  it.skip('should subscribe to any schema event', function () {
+
+  })
 })