admin/bodyshop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feature/IO-3096-GlobalNotifications - Logging / Merge release

Browse Source
This commit is contained in:
Dave Richer
2025-03-03 14:36:18 -05:00
parent 15686bdab8
commit b9df4c2587
1 changed files with 24 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
server.js
View File

@@ -145,7 +145,10 @@ const getRedisNodesFromAWS = async () => {
cluster.CacheNodes.map((node) => `${node.Endpoint.Address}:${node.Endpoint.Port}`) cluster.CacheNodes.map((node) => `${node.Endpoint.Address}:${node.Endpoint.Port}`)
); );
} catch (err) { } 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; throw err;
} }
}; };
@@ -169,7 +172,10 @@ const connectToRedisCluster = async () => {
try { try {
redisServers = JSON.parse(process.env.REDIS_URL); redisServers = JSON.parse(process.env.REDIS_URL);
} catch (error) { } 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); process.exit(1);
} }
} }
@@ -207,7 +213,10 @@ const connectToRedisCluster = async () => {
}); });
redisCluster.on("error", (err) => { 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); reject(err);
}); });
}); });
@@ -229,8 +238,18 @@ const applySocketIO = async ({ server, app }) => {
const pubClient = redisCluster; const pubClient = redisCluster;
const subClient = pubClient.duplicate(); const subClient = pubClient.duplicate();
pubClient.on("error", (err) => logger.log(`Redis pubClient error: ${err}`, "ERROR", "redis")); pubClient.on("error", (err) =>
subClient.on("error", (err) => logger.log(`Redis subClient error: ${err}`, "ERROR", "redis")); 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 // Register Redis cleanup
registerCleanupTask(async () => { registerCleanupTask(async () => {