From 82a6f9027e5df55b113d550d5e26a8b958f87219 Mon Sep 17 00:00:00 2001
From: Adria Navarro <adria@budibase.com>
Date: Fri, 1 Mar 2024 13:41:40 +0100
Subject: [PATCH] Namespace key in redis by db

---
 packages/backend-core/src/cache/docWritethrough.ts | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/packages/backend-core/src/cache/docWritethrough.ts b/packages/backend-core/src/cache/docWritethrough.ts
index e46c763906..e367c9e060 100644
--- a/packages/backend-core/src/cache/docWritethrough.ts
+++ b/packages/backend-core/src/cache/docWritethrough.ts
@@ -23,6 +23,7 @@ export class DocWritethrough {
   private _docId: string
   private writeRateMs: number
 
+  private cacheKeyPrefix: string
   private docInfoCacheKey: string
 
   constructor(
@@ -33,7 +34,8 @@ export class DocWritethrough {
     this.db = db
     this._docId = docId
     this.writeRateMs = writeRateMs
-    this.docInfoCacheKey = `${this.db.name}:${this.docId}:info`
+    this.cacheKeyPrefix = `${this.db.name}:${this.docId}`
+    this.docInfoCacheKey = `${this.cacheKeyPrefix}:info`
   }
 
   get docId() {
@@ -85,7 +87,7 @@ export class DocWritethrough {
 
   private async storeToCache(cache: BaseCache, data: Record<string, any>) {
     for (const [key, value] of Object.entries(data)) {
-      const cacheKey = this.docId + ":data:" + key
+      const cacheKey = this.cacheKeyPrefix + ":data:" + key
       await cache.store(cacheKey, { key, value }, undefined)
     }
   }
@@ -98,7 +100,7 @@ export class DocWritethrough {
       doc = { _id: this.docId }
     }
 
-    const keysToPersist = await cache.keys(`${this.docId}:data:*`)
+    const keysToPersist = await cache.keys(`${this.cacheKeyPrefix}:data:*`)
     for (const key of keysToPersist) {
       const data = await cache.get(key, { useTenancy: false })
       doc[data.key] = data.value