add-test/don't invalidate the cache if the cache method was excluded

Author: A-J Roos

src/index.ts

@@ -132,8 +132,8 @@ export const createPrismaRedisCache = ({
       // Query the database for any Prisma method (mutation method) or Prisma model we excluded from the cache
       result = await fetchFromPrisma(params);
 
+      // If we successfully executed the Mutation we clear and invalidate the cache for the Prisma model
       if (defaultMutationMethods.includes(params.action as PrismaMutationAction)) {
-        // If we successfully executed the Mutation we clear and invalidate the cache for the Prisma model
         await cache.invalidateAll(`${params.model}~*`);
       }
     }

test/index.test.ts

@@ -273,3 +273,40 @@ test("should invalidate a single Prisma model cache after data mutation", async
   // Test that we keep other cached queries that shouldn't be cleared
   expect(JSON.parse((await redis.get(cacheKey2)) as string)).toMatchObject(dbValue);
 });
+
+test("should not invalidate a Prisma model if cache method is excluded", async () => {
+  const middleware = createPrismaRedisCache({
+    storage: { type: "redis", options: { client: redis, invalidation: true } },
+    cacheTime,
+    excludeMethods: ["findFirst"],
+  });
+
+  // Run a "fake" User Prisma query
+  await middleware(
+    {
+      args,
+      action: action1,
+      model: model1,
+      dataPath: [],
+      runInTransaction: false,
+    },
+    next,
+  );
+
+  // Run a "fake" Post Prisma query
+  await middleware(
+    {
+      args,
+      action: action2,
+      model: model1,
+      dataPath: [],
+      runInTransaction: false,
+    },
+    next,
+  );
+
+  // Test if the cached query was fetched from the cache
+  expect(JSON.parse((await redis.get(cacheKey1)) as string)).toMatchObject(dbValue);
+  // Test that the excluded cache method was not cached
+  assert.equal(JSON.parse((await redis.get(cacheKey2)) as string), null);
+});