import Redis from "ioredis";
import config from "@/config/index.js";

export function createConnection() {
	return new Redis({
		port: config.redis.port,
		host: config.redis.host,
		family: config.redis.family == null ? 0 : config.redis.family,
		password: config.redis.pass,
		username: "default",
		keyPrefix: `${config.redis.prefix}:`,
		db: config.redis.db || 0,
		tls: {
			rejectUnauthorized: false,
			host: config.redis.host,
		},
	});
}

export const subscriber = createConnection();
subscriber.subscribe(config.host);

export const redisClient = createConnection();