import { createClient } from "redis";

export const redisSubscriber = createClient({
    socket: {
        host: process.env.REDIS_HOST || "127.0.0.1",
        port: Number(process.env.REDIS_PORT || 6379)
    }
});

export async function connectRedis() {

    if (!redisSubscriber.isOpen) {
        await redisSubscriber.connect();
    }

    console.log("Redis connected");
}

export const REDIS_CHANNEL =
    process.env.REDIS_CHANNEL || "whatsapp:new";