pollo/src/server/redis.ts

import { Redis } from "@upstash/redis";
import https from "https";
import { env } from "~/env.mjs";

export const redis = Redis.fromEnv({
  agent: new https.Agent({ keepAlive: true }),
});

export const setCache = async <T>(key: string, value: T) => {
  try {
    console.log("KEY: ", key);
    await redis.set(`${env.APP_ENV}_${key}`, value, {
      ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS),
    });
    return true;
  } catch {
    return false;
  }
};

export const fetchCache = async <T>(key: string) => {
  try {
    const result = await redis.get(`${env.APP_ENV}_${key}`);
    if (result) {
      console.log("CACHE HIT");
    } else {
      console.log("CACHE MISS");
    }
    return result as T;
  } catch {
    console.log("CACHE ERROR");
    return null;
  }
};

export const invalidateCache = async (key: string) => {
  try {
    await redis.del(`${env.APP_ENV}_${key}`);
    return true;
  } catch {
    return false;
  }
};