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

IO-2959 Implement logger & best practices.

Browse Source
This commit is contained in:
Patrick Fic
2024-11-26 08:52:58 -08:00
parent 6058bb1b8f
commit a4bff1a548
2 changed files with 28 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server.js
View File

@@ -22,7 +22,7 @@ const { applyIOHelpers } = require("./server/utils/ioHelpers");
const { redisSocketEvents } = require("./server/web-sockets/redisSocketEvents"); const { redisSocketEvents } = require("./server/web-sockets/redisSocketEvents");
const { ElastiCacheClient, DescribeCacheClustersCommand } = require("@aws-sdk/client-elasticache"); const { ElastiCacheClient, DescribeCacheClustersCommand } = require("@aws-sdk/client-elasticache");
const { InstanceRegion } = require("./server/utils/instanceMgr"); const { InstanceRegion } = require("./server/utils/instanceMgr");
const { StartStatusReporter } = require("./server/utils/statusReporter"); const StartStatusReporter = require("./server/utils/statusReporter");
const CLUSTER_RETRY_BASE_DELAY = 100; const CLUSTER_RETRY_BASE_DELAY = 100;
const CLUSTER_RETRY_MAX_DELAY = 5000; const CLUSTER_RETRY_MAX_DELAY = 5000;

38
server/utils/statusReporter.js
View File

@@ -1,18 +1,18 @@
// Load environment variables THIS MUST BE AT THE TOP // Load environment variables THIS MUST BE AT THE TOP
const path = require("path"); const path = require("path");
const getHostNameOrIP = require("./getHostNameOrIP"); const getHostNameOrIP = require("./getHostNameOrIP");
const logger = require("./logger");
require("dotenv").config({ require("dotenv").config({
path: path.resolve(process.cwd(), `.env.${process.env.NODE_ENV || "development"}`) path: path.resolve(process.cwd(), `.env.${process.env.NODE_ENV || "development"}`)
}); });
const CrispStatusReporter = require("crisp-status-reporter").CrispStatusReporter; const CrispStatusReporter = require("crisp-status-reporter").CrispStatusReporter;
const InstanceManager = require("../utils/instanceMgr").default; const InstanceManager = require("../utils/instanceMgr").default;
exports.StartStatusReporter = function () { function StartStatusReporter() {
//For ImEX Online. //For ImEX Online.
InstanceManager({ InstanceManager({
executeFunction: true, executeFunction: true,
debug: true,
args: [], args: [],
imex: () => { imex: () => {
if ( if (
@@ -21,16 +21,32 @@ exports.StartStatusReporter = function () {
!process.env.CRISP_SERVICE_IDENTIFIER || !process.env.CRISP_SERVICE_IDENTIFIER ||
!process.env.CRISP_NODE_IDENTIFIER !process.env.CRISP_NODE_IDENTIFIER
) { ) {
logger.log("crisp-status-update-error", "DEBUG", null, null, { message: "Environment Variables not set." });
return; return;
} }
var crispStatusReporter = new CrispStatusReporter({
token: process.env.CRISP_SECRET_TOKEN, // Your reporter token (given by Crisp) try {
service_id: process.env.CRISP_SERVICE_IDENTIFIER, // Service ID containing the parent Node for Replica (given by Crisp) const crispStatusReporter = new CrispStatusReporter({
node_id: process.env.CRISP_NODE_IDENTIFIER, // Node ID containing Replica (given by Crisp) token: process.env.CRISP_SECRET_TOKEN, // Your reporter token (given by Crisp)
replica_id: getHostNameOrIP(), // Unique Replica ID for instance (ie. your IP on the LAN) service_id: process.env.CRISP_SERVICE_IDENTIFIER, // Service ID containing the parent Node for Replica (given by Crisp)
interval: 30, // Reporting interval (in seconds; defaults to 30 seconds if not set) node_id: process.env.CRISP_NODE_IDENTIFIER, // Node ID containing Replica (given by Crisp)
console: require("console") // Console instance if you need to debug issues, replica_id: getHostNameOrIP(), // Unique Replica ID for instance (ie. your IP on the LAN)
}); interval: 30, // Reporting interval (in seconds; defaults to 30 seconds if not set)
console: {
debug: (log_message, data) => logger.log("crisp-status-update", "DEBUG", null, null, { log_message, data }),
log: (log_message, data) => logger.log("crisp-status-update", "DEBUG", null, null, { log_message, data }),
warn: (log_message, data) => logger.log("crisp-status-update", "WARN", null, null, { log_message, data }),
error: (log_message, data) => logger.log("crisp-status-update", "ERROR", null, null, { log_message, data })
} // Console instance if you need to debug issues,
});
return crispStatusReporter;
} catch (error) {
logger.log("crisp-status-update-error", "DEBUG", null, null, { error: error.message });
}
} }
}); });
}; }
module.exports = StartStatusReporter;