Delete info on process

packages/backend-core/src/cache/base/index.ts

@@ -108,4 +108,13 @@ export default class BaseCache {
       throw err
     }
   }
+
+  /**
+   * Delete the entry if the provided value matches the stored one.
+   */
+  async deleteIfValue(key: string, value: any, opts = { useTenancy: true }) {
+    key = opts.useTenancy ? generateTenantKey(key) : key
+    const client = await this.getClient()
+    await client.deleteIfValue(key, value)
+  }
 }

packages/backend-core/src/cache/docWritethrough.ts

@@ -66,6 +66,11 @@ docWritethroughProcessorQueue.process(async message => {
 
       await persistToDb(cache, message.data)
       console.log("DocWritethrough persisted", { data: message.data })
+
+      await cache.deleteIfValue(
+        REDIS_KEYS(cacheKeyPrefix).LATEST_MESSAGE_ID,
+        latestMessageId
+      )
     }
   )