fix: subscriptions not read correctly on startup (#100)

moscajs · Jun 13, 2022 · 8448baf · 8448baf
1 parent af20fea
commit 8448baf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/persistence.js b/persistence.js
@@ -229,7 +229,7 @@ class RedisPersistence extends CachedPersistence {
     const that = this
 
     const hgetallStream = throughv.obj(function getStream (clientId, enc, cb) {
-      that._db.hgetall(clientSubKey(clientId), function clientHash (err, hash) {
+      that._db.hgetallBuffer(clientSubKey(clientId), function clientHash (err, hash) {
         cb(err, { clientHash: hash, clientId })
       })
     }, function emitReady (cb) {
@@ -562,7 +562,7 @@ function returnSubsForClient (subs) {
 function processKeysForClient (clientId, clientHash, that) {
   const topics = Object.keys(clientHash)
   for (const topic of topics) {
-    const sub = clientHash[topic]
+    const sub = msgpack.decode(clientHash[topic])
     sub.clientId = clientId
     that._trie.add(topic, sub)
   }