Cleanup TTL

Author: aklinker1

src/services/in-memory-cache.ts

@@ -1,14 +1,23 @@
+import { HOUR_MS } from "../utils/time";
 import type { Cache } from "./cache";
 
+const TTL = HOUR_MS;
+
 export function createInMemoryCache(): Cache {
   let cache: Record<string, any> = Object.create(null);
+  let ttl: Record<string, number> = Object.create(null);
 
   return {
     get: async (key: string) => {
+      if (ttl[key] && Date.now() > ttl[key]) {
+        delete cache[key];
+        delete ttl[key];
+      }
       return cache[key];
     },
     set: async (key: string, value: any) => {
       cache[key] = value;
+      ttl[key] = Date.now() + TTL;
     },
   };
 }

src/services/redis-cache.ts

@@ -1,7 +1,8 @@
 import { DAY_MS } from "../utils/time";
 import type { Cache } from "./cache";
 
-const EXPIRATION = DAY_MS / 1000; // 24 hours in seconds
+const TTL = DAY_MS;
+const TTL_S = TTL / 1000;
 
 export function createRedisCache(): Cache {
   return {
@@ -14,7 +15,7 @@ export function createRedisCache(): Cache {
     },
     async set<T>(key: string, value: T): Promise<void> {
       await Bun.redis.set(key, JSON.stringify(value));
-      await Bun.redis.expire(key, EXPIRATION);
+      await Bun.redis.expire(key, TTL_S);
     },
   };
 }