keep original subscription negating logic to pass test case.

moscajs · May 29, 2019 · 17c70ef · 17c70ef
1 parent 9d3d9b1
commit 17c70ef
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -275,12 +275,12 @@ instance.authorizeSubscribe = function (client, sub, callback) {
 }
 ```
 
-To negate a subscription, set the subscription's QoS to `128`:
+To negate a subscription, set the subscription to `null`:
 
 ```js
 instance.authorizeSubscribe = function (client, sub, callback) {
   if (sub.topic === 'aaaa') {
-    sub.qos = 128
+    sub = null
   }
 
   callback(null, sub)

diff --git a/lib/handlers/subscribe.js b/lib/handlers/subscribe.js
@@ -66,6 +66,11 @@ function storeSubscriptions (sub, done) {
   var broker = client.broker
   var perst = broker.persistence
 
+  if (!sub) {
+    this.granted.push(128)
+    return done(null, sub)
+  }
+
   if (packet.subscriptions.length > 0 && ++this.subsIndex !== packet.subscriptions.length) {
     // TODO change aedes subscribe handle, but this fix bugs for now.
     return done(null, sub)