redisClient.js

// version: FINAL_FIX_1
const { createClient } = require("redis");

let clientInstance = null;

// -----------------------------
// GET REDIS CLIENT (LAZY INIT)
// -----------------------------
function getRedisClient() {
  if (!process.env.REDIS_URL) {
    throw new Error("REDIS_URL not set");
  }

  if (!clientInstance) {
    clientInstance = createClient({
      url: process.env.REDIS_URL
    });

    clientInstance.on("error", (err) => {
      console.error("Redis error:", err);
    });
  }

  return clientInstance;
}

// -----------------------------
// CONNECT (SAFE + IDEMPOTENT)
// -----------------------------
async function connectRedis() {
  const client = getRedisClient();

  if (!client.isOpen) {
    try {
      await client.connect();
      console.log("Redis connected");
    } catch (err) {
      console.error("Redis connection failed:", err.message);
      throw new Error("REDIS_CONNECTION_FAILED");
    }
  }

  return client;
}

module.exports = {
  getRedisClient,
  connectRedis
};