From d9a5899b2770e7140c360f0eaf24b9e3ccb84d07 Mon Sep 17 00:00:00 2001
From: Adria Navarro <adria@budibase.com>
Date: Tue, 5 Mar 2024 16:49:45 +0100
Subject: [PATCH] Bulk store test

---
 .../src/redis/tests/redis.spec.ts             | 24 +++++++++++++++++--
 1 file changed, 22 insertions(+), 2 deletions(-)

diff --git a/packages/backend-core/src/redis/tests/redis.spec.ts b/packages/backend-core/src/redis/tests/redis.spec.ts
index d082b6b617..6333573e6e 100644
--- a/packages/backend-core/src/redis/tests/redis.spec.ts
+++ b/packages/backend-core/src/redis/tests/redis.spec.ts
@@ -2,9 +2,10 @@ import { generator, structures } from "../../../tests"
 import RedisWrapper from "../redis"
 
 describe("redis", () => {
-  const redis = new RedisWrapper(structures.db.id())
+  let redis: RedisWrapper
 
-  beforeAll(async () => {
+  beforeEach(async () => {
+    redis = new RedisWrapper(structures.db.id())
     await redis.init()
   })
 
@@ -18,4 +19,23 @@ describe("redis", () => {
       expect(await redis.get(key)).toEqual(value)
     })
   })
+
+  describe("bulkStore", () => {
+    it("a basic object can be persisted", async () => {
+      const data = generator
+        .unique(() => generator.word(), 10)
+        .reduce((acc, key) => {
+          acc[key] = generator.word()
+          return acc
+        }, {} as Record<string, string>)
+
+      await redis.bulkStore(data)
+
+      for (const [key, value] of Object.entries(data)) {
+        expect(await redis.get(key)).toEqual(value)
+      }
+
+      expect(await redis.keys("*")).toHaveLength(10)
+    })
+  })
 })