diff --git a/README.md b/README.md index 3dd62f1..541de27 100644 --- 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 index 560f3ca..8badb42 100644 --- 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 index 3f5eba3..b056b77 100644 --- 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 index 2644d3a..788e6db 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,6 +1,6 @@ { "name": "fox-wamp", - "version": "0.6.1", + "version": "0.6.2", "lockfileVersion": 1, "requires": true, "dependencies": { @@ -254,9 +254,9 @@ "dev": true }, "commander": { - "version": "2.19.0", - "resolved": "https://registry.npmjs.org/commander/-/commander-2.19.0.tgz", - "integrity": "sha512-6tvAOO+D6OENvRAh524Dh9jcfKTYDQAqvqezbCW82xj5X0pSrcpxtvRKHLG0yBY6SD7PSDrJaj+0AiOcKVd1Xg==" + "version": "2.20.0", + "resolved": "https://registry.npmjs.org/commander/-/commander-2.20.0.tgz", + "integrity": "sha512-7j2y+40w61zy6YC2iRNpUe/NwhNyoXrYpHMrSunaMG64nRnaf96zO/KMQR4OyN/UnE5KLyEBnKHd4aG3rskjpQ==" }, "concat-map": { "version": "0.0.1", @@ -936,9 +936,9 @@ "dev": true }, "qlobber": { - "version": "3.0.2", - "resolved": "https://registry.npmjs.org/qlobber/-/qlobber-3.0.2.tgz", - "integrity": "sha512-WSBRhZqAgVpdq6nypgMUWjlvfCgc6lUIEENy6dwg60tN2sJBN5vFyADGNaSujYeZOepFPB1uFzgBAlK+L0RKVA==" + "version": "3.1.0", + "resolved": "https://registry.npmjs.org/qlobber/-/qlobber-3.1.0.tgz", + "integrity": "sha512-B7EU6Hv9g4BeJiB7qtOjn9wwgqVpcWE5c4/86O0Yoj7fmAvgwXrdG1E+QF13S/+TX5XGUl7toizP0gzXR2Saug==" }, "ramda": { "version": "0.26.1", diff --git a/package.json b/package.json index 32b715a..887424f 100644 --- 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": {