authorize function

kalmyk · Apr 12, 2019 · 9814e75 · 9814e75
1 parent 9b4e37e
commit 9814e75
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 11 deletions.
diff --git a/README.md b/README.md
@@ -147,6 +147,9 @@ publish('the.key', [ 'args' ], { kwArgs: false }, {
 Take a look for more use cases at http://jeta.host/
 
 ## Changes:
+2019-04-11
+- authorize function supported for SUBSCRIBE & PUBLISH
+
 2019-03-22
 - WAMP registration option.concurrency supported.
 

diff --git a/lib/fox_api.js b/lib/fox_api.js
@@ -6,6 +6,7 @@ const Session = require('./session')
 const tools = require('./tools')
 
 function FoxApi (realm) {
+  this.registerSession = () => {}
   Session.call(this, this)
   this.sessionId = tools.randomId()
 

diff --git a/lib/mqtt/gate.js b/lib/mqtt/gate.js
@@ -161,9 +161,12 @@ handlers.publish = function (ctx, session, message) {
     data = { payload: message.payload }
   }
 
+  let uri = mqttParse(message.topic)
+  this.checkAuthorize(ctx, 'publish', uri)
+
   session.realm.doPush(session, {
     mtype: 'publish',
-    uri: mqttParse(message.topic),
+    uri,
     data,
     opt
   })

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "fox-wamp",
-  "version": "0.6.1",
+  "version": "0.6.2",
   "description": "Web Application Message Router/Server WAMP/MQTT",
   "author": {
     "name": "Anatoly Tsapkov",
@@ -22,11 +22,11 @@
     "subscribe"
   ],
   "dependencies": {
-    "commander": "^2.19.0",
+    "commander": "^2.20.0",
     "jsonschema": "^1.2.4",
     "mqtt-packet": "^6.1.1",
     "node-statsd": "*",
-    "qlobber": "*",
+    "qlobber": "^3.1.0",
     "ws": "^6.2.1"
   },
   "devDependencies": {