fix(multi): wait deserialize promise

microlinkhq · Mar 28, 2022 · 898fcbe · 898fcbe
1 parent 45b544c
commit 898fcbe
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 10 deletions.
diff --git a/packages/multi/package.json b/packages/multi/package.json
@@ -31,6 +31,7 @@
   },
   "devDependencies": {
     "@keyvhq/sqlite": "latest",
+    "@keyvhq/compress": "latest",
     "ava": "latest",
     "delay": "latest"
   },

diff --git a/packages/multi/src/index.js b/packages/multi/src/index.js
@@ -25,7 +25,7 @@ class MultiCache {
       const key = this.remote._getKeyPrefix(...args)
 
       const raw = await this.remote.store.get(key)
-      const data = typeof raw === 'string' ? this.remote.deserialize(raw) : raw
+      const data = typeof raw === 'string' ? await this.remote.deserialize(raw) : raw
 
       const hasValue = data ? data.value !== undefined : false
       const isFresh =

diff --git a/packages/multi/test/index.js b/packages/multi/test/index.js
@@ -3,18 +3,19 @@
 const test = require('ava')
 const delay = require('delay')
 
-const KeyvMulti = require('..')
-const Keyv = require('@keyvhq/core')
+const keyvCompress = require('@keyvhq/compress')
 const KeyvSqlite = require('@keyvhq/sqlite')
+const Keyv = require('@keyvhq/core')
+const KeyvMulti = require('..')
 
-const remoteStore = () =>
-  new Keyv({
-    store: new KeyvSqlite({
-      uri: 'sqlite://test/testdb.sqlite',
-      busyTimeout: 30000
-    })
+const remoteStore = () => keyvCompress(new Keyv({
+  store: new KeyvSqlite({
+    uri: 'sqlite://test/testdb.sqlite',
+    busyTimeout: 30000
   })
-const localStore = () => new Keyv()
+}))
+
+const localStore = () => keyvCompress(new Keyv())
 
 test.beforeEach(async () => {
   const remote = remoteStore()