Merge pull request #18 from azuqua/add-subscribe-callback

feat: support subscribe callbacks

Author: richardheng-okta

lib/external.js

@@ -84,7 +84,7 @@ module.exports = {
       clearInterval(this._cleanupTimer);
   },
 
-  subscribe: function(socket, channel){
+  subscribe: function(socket, channel, message){
     if(this.pubsubClient){
       this._debug("Subscribing socket", socket.sid, channel);
       if(!this._channels[channel]){
@@ -95,7 +95,7 @@ module.exports = {
       if(!socket.channels)
         socket.channels = {};
       socket.channels[channel] = true;
-      utils.sync(socket, "subscribe", { channel: channel });
+      utils.sync(socket, "subscribe", Object.assign({}, message, { channel: channel }));
     }
   },
 

lib/rpc.js

@@ -16,7 +16,7 @@ module.exports = function(socket, message, callback){
       if(error || !allowed)
         callback(error || "Forbidden");
       else
-        self.subscribe(socket, message.req.channel);
+        self.subscribe(socket, message.req.channel, message);
     });
     break;
   case "_unsubscribe": 

package.json

@@ -1,7 +1,7 @@
 {
   "name": "node-token-sockjs",
   "description": "A wrapper around express, sockjs-node, and redis that provides token based authentication, a websocket based rpc-like abstraction, and an optional publish subscribe interface.",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "author": "Azuqua",
   "keywords": [
     "azuqua",
@@ -44,7 +44,7 @@
   "devDependencies": {
     "chai": "^1.9.1",
     "express": "~3.4.8",
-    "grunt": "~0.4.2",
+    "grunt": "^1.4.1",
     "grunt-contrib-clean": "~0.5.0",
     "grunt-contrib-jshint": "~0.8.0",
     "grunt-mocha-test": "~0.9.4",