forceUpdate: true should await for redis (#42)

soundxyz · Mar 13, 2023 · fd950d8 · fd950d8
1 parent 88af6f5
commit fd950d8
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/.changeset/spotty-deers-suffer.md b/.changeset/spotty-deers-suffer.md
@@ -0,0 +1,5 @@
+---
+"@soundxyz/fine-grained-cache": patch
+---
+
+When specifying forceUpdate: true, it should await for redis to set
diff --git a/src/fineGrained.ts b/src/fineGrained.ts
@@ -686,7 +686,7 @@ export function FineGrainedCache({
                 ttl: expirySeconds,
               }).catch(onError);
 
-              if (awaitRedisSet) await set;
+              if (awaitRedisSet || forceUpdate) await set;
             } else {
               const tracing = enabledLogEvents?.REDIS_SET ? getTracing() : null;
 
@@ -704,7 +704,7 @@ export function FineGrainedCache({
                 })
                 .catch(onError);
 
-              if (awaitRedisSet) await set;
+              if (awaitRedisSet || forceUpdate) await set;
             }
           } else if (ttl === "Infinity") {
             if (pipelineRedisSET) {
@@ -713,7 +713,7 @@ export function FineGrainedCache({
                 value: stringifiedValue,
               }).catch(onError);
 
-              if (awaitRedisSet) await set;
+              if (awaitRedisSet || forceUpdate) await set;
             } else {
               const tracing = enabledLogEvents?.REDIS_SET ? getTracing() : null;
 
@@ -731,7 +731,7 @@ export function FineGrainedCache({
                 })
                 .catch(onError);
 
-              if (awaitRedisSet) await set;
+              if (awaitRedisSet || forceUpdate) await set;
             }
           } else if (enabledLogEvents?.REDIS_SKIP_SET) {
             logMessage("REDIS_SKIP_SET", {