export function createBullMqConnectionOptions(
  configService: ConfigService,
): ConnectionOptions {
  const host = configService.get<string>('REDIS_HOST');
  const port = configService.get<number>('REDIS_PORT');
  const username = configService.get<string | undefined>('REDIS_USERNAME');
  const password = configService.get<string | undefined>('REDIS_PASSWORD');
  const familyEnvValue = configService.get<string | undefined>('REDIS_FAMILY');
  let family: number = 0; // Default to 0 (IPv4 then IPv6)

  if (familyEnvValue !== undefined) {
    const parsedFamily = parseInt(familyEnvValue, 10);
    if (!isNaN(parsedFamily) && [0, 4, 6].includes(parsedFamily)) {
      family = parsedFamily;
    } else {
      logger.warn(
        `Invalid REDIS_FAMILY value: "${familyEnvValue}". Expected "0", "4", or "6". Defaulting to ${family}.`,
      );
    }
  }

  const connectionOptions: ConnectionOptions = {
    host,
    port,
    username: username || undefined, // Ensure undefined if empty string
    password: password || undefined, // Ensure undefined if empty string
    family,
    // If host is not localhost, enable TLS and set servername to the host for SNI
    tls: host !== 'localhost' ? { servername: host } : undefined,
  };

export function createBullMqConnectionOptions(
  configService: ConfigService,
): ConnectionOptions {
  const redisUrlString = configService.get<string>('REDIS_URL');

  if (!redisUrlString) {
    throw new Error('REDIS_URL is not defined in environment variables.');
  }
  const redisUrl = new URL(redisUrlString);
  const host = redisUrl.hostname;
  const port = Number(redisUrl.port);
  const username = redisUrl.username || undefined;
  const password = redisUrl.password || undefined;

  const connectionOptions: ConnectionOptions = {
    host,
    port,
    username,
    password,
    tls: redisUrl.protocol === 'rediss:' ? { servername: host } : undefined,
  };
  return connectionOptions;
}

export function createBullMqConnectionOptions(
  configService: ConfigService,
): ConnectionOptions {
  const host = configService.get<string>('REDIS_HOST');
  const port = configService.get<number>('REDIS_PORT');
  const username = configService.get<string | undefined>('REDIS_USERNAME');
  const password = configService.get<string | undefined>('REDIS_PASSWORD');
  const familyEnvValue = configService.get<string | undefined>('REDIS_FAMILY');
  let family: number = 0; // Default to 0 (IPv4 then IPv6)

  if (familyEnvValue !== undefined) {
    const parsedFamily = parseInt(familyEnvValue, 10);
    if (!isNaN(parsedFamily) && [0, 4, 6].includes(parsedFamily)) {
      family = parsedFamily;
    } else {
      logger.warn(
        `Invalid REDIS_FAMILY value: "${familyEnvValue}". Expected "0", "4", or "6". Defaulting to ${family}.`,
      );
    }
  }

  const connectionOptions: ConnectionOptions = {
    host,
    port,
    username: username || undefined, // Ensure undefined if empty string
    password: password || undefined, // Ensure undefined if empty string
    family,
    // If host is not localhost, enable TLS and set servername to the host for SNI
    tls: host && host !== 'localhost' ? { servername: host } : undefined,
  };
  return connectionOptions;
}

import IORedis, { RedisOptions } from 'ioredis';
import { ConfigService } from '@nestjs/config';
import { Logger } from '@nestjs/common';
import { URL } from 'url';

export function createBullMqConnection(configService: ConfigService): IORedis {
  const isLocal = process.env.NODE_ENV === 'development';

  if (isLocal) {
    const redisUrlString = configService.get<string>('REDIS_URL_PUBLIC');
    if (!redisUrlString) {
      throw new Error(
        'REDIS_URL_PUBLIC is not defined in environment variables.',
      );
    }

    const redisUrl = new URL(redisUrlString);

    const options: RedisOptions = {
      host: redisUrl.hostname,
      port: Number(redisUrl.port),
      username: redisUrl.username || undefined,
      password: redisUrl.password || undefined,
      tls:
        redisUrl.protocol === 'rediss:'
          ? { servername: redisUrl.hostname }
          : undefined,
      maxRetriesPerRequest: null,
    };

    Logger.log(
      `Using EXTERNAL Redis connection (Host: ${options.host}, Port: ${options.port}, TLS: ${!!options.tls})`,
    );

    return new IORedis(options);
  } else {
    const redisUrlString = configService.get<string>('REDIS_URL_PRIVATE');
    if (!redisUrlString) {
      throw new Error(
        'REDIS_URL_PRIVATE is not defined in environment variables.',
      );
    }

    const redisUrl = new URL(redisUrlString);

    const options: RedisOptions = {
      host: redisUrl.hostname,
      port: Number(redisUrl.port),
      family: 0, // IPv4/IPv6 Dual Stack Lookup
      username: redisUrl.username || undefined,
      password: redisUrl.password || undefined,
      maxRetriesPerRequest: null,
    };

    Logger.log(
      `Using INTERNAL Redis connection (Host: ${options.host}, Port: ${options.port})`,
    );

    return new IORedis(options);
  }
}