fixes moscajs#693

Author: mitsos1os

lib/persistence/levelup.js

@@ -162,11 +162,12 @@ LevelUpPersistence.prototype.storeSubscriptions = function(client, done) {
   var now = Date.now();
 
   if (!client.clean) {
+    // Issue #693
     Object.keys(client.subscriptions).forEach(function(key) {
-      if (client.subscriptions[key].qos > 0) {
-        subscriptions[key] = client.subscriptions[key];
-        subscriptions[key].ttl = that.options.ttl.subscriptions + now;
-      }
+      //if (client.subscriptions[key].qos > 0) { // Issue #693
+      subscriptions[key] = client.subscriptions[key];
+      subscriptions[key].ttl = that.options.ttl.subscriptions + now;
+      //} // Issue #693
     });
     this._clientSubscriptions.put(client.id, subscriptions, done);
     Object.keys(subscriptions).forEach(function(key) {

lib/persistence/mongo.js

@@ -183,9 +183,11 @@ MongoPersistence.prototype.storeSubscriptions = function(client, done) {
   var that = this;
 
   if (!client.clean) {
-    subscriptions = Object.keys(client.subscriptions).filter(function(key) {
-      return client.subscriptions[key].qos > 0;
-    });
+    // Issue #693
+    // subscriptions = Object.keys(client.subscriptions).filter(function(key) {
+    //   return client.subscriptions[key].qos > 0;
+    // });
+    subscriptions = Object.keys(client.subscriptions);
 
     steed.each(subscriptions, function(key, cb) {
       that._subscriptions.findAndModify({

lib/persistence/redis.js

@@ -283,10 +283,11 @@ RedisPersistence.prototype.storeSubscriptions = function(client, cb) {
   var that = this;
   var subscriptions = {};
 
+  // Issue #693
   Object.keys(client.subscriptions).forEach(function(key) {
-    if (client.subscriptions[key].qos > 0) {
-      subscriptions[key] = client.subscriptions[key];
-    }
+    // if (client.subscriptions[key].qos > 0) { // Issue #693
+    subscriptions[key] = client.subscriptions[key];
+    //} // Issue #693
   });
 
   this._client.get(clientSubKey, function(err, currentSubs){

test/persistence/abstract.js

@@ -558,7 +558,7 @@ module.exports = function(create, buildOpts) {
       });
     });
 
-    it("should not store a QoS 0 subscription", function(done) {
+    it("should store a QoS 0 subscription", function(done) {
       var instance = this.instance;
       var client = {
         id: "my client id - 42",
@@ -573,7 +573,7 @@ module.exports = function(create, buildOpts) {
 
       instance.storeSubscriptions(client, function() {
         instance.lookupSubscriptions(client, function(err, results) {
-          expect(results).to.eql({});
+          expect(results).to.eql(client.subscriptions);
           done();
         });
       });