diff --git a/Server/controllers/nodesController.js b/Server/controllers/nodesController.js index 370f392..bb5c081 100644 --- a/Server/controllers/nodesController.js +++ b/Server/controllers/nodesController.js @@ -108,6 +108,7 @@ exports.requestNodeJoinServer = async (req, res) => { */ exports.nodeMonitorService = class nodeMonitorService { constructor() { + this.log = new DebugBuilder("server", "nodeMonitorService"); } async start(){ @@ -130,21 +131,21 @@ exports.nodeMonitorService = class nodeMonitorService { async checkInWithOnlineNodes(){ getOnlineNodes((nodes) => { - log.DEBUG("Online Nodes: ", nodes); + this.log.DEBUG("Online Nodes: ", nodes); for (const node of nodes) { const reqOptions = new requestOptions("/client/requestCheckIn", "GET", node.ip, node.port) - const request = sendHttpRequest(reqOptions, "", (responseObj) => { + sendHttpRequest(reqOptions, "", (responseObj) => { if (responseObj) { - log.DEBUG("Response from: ", node.name, responseObj); + this.log.DEBUG("Response from: ", node.name, responseObj); } else { - log.DEBUG("No response from node, assuming it's offline"); + this.log.DEBUG("No response from node, assuming it's offline"); const offlineNode = new nodeObject({ _online: 0, _id: node.id }); - log.DEBUG("Offline node update object: ", offlineNode); + this.log.DEBUG("Offline node update object: ", offlineNode); updateNodeInfo(offlineNode, (sqlResponse) => { - if (!sqlResponse) log.ERROR("No response from SQL object"); + if (!sqlResponse) this.log.ERROR("No response from SQL object"); - log.DEBUG("Updated node: ", sqlResponse); + this.log.DEBUG("Updated offline node: ", sqlResponse); }) } }) diff --git a/Server/index.js b/Server/index.js index ba5622b..bdee6b1 100644 --- a/Server/index.js +++ b/Server/index.js @@ -148,7 +148,7 @@ client.on('ready', () => { runHTTPServer(); log.DEBUG("Starting Node Monitoring Service"); - //runNodeMonitorService(); + runNodeMonitorService(); log.DEBUG("Starting RSS watcher"); runRssService();