ioredis

import Redis from "ioredis";
 
export const redis = new Redis(process.env.REDIS_URL!, {
  maxRetriesPerRequest: 3,
  enableReadyCheck: true,
  lazyConnect: false,
});
 
redis.on("error", (err) => {
  console.error({ msg: "redis_error", err: err.message });
});
 
export async function cacheGet(key: string) {
  return redis.get(key);
}

// src/redis.ts
import Redis from "ioredis";
 
function createRedis() {
  const url = process.env.REDIS_URL!;
  if (process.env.REDIS_CLUSTER === "true") {
    return new Redis.Cluster([{ host: process.env.REDIS_HOST!, port: 6379 }], {
      redisOptions: { password: process.env.REDIS_PASSWORD },
    });
  }
  return new Redis(url, { maxRetriesPerRequest: 3 });
}
 
export const redis = createRedis();
 
// src/cache/batch.ts
export async function mgetJson<T>(keys: string[]): Promise<(T | null)[]> {
  if (keys.length === 0) return [];
  const pipeline = redis.pipeline();
  keys.forEach((k) => pipeline.get(k));
  const results = await pipeline.exec();
  return (results ?? []).map(([err, val]) => {
    if (err || val == null) return null;
    return JSON.parse(val as string) as T;
  });
}
 
// Graceful shutdown
process.on("SIGTERM", async () => {
  await redis.quit();
});

const pipe = redis.pipeline();
pipe.set("a", "1");
pipe.incr("counter");
await pipe.exec();
 
await redis.mset("a", "1", "b", "2");

const script = `
  local current = redis.call('GET', KEYS[1])
  if current == false then
    redis.call('SET', KEYS[1], ARGV[1], 'EX', ARGV[2])
    return 1
  end
  return 0
`;
await redis.eval(script, 1, "lock:job", "token", "30");

import fp from "fastify-plugin";
import { redis } from "./redis";
 
export const redisPlugin = fp(async (fastify) => {
  fastify.decorate("redis", redis);
  fastify.addHook("onClose", async () => {
    await redis.quit();
  });
});