From b9df4c25874405cc83c468cd0ed44c9933ede501 Mon Sep 17 00:00:00 2001 From: Dave Richer Date: Mon, 3 Mar 2025 14:36:18 -0500 Subject: [PATCH] feature/IO-3096-GlobalNotifications - Logging / Merge release --- server.js | 29 ++++++++++++++++++++++++----- 1 file changed, 24 insertions(+), 5 deletions(-) diff --git a/server.js b/server.js index ca126a917..4047333d3 100644 --- a/server.js +++ b/server.js @@ -145,7 +145,10 @@ const getRedisNodesFromAWS = async () => { cluster.CacheNodes.map((node) => `${node.Endpoint.Address}:${node.Endpoint.Port}`) ); } 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; } }; @@ -169,7 +172,10 @@ const connectToRedisCluster = async () => { try { redisServers = JSON.parse(process.env.REDIS_URL); } catch (error) { - logger.log(`Failed to parse REDIS_URL: ${error.message}. Exiting...`, "ERROR", "redis", "api"); + logger.log(`Failed to parse REDIS_URL: ${error.message}. Exiting...`, "ERROR", "redis", "api", { + message: error?.message, + stack: error?.stack + }); process.exit(1); } } @@ -207,7 +213,10 @@ const connectToRedisCluster = async () => { }); redisCluster.on("error", (err) => { - logger.log(`Redis cluster connection failed: ${err.message}`, "ERROR", "redis", "api"); + logger.log(`Redis cluster connection failed:`, "ERROR", "redis", "api", { + message: err?.message, + stack: err?.stack + }); reject(err); }); }); @@ -229,8 +238,18 @@ const applySocketIO = async ({ server, app }) => { const pubClient = redisCluster; const subClient = pubClient.duplicate(); - pubClient.on("error", (err) => logger.log(`Redis pubClient error: ${err}`, "ERROR", "redis")); - subClient.on("error", (err) => logger.log(`Redis subClient error: ${err}`, "ERROR", "redis")); + pubClient.on("error", (err) => + logger.log(`Redis pubClient error: ${err}`, "ERROR", "redis", "api", { + message: err?.message, + stack: err?.stack + }) + ); + subClient.on("error", (err) => + logger.log(`Redis subClient error: ${err}`, "ERROR", "redis", "api", { + message: err?.message, + stack: err?.stack + }) + ); // Register Redis cleanup registerCleanupTask(async () => {