fix: added 9 fallback to 8 regarding subsciption parse (#108)

moscajs · Jan 16, 2023 · 6d2d86a · 6d2d86a
1 parent f53ed12
commit 6d2d86a
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/persistence.js b/persistence.js
@@ -554,7 +554,14 @@ function returnSubsForClient (subs) {
   }
 
   for (const subKey of subKeys) {
-    toReturn.push(msgpack.decode(subs[subKey]))
+    if (subs[subKey].length === 1) { // version 8x fallback, QoS saved not encoded object
+      toReturn.push({
+        topic: subKey,
+        qos: parseInt(subs[subKey])
+      })
+    } else {
+      toReturn.push(msgpack.decode(subs[subKey]))
+    }
   }
 
   return toReturn