diff --git a/src/utils/redis.ts b/src/utils/redis.ts index e4d434f..c416146 100644 --- a/src/utils/redis.ts +++ b/src/utils/redis.ts @@ -365,7 +365,9 @@ async function setupCacheClientListener(cacheClient: RedisClientType, if (keys) { lastInvalidationMessage = Date.now(); - for (const key of keys) { + for (let key of keys) { + if (config.redis.useCompression) key = key.replace(/.c$/, ""); + if (cache.delete(key)) { lastInvalidation = Date.now(); }