From 355dea5b05659efa5da48ed12062852aa980a4b2 Mon Sep 17 00:00:00 2001
From: Adria Navarro <adria@budibase.com>
Date: Wed, 6 Mar 2024 00:13:11 +0100
Subject: [PATCH] Add deleteIfValue

---
 packages/backend-core/src/redis/redis.ts | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/packages/backend-core/src/redis/redis.ts b/packages/backend-core/src/redis/redis.ts
index 55d43e4f60..fd40467b6a 100644
--- a/packages/backend-core/src/redis/redis.ts
+++ b/packages/backend-core/src/redis/redis.ts
@@ -339,6 +339,18 @@ class RedisWrapper {
     }
     return result
   }
+
+  async deleteIfValue(key: string, value: any) {
+    const client = this.getClient()
+
+    const luaScript = `
+      if redis.call('GET', KEYS[1]) == ARGV[1] then
+        redis.call('DEL', KEYS[1])
+      end
+      `
+
+    await client.eval(luaScript, 1, addDbPrefix(this._db, key), value)
+  }
 }
 
 export default RedisWrapper