IO-3170-Enhanced-GetRedisEndpointsFromAWS - Fix to prevent breaking

server.js

@@ -139,15 +139,32 @@ const getRedisNodesFromAWS = async () => {
     const response = await client.send(command);
     const cacheClusters = response.CacheClusters;
 
-    return cacheClusters.flatMap((cluster) =>
+    // Ensure cacheClusters exists and is an array
-      cluster.CacheNodes.map((node) => `${node.Endpoint.Address}:${node.Endpoint.Port}`)
+    if (!cacheClusters || !Array.isArray(cacheClusters) || cacheClusters.length === 0) {
-    );
+      logger.log(`No cache clusters found for cluster id ${process.env.REDIS_CLUSTER_ID}`, "ERROR", "redis", "api");
+      return [];
+    }
+
+    // Process each cluster
+    return cacheClusters.flatMap((cluster) => {
+      if (cluster.CacheNodes && Array.isArray(cluster.CacheNodes)) {
+        // Map nodes to address strings
+        const addresses = cluster.CacheNodes.map((node) => `${node.Endpoint.Address}:${node.Endpoint.Port}`);
+        // Debug log node addresses
+        logger.log(`Cluster node addresses: ${addresses.join(", ")}`, "DEBUG", "redis", "api");
+        // Return only those addresses that start with the current cluster id
+        return addresses.filter((address) => address.startsWith(process.env.REDIS_CLUSTER_ID));
+      }
+      return [];
+    });
   } catch (err) {
-    logger.log(`Error fetching Redis nodes from AWS: ${err.message}`, "ERROR", "redis", "api");
+    logger.log(`Error fetching Redis nodes from AWS:`, "ERROR", "redis", "api", {
+      message: err?.message,
+      stack: err?.stack
+    });
     throw err;
   }
 };
-
 /**
  * Connect to Redis Cluster
  * @returns {Promise<unknown>}
@@ -360,7 +377,10 @@ async function handleSigterm() {
     }
     logger.log("sigterm-api", "WARN", null, null, { message: `All cleanup tasks completed.` });
   } catch (error) {
-    logger.log("sigterm-api-error", "ERROR", null, null, { message: error.message, stack: error.stack });
+    logger.log("sigterm-api-error", "ERROR", null, null, {
+      message: error.message,
+      stack: error.stack
+    });
   }
 
   process.exit(0);