Function getRedisClusterOptions

server/redisConnection.js:60–87

(overridePrefix = null)

};

const getRedisClusterOptions = (overridePrefix = null) => {
  const clusterNodes = getRedisEnvValue("CLUSTER_NODES", overridePrefix);

  if (clusterNodes) {
    const nodes = clusterNodes.split(",").map((node) => {
      const [host, port] = node.trim().split(":");
      return { host, port: parseInt(port, 10) || 6379 };
    });

    const clusterOptions = {
      enableReadyCheck: false,
      redisOptions: {
        password: getRedisEnvValue("PASSWORD", overridePrefix),
      }
    };

    // Add TLS configuration if provided
    const tlsCa = getRedisEnvValue("CA", overridePrefix);

    if (tlsCa) {
      clusterOptions.redisOptions.tls = { ca: tlsCa };
    }

    return { cluster: { nodes, options: clusterOptions } };
  }

  return null;
};

const getQueueOptions = () => {
  // Check if cluster configuration is available