From fb11a7ef3e4fefcdd981c6c579461087380dcdbc Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Sun, 3 Jun 2018 23:39:03 +0200 Subject: [PATCH] Corrections on Logging --- DebugLog.js | 4 +- ExtractionBotProcessMainLoop.js | 82 ++++++++++++---------- IndicatorBotProcessMainLoop.js | 76 ++++++++++++--------- TradingBotProcessMainLoop.js | 116 ++++++++++++++++++-------------- 4 files changed, 157 insertions(+), 121 deletions(-) diff --git a/DebugLog.js b/DebugLog.js index 5be8718f4..8904751e7 100644 --- a/DebugLog.js +++ b/DebugLog.js @@ -3,7 +3,7 @@ const ROOT_DIR = './'; const MODULE_NAME = "DebugLog"; - let executionDatetime = ".Y." + global.EXECUTION_DATETIME.getUTCFullYear() + + let executionDatetime = "Y." + global.EXECUTION_DATETIME.getUTCFullYear() + ".M." + pad(global.EXECUTION_DATETIME.getUTCMonth() + 1, 2) + ".D." + pad(global.EXECUTION_DATETIME.getUTCDate(), 2) + ".H." + pad(global.EXECUTION_DATETIME.getUTCHours(),2) + @@ -33,7 +33,7 @@ disableCloudLogging = pDisableCloudLogging if (disableCloudLogging !== true) { - thisObject.bot.eventHandler.listenToEvent("Loop Finished", onLoopFinished); + thisObject.bot.eventHandler.listenToEvent("Close Log File", onLoopFinished); } } diff --git a/ExtractionBotProcessMainLoop.js b/ExtractionBotProcessMainLoop.js index 945e96ce1..516ef7e49 100644 --- a/ExtractionBotProcessMainLoop.js +++ b/ExtractionBotProcessMainLoop.js @@ -13,7 +13,9 @@ bot.eventHandler = EVENT_HANDLER_MODULE.newEventHandler(); const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); - const logger = DEBUG_MODULE.newDebugLog(); + let logger; + + logger = DEBUG_MODULE.newDebugLog(); logger.fileName = MODULE_NAME; logger.bot = bot; logger.forceLoopSplit = true; @@ -77,7 +79,7 @@ logger.write("[ERROR] initialize -> onInizialized -> onBotDownloaded -> err.message = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } @@ -105,7 +107,7 @@ logger.write("[ERROR] initialize -> onInizialized -> onBotDownloaded -> onCommonsDownloaded -> err.message = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } @@ -118,12 +120,12 @@ } else { logger.write("[ERROR] Root -> start -> getBotConfig -> onInizialized -> err = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); } } } catch (err) { logger.write("[ERROR] initialize -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -133,6 +135,8 @@ try { if (FULL_LOG === true) { logger.write("[INFO] run -> Entering function."); } + bot.eventHandler.raiseEvent("Close Log File"); + let intervalHandle; if (bot.runAtFixedInterval === true) { @@ -148,6 +152,15 @@ function loop() { try { + + /* For each loop we want to create a new log file. */ + + logger = DEBUG_MODULE.newDebugLog(); + logger.fileName = MODULE_NAME; + logger.bot = bot; + logger.forceLoopSplit = true; + logger.initialize(); + bot.loopCounter++; if (FULL_LOG === true) { logger.write("[INFO] run -> loop -> Entering function."); } @@ -156,7 +169,6 @@ const UTILITIES = require(ROOT_DIR + 'CloudUtilities'); const BLOB_STORAGE = require(ROOT_DIR + 'BlobStorage'); - const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); const STATUS_REPORT = require(ROOT_DIR + 'StatusReport'); const POLONIEX_CLIENT_MODULE = require(ROOT_DIR + 'PoloniexAPIClient'); const STATUS_DEPENDENCIES = require(ROOT_DIR + 'StatusDependencies'); @@ -204,7 +216,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); return; @@ -213,7 +225,7 @@ logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; @@ -222,7 +234,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -230,7 +242,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -266,7 +278,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); return; @@ -275,7 +287,7 @@ logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; @@ -284,7 +296,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -292,7 +304,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeUserBot -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -327,7 +339,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); return; @@ -349,21 +361,21 @@ } case "Month before it is needed.": { logger.write("[WARN] run -> loop -> startUserBot -> onFinished > Month before it is needed. This Loop will be terminated."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } case "Month fully processed.": { logger.write("[WARN] run -> loop -> startUserBot -> onFinished > Month fully processed. This Loop will be terminated."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } case "End of the month reached.": { logger.write("[WARN] run -> loop -> startUserBot -> onFinished > End of the month reached. This Loop will be terminated."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_OK_RESPONSE); return; @@ -377,7 +389,7 @@ } default: { logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled custom response received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); return; @@ -388,7 +400,7 @@ logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; @@ -397,7 +409,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -405,7 +417,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> startUserBot -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -413,7 +425,7 @@ } catch (err) { logger.write("[ERROR] run -> loop -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(err); } @@ -432,7 +444,7 @@ if (bot.runAtFixedInterval === true) { intervalHandle.clearInterval();} if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Stopping the Loop Gracefully. See you next time!"); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_OK_RESPONSE); return; @@ -447,29 +459,29 @@ case 'Normal': { if (bot.runAtFixedInterval === true) { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Fixed Interval Normal exit point reached."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } else { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.normalWaitTime / 1000) + " seconds."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.normalWaitTime); } } break; case 'Retry': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.retryWaitTime / 1000) + " seconds."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.retryWaitTime); } break; case 'Sleep': { if (bot.runAtFixedInterval === true) { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Fixed Interval Sleep exit point reached."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } else { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.sleepWaitTime / 60000) + " minutes."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.sleepWaitTime); } } @@ -477,11 +489,11 @@ case 'Coma': { if (bot.runAtFixedInterval === true) { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Fixed Interval Coma exit point reached."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } else { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.comaWaitTime / 3600000) + " hours."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.comaWaitTime); } } @@ -504,7 +516,7 @@ if (err.result !== global.DEFAULT_OK_RESPONSE.result) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> onFileReceived -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; @@ -522,7 +534,7 @@ } catch (err) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> onFileReceived -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; @@ -531,7 +543,7 @@ } catch (err) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; @@ -541,7 +553,7 @@ catch (err) { logger.write("[ERROR] run -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); clearInterval(intervalHandle); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } diff --git a/IndicatorBotProcessMainLoop.js b/IndicatorBotProcessMainLoop.js index c82c581ec..fbdae18f7 100644 --- a/IndicatorBotProcessMainLoop.js +++ b/IndicatorBotProcessMainLoop.js @@ -13,7 +13,9 @@ bot.eventHandler = EVENT_HANDLER_MODULE.newEventHandler(); const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); - const logger = DEBUG_MODULE.newDebugLog(); + let logger; + + logger = DEBUG_MODULE.newDebugLog(); logger.fileName = MODULE_NAME; logger.bot = bot; logger.forceLoopSplit = true; @@ -77,7 +79,7 @@ logger.write("[ERROR] initialize -> onInizialized -> onBotDownloaded -> err.message = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } @@ -105,7 +107,7 @@ logger.write("[ERROR] initialize -> onInizialized -> onBotDownloaded -> onCommonsDownloaded -> err.message = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } @@ -118,12 +120,12 @@ } else { logger.write("[ERROR] Root -> start -> getBotConfig -> onInizialized -> err = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); } } } catch (err) { logger.write("[ERROR] initialize -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -133,11 +135,22 @@ try { if (FULL_LOG === true) { logger.write("[INFO] run -> Entering function."); } + bot.eventHandler.raiseEvent("Close Log File"); + loop(); function loop() { try { + + /* For each loop we want to create a new log file. */ + + logger = DEBUG_MODULE.newDebugLog(); + logger.fileName = MODULE_NAME; + logger.bot = bot; + logger.forceLoopSplit = true; + logger.initialize(); + bot.loopCounter++; if (FULL_LOG === true) { logger.write("[INFO] run -> loop -> Entering function."); } @@ -146,7 +159,6 @@ const UTILITIES = require(ROOT_DIR + 'CloudUtilities'); const BLOB_STORAGE = require(ROOT_DIR + 'BlobStorage'); - const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); const STATUS_REPORT = require(ROOT_DIR + 'StatusReport'); const STATUS_DEPENDENCIES = require(ROOT_DIR + 'StatusDependencies'); @@ -194,7 +206,7 @@ case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -202,7 +214,7 @@ logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -210,14 +222,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -252,7 +264,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -260,7 +272,7 @@ logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -268,14 +280,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeUserBot -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -309,7 +321,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -330,19 +342,19 @@ } case "Month before it is needed.": { logger.write("[WARN] run -> loop -> startUserBot -> onFinished -> Month before it is needed. This Loop will be terminated."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } case "Month fully processed.": { logger.write("[WARN] run -> loop -> startUserBot -> onFinished -> Month fully processed. This Loop will be terminated."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } case "End of the month reached.": { logger.write("[WARN] run -> loop -> startUserBot -> onFinished -> End of the month reached. This Loop will be terminated."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } @@ -354,7 +366,7 @@ } default: { logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled custom response received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -364,7 +376,7 @@ logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -372,21 +384,21 @@ } catch (err) { logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> startUserBot -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -403,7 +415,7 @@ if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Stopping the Loop Gracefully. See you next time!"); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; @@ -416,25 +428,25 @@ switch (nextWaitTime) { case 'Normal': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.normalWaitTime / 1000) + " seconds."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.normalWaitTime); } break; case 'Retry': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.retryWaitTime / 1000) + " seconds."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.retryWaitTime); } break; case 'Sleep': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.sleepWaitTime / 60000) + " minutes."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.sleepWaitTime); } break; case 'Coma': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Restarting Loop in " + (processConfig.comaWaitTime / 3600000) + " hours."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.comaWaitTime); } break; @@ -456,7 +468,7 @@ if (err.result !== global.DEFAULT_OK_RESPONSE.result) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> onFileReceived -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -473,7 +485,7 @@ } catch (err) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> onFileReceived -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -481,7 +493,7 @@ } catch (err) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -490,7 +502,7 @@ catch (err) { logger.write("[ERROR] run -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/TradingBotProcessMainLoop.js b/TradingBotProcessMainLoop.js index 6cf0ebe33..acb82abf4 100644 --- a/TradingBotProcessMainLoop.js +++ b/TradingBotProcessMainLoop.js @@ -13,7 +13,9 @@ bot.eventHandler = EVENT_HANDLER_MODULE.newEventHandler(); const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); - const logger = DEBUG_MODULE.newDebugLog(); + let logger; + + logger = DEBUG_MODULE.newDebugLog(); logger.fileName = MODULE_NAME; logger.bot = bot; logger.forceLoopSplit = true; @@ -78,7 +80,7 @@ logger.write("[ERROR] initialize -> onInizialized -> onBotDownloaded -> err.message = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } @@ -106,7 +108,7 @@ logger.write("[ERROR] initialize -> onInizialized -> onBotDownloaded -> onCommonsDownloaded -> err.message = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); return; } @@ -119,12 +121,12 @@ } else { logger.write("[ERROR] Root -> start -> getBotConfig -> onInizialized -> err = " + err.message); callBackFunction(global.DEFAULT_FAIL_RESPONSE); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); } } } catch (err) { logger.write("[ERROR] initialize -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -134,11 +136,22 @@ try { if (FULL_LOG === true) { logger.write("[INFO] run -> Entering function."); } + bot.eventHandler.raiseEvent("Close Log File"); + loop(); function loop() { try { + + /* For each loop we want to create a new log file. */ + + logger = DEBUG_MODULE.newDebugLog(); + logger.fileName = MODULE_NAME; + logger.bot = bot; + logger.forceLoopSplit = true; + logger.initialize(); + bot.loopCounter++; if (FULL_LOG === true) { logger.write("[INFO] run -> loop -> Entering function."); } @@ -147,7 +160,6 @@ const UTILITIES = require(ROOT_DIR + 'CloudUtilities'); const BLOB_STORAGE = require(ROOT_DIR + 'BlobStorage'); - const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); const POLONIEX_CLIENT_MODULE = require(ROOT_DIR + 'PoloniexAPIClient'); const EXCHANGE_API = require(ROOT_DIR + 'ExchangeAPI'); const CONTEXT = require(ROOT_DIR + 'Context'); @@ -255,7 +267,7 @@ if (FULL_LOG === true) { logger.write("[INFO] run -> loop -> End of Backtesting Period reached. Exiting Bot Process Loop."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } @@ -300,7 +312,7 @@ if (FULL_LOG === true) { logger.write("[INFO] run -> loop -> End of Competition Period reached. Exiting Bot Process Loop."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; } @@ -310,7 +322,7 @@ default: { logger.write("[ERROR] run -> loop -> Unexpected bot.startMode."); logger.write("[ERROR] run -> loop -> bot.startMode = " + bot.startMode); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -365,7 +377,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -373,7 +385,7 @@ logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -381,14 +393,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -423,7 +435,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -431,7 +443,7 @@ logger.write("[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -439,14 +451,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeDataDependencies -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -480,7 +492,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -488,7 +500,7 @@ logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -496,14 +508,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeContext -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -538,7 +550,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -546,7 +558,7 @@ logger.write("[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -554,14 +566,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeContext -> onInizialized -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeExchangeAPI -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -595,7 +607,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeAssistant -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -603,7 +615,7 @@ logger.write("[ERROR] run -> loop -> initializeAssistant -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeAssistant -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -611,14 +623,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeAssistant -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeAssistant -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -653,7 +665,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -661,7 +673,7 @@ logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -669,14 +681,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> initializeUserBot -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -709,7 +721,7 @@ } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -717,7 +729,7 @@ logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -725,14 +737,14 @@ } catch (err) { logger.write("[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> startUserBot -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -760,13 +772,13 @@ } case global.DEFAULT_RETRY_RESPONSE.result: { // Something bad happened, but if we retry in a while it might go through the next time. logger.write("[ERROR] run -> loop -> saveContext -> onFinished -> Can not retry at this point."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle. logger.write("[ERROR] run -> loop -> saveContext -> onFinished -> Operation Failed. Aborting the process."); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); return; } @@ -774,7 +786,7 @@ logger.write("[ERROR] run -> loop -> saveContext -> onFinished -> Unhandled err.result received. -> err.result = " + err.result); logger.write("[ERROR] run -> loop -> saveContext -> onFinished -> Unhandled err.result received. -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -782,21 +794,21 @@ } catch (err) { logger.write("[ERROR] run -> loop -> saveContext -> onFinished -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> saveContext -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } } catch (err) { logger.write("[ERROR] run -> loop -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(err); } } @@ -812,7 +824,7 @@ function onStop() { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Stopping the Loop Gracefully. See you next time!"); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_OK_RESPONSE); return; @@ -825,25 +837,25 @@ switch (nextWaitTime) { case 'Normal': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Normal -> Restarting Loop in " + (processConfig.normalWaitTime / 1000) + " seconds."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.normalWaitTime); } break; case 'Retry': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Retry -> Restarting Loop in " + (processConfig.retryWaitTime / 1000) + " seconds."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.retryWaitTime); } break; case 'Sleep': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Sleep -> Restarting Loop in " + (processConfig.sleepWaitTime / 60000) + " minutes."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.sleepWaitTime); } break; case 'Coma': { if (FULL_LOG === true) { logger.write("[INFO] run -> loopControl -> Coma -> Restarting Loop in " + (processConfig.comaWaitTime / 3600000) + " hours."); } - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); setTimeout(loop, processConfig.comaWaitTime); } break; @@ -865,7 +877,7 @@ if (err.result !== global.DEFAULT_OK_RESPONSE.result) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> onFileReceived -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -882,7 +894,7 @@ } catch (err) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> onFileReceived -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -890,7 +902,7 @@ } catch (err) { logger.write("[ERROR] run -> loopControl -> shallWeStop -> err.message = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -899,7 +911,7 @@ catch (err) { logger.write("[ERROR] run -> err = " + err.message); - bot.eventHandler.raiseEvent("Loop Finished"); + bot.eventHandler.raiseEvent("Close Log File"); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } }