Simple zlib + Prisma compressed caching implementation

cache.ts

// Generic cache class for compressing and storing data in the database. Use it for any data where you don't need to be able to read it. Things like deterministic API calls are a great candidate.
// Also a fun experiment to play around with cache invalidation times, where the cache is only "valid" for so long.
 
import zlib from "zlib";

export const getCache = async (prisma: any, key: string): Promise<string | undefined> => {
  const entry = await prisma.cacheEntry.findUnique({
    where: {
      key,
    },
    select: {
      value: true,
    },
  });
  if (!entry) return undefined;
  return zlib.inflateSync(new Buffer(entry.value, "base64")).toString();
};

export const setCache = async (prisma: any, key: string, data: string): Promise<void> => {
  const value = zlib.deflateSync(data).toString("base64");
  await prisma.cacheEntry.upsert({
    where: {
      key,
    },
    update: {
      value,
    },
    create: {
      key,
      value,
    },
  });
};

schema.prisma

// Simple prisma model to accompany the above
generator client {
  provider = "prisma-client-js"
}

datasource db {
  provider = "mongodb"
  url      = env("DATABASE_URL")
}

model CacheEntry {
  key   String @id @map("_id")
  value String
}