v4.0.2: fix rejecting queued promises

dist/cjs/index.js

@@ -63,9 +63,11 @@ let cache = function ({ call, key, expires = 0 }) {
 
     // get existing promise (of a previous pending request asking for the exact same thing)
     let existingPromise = getPromise({ key });
-    if(existingPromise) { return existingPromise.then((value)=>{
-      return resolve(value)
-    }) }
+    if(existingPromise) { 
+      return existingPromise
+        .then(resolve)
+        .catch(reject)
+    }
 
     setPromise({ key, promise: new Promise((resolveQueue, rejectQueue)=>{
       if (expires === 0) {
@@ -104,6 +106,8 @@ let cache = function ({ call, key, expires = 0 }) {
       })
     }).then(()=>{
       deletePromise({ key });
+    }).catch(()=>{
+      deletePromise({ key });
     });
   })
 };

dist/es/index.js

@@ -59,9 +59,11 @@ let cache = function ({ call, key, expires = 0 }) {
 
     // get existing promise (of a previous pending request asking for the exact same thing)
     let existingPromise = getPromise({ key });
-    if(existingPromise) { return existingPromise.then((value)=>{
-      return resolve(value)
-    }) }
+    if(existingPromise) { 
+      return existingPromise
+        .then(resolve)
+        .catch(reject)
+    }
 
     setPromise({ key, promise: new Promise((resolveQueue, rejectQueue)=>{
       if (expires === 0) {
@@ -100,6 +102,8 @@ let cache = function ({ call, key, expires = 0 }) {
       })
     }).then(()=>{
       deletePromise({ key });
+    }).catch(()=>{
+      deletePromise({ key });
     });
   })
 };

dist/umd/index.js

@@ -62,9 +62,11 @@
 
       // get existing promise (of a previous pending request asking for the exact same thing)
       let existingPromise = getPromise({ key });
-      if(existingPromise) { return existingPromise.then((value)=>{
-        return resolve(value)
-      }) }
+      if(existingPromise) { 
+        return existingPromise
+          .then(resolve)
+          .catch(reject)
+      }
 
       setPromise({ key, promise: new Promise((resolveQueue, rejectQueue)=>{
         if (expires === 0) {
@@ -103,6 +105,8 @@
         })
       }).then(()=>{
         deletePromise({ key });
+      }).catch(()=>{
+        deletePromise({ key });
       });
     })
   };

package.json

@@ -1,7 +1,7 @@
 {
   "name": "depay-web3-client",
   "moduleName": "Web3Client",
-  "version": "4.0.1",
+  "version": "4.0.2",
   "description": "A web3 client to fetch blockchain data just like we are used to with http clients.",
   "main": "dist/cjs/index.js",
   "module": "dist/es/index.js",

src/cache.js

@@ -56,9 +56,11 @@ let cache = function ({ call, key, expires = 0 }) {
 
     // get existing promise (of a previous pending request asking for the exact same thing)
     let existingPromise = getPromise({ key })
-    if(existingPromise) { return existingPromise.then((value)=>{
-      return resolve(value)
-    }) }
+    if(existingPromise) { 
+      return existingPromise
+        .then(resolve)
+        .catch(reject)
+    }
 
     setPromise({ key, promise: new Promise((resolveQueue, rejectQueue)=>{
       if (expires === 0) {
@@ -97,6 +99,8 @@ let cache = function ({ call, key, expires = 0 }) {
       })
     }).then(()=>{
       deletePromise({ key })
+    }).catch(()=>{
+      deletePromise({ key })
     })
   })
 }