rudeshark.net/packages/backend/src/db/redis.ts

25 lines
563 B
TypeScript

import config from "@/config/index.js";
import Redis from "ioredis";
export function createConnection() {
let source = config.redis;
if (config.cacheServer) {
source = config.cacheServer;
}
return new Redis({
port: source.port,
host: source.host,
family: source.family ?? 0,
password: source.pass,
username: source.user ?? "default",
keyPrefix: `${source.prefix}:`,
db: source.db || 0,
tls: source.tls,
});
}
export const subscriber = createConnection();
subscriber.subscribe(config.host);
export const redisClient = createConnection();