From 9364a7e654d1d1f588688f2c344ce9610ba1a332 Mon Sep 17 00:00:00 2001
From: Ajay <dev@ajay.app>
Date: Thu, 8 Feb 2024 21:15:28 -0500
Subject: [PATCH] Show general last invalidation message

---
 src/utils/redis.ts | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/utils/redis.ts b/src/utils/redis.ts
index c1fad71..f7dacf2 100644
--- a/src/utils/redis.ts
+++ b/src/utils/redis.ts
@@ -20,6 +20,7 @@ export interface RedisStats {
     memoryCacheLength: number;
     memoryCacheSize: number;
     lastInvalidation: number;
+    lastInvalidationMessage: number;
 }
 
 interface RedisSB {
@@ -58,6 +59,7 @@ let writeRequests = 0;
 let memoryCacheHits = 0;
 let memoryCacheMisses = 0;
 let memoryCacheUncachedMisses = 0;
+let lastInvalidationMessage = 0;
 let lastInvalidation = 0;
 
 const readResponseTime: number[] = [];
@@ -296,7 +298,8 @@ export function getRedisStats(): RedisStats {
         memoryCacheTotalHits: memoryCacheHits / (memoryCacheHits + memoryCacheMisses + memoryCacheUncachedMisses),
         memoryCacheLength: cache?.size ?? 0,
         memoryCacheSize: cache?.calculatedSize ?? 0,
-        lastInvalidation
+        lastInvalidation,
+        lastInvalidationMessage
     };
 }
 
@@ -306,6 +309,7 @@ async function setupCacheClientListener(cacheClient: RedisClientType,
     cacheConnectionClientId = String(await cacheClient.clientId());
 
     cacheClient.subscribe("__redis__:invalidate", (messages) => {
+        lastInvalidationMessage = Date.now();
         if (cache.delete(messages?.[0])) {
             lastInvalidation = Date.now();
         }