Add onIntervalExpiration and tests.

Author: sanny-io

packages/plugins/cache/src/providers/memory.ts

@@ -18,6 +18,7 @@ export class MemoryCacheProvider implements CacheProvider {
         for (const [key, entry] of this.entryStore) {
             if (entryIsExpired(entry)) {
                 this.entryStore.delete(key);
+                this.options?.onIntervalExpiration?.(entry);
             }
         }
 
@@ -87,4 +88,9 @@ export type MemoryCacheOptions = {
      * @default 60
      */
     checkInterval?: number;
+
+    /**
+     * Called when an entry has expired via the interval check.
+     */
+    onIntervalExpiration?: (entry: CacheEntry) => void,
 };

tests/e2e/orm/cache/memory.test.ts

@@ -868,6 +868,37 @@ describe('Cache plugin (memory)', () => {
         });
     });
 
+    it('supports custom options', async () => {
+        const onIntervalExpiration = vi.fn(() => {});
+        const extDb = db.$use(defineCachePlugin({
+            provider: new MemoryCacheProvider({
+                checkInterval: 10,
+                onIntervalExpiration,
+            }),
+        }));
+
+        await extDb.user.exists({
+            cache: {
+                ttl: 5,
+            },
+        });
+
+        vi.advanceTimersByTime(5100);
+        expect(onIntervalExpiration).not.toHaveBeenCalled();
+        vi.advanceTimersByTime(10000);
+        expect(onIntervalExpiration).toHaveBeenCalledOnce();
+        
+        // @ts-expect-error
+        const arg = onIntervalExpiration.mock.lastCall[0];
+
+        expect(arg).toMatchObject({
+            result: false,
+            options: {
+                ttl: 5,
+            },
+        })
+    });
+
     it('handles edge cases', async () => {
         const extDb = db.$use(defineCachePlugin({
             provider: new MemoryCacheProvider(),