fez5587/Superalgos
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Corrections on Logging

Browse Source
This commit is contained in:
Luis Fernando Molina committed 2018-06-03 23:39:03 +02:00
1 parent ea2d376ab6
commit fb11a7ef3e
4 files changed
+157 -121
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

DebugLog.js
+2 -2
View File
@@ -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);
}
}
ExtractionBotProcessMainLoop.js
+47 -35
View File
@@ -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);
}
IndicatorBotProcessMainLoop.js
+44 -32
View File
@@ -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);
}
}
TradingBotProcessMainLoop.js
+64 -52
View File
@@ -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);
}
}