chore: do not emit expire if removing key from set fails

lemonde · Sep 3, 2021 · c1aab63 · c1aab63
1 parent 0b72eae
commit c1aab63
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/locky.js b/lib/locky.js
@@ -364,7 +364,11 @@ class Locky extends EventEmitter {
 
     const trx = redisClient.multi();
     trx.srem(this.currentLocksKey, keysToExpire);
-    await promisify(trx.exec.bind(trx))();
+    const results = await promisify(trx.exec.bind(trx))();
+
+    // Results are null if a watch key has been modified
+    // during the transaction execution
+    if (results === null) return;
 
     await Promise.all(
       keysToExpire.map((key) =>