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

Canceling Helth Timeout on fail errors

Browse Source
This commit is contained in:
Luis Fernando Molina committed 2018-06-13 23:47:10 +02:00
1 parent 187b2ff82b
commit 2ae5e2a68e
4 files changed
+153 -1
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

ExtractionBotProcessMainLoop.js
+26
View File
@@ -215,6 +215,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -224,6 +225,7 @@
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -233,6 +235,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -241,6 +244,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -277,6 +281,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized > Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -287,6 +292,7 @@
logger.write(MODULE_NAME, "[WARN] run -> loop -> initializeUserBot -> onInizialized > Too far in the future. This Loop will enter in coma.");
nextWaitTime = 'Coma';
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
loopControl(nextWaitTime);
return;
}
@@ -294,6 +300,7 @@
logger.write(MODULE_NAME, "[WARN] run -> loop -> initializeUserBot -> onInizialized > Not needed now, but soon. This Loop will continue with Normal wait time.");
nextWaitTime = 'Normal';
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
loopControl(nextWaitTime);
return;
}
@@ -301,6 +308,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled custom response received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -312,6 +320,7 @@
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -321,6 +330,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -329,6 +339,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -364,6 +375,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished > Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -386,6 +398,7 @@
logger.write(MODULE_NAME, "[WARN] run -> loop -> startUserBot -> onFinished > Month before it is needed. This Loop will be terminated.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
@@ -393,6 +406,7 @@
logger.write(MODULE_NAME, "[WARN] run -> loop -> startUserBot -> onFinished > Month fully processed. This Loop will be terminated.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
@@ -400,6 +414,7 @@
logger.write(MODULE_NAME, "[WARN] run -> loop -> startUserBot -> onFinished > End of the month reached. This Loop will be terminated.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
@@ -407,6 +422,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished > Unhandled custom response received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -418,6 +434,7 @@
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -427,6 +444,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -435,6 +453,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -455,6 +474,7 @@
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] run -> loop -> loopControl -> onStop -> Stopping the Loop Gracefully. See you next time!"); }
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
@@ -577,6 +597,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onInizialized -> global.CURRENT_EXECUTION_AT = " + global.CURRENT_EXECUTION_AT);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -592,6 +613,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onFileReceived -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -610,6 +632,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onFileReceived -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -621,6 +644,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -629,6 +653,7 @@
} catch (err) {
parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.message);
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -637,6 +662,7 @@
catch (err) {
parentLogger.write(MODULE_NAME, "[ERROR] run -> err = " + err.message);
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
}
}
IndicatorBotProcessMainLoop.js
+40
View File
@@ -215,6 +215,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -223,6 +225,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -231,6 +235,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -238,6 +244,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -273,6 +281,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -294,6 +304,8 @@
default: {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized > Unhandled custom response received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -304,6 +316,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -312,6 +326,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -319,6 +335,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -353,6 +371,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -374,24 +394,32 @@
case "Month before it is needed.": {
logger.write(MODULE_NAME, "[WARN] run -> loop -> startUserBot -> onFinished -> Month before it is needed. This Loop will be terminated.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
case "Month fully processed.": {
logger.write(MODULE_NAME, "[WARN] run -> loop -> startUserBot -> onFinished -> Month fully processed. This Loop will be terminated.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
case "End of the month reached.": {
logger.write(MODULE_NAME, "[WARN] run -> loop -> startUserBot -> onFinished -> End of the month reached. This Loop will be terminated.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
default: {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled custom response received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -402,6 +430,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -410,6 +440,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -417,6 +449,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -540,6 +574,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onInizialized -> global.CURRENT_EXECUTION_AT = " + global.CURRENT_EXECUTION_AT);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -555,6 +590,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onFileReceived -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -573,6 +609,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onFileReceived -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -584,6 +621,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -592,6 +630,7 @@
} catch (err) {
parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.message);
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -600,6 +639,7 @@
catch (err) {
parentLogger.write(MODULE_NAME, "[ERROR] run -> err = " + err.message);
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
}
}
PoloniexAPIClient.js
+7 -1
View File
@@ -403,7 +403,7 @@
const FULL_LOG = false;
const LOG_FILE_CONTENT = false;
const MODULE_NAME = "Poloniex API ClientS";
const MODULE_NAME = "Poloniex API Client";
/* This function analizes the different situations we might encounter trying to access Poloniex and returns appropiate standard errors. */
@@ -427,6 +427,8 @@
stringExchangeResponse.indexOf("Internal error. Please try again") > 0))) {
logger.write(MODULE_NAME, "[WARN] analizeResponse -> Timeout reached or connection problem while trying to access the Exchange API. Requesting new execution later.");
logger.write(MODULE_NAME, "[WARN] analizeResponse -> stringExchangeErr = " + stringExchangeErr);
notOkCallBack(global.DEFAULT_RETRY_RESPONSE);
return;
@@ -435,6 +437,8 @@
if (JSON.stringify(exchangeResponse).indexOf("error") > 0) {
logger.write(MODULE_NAME, "[ERROR] analizeResponse -> Unexpected response from the Exchange.");
logger.write(MODULE_NAME, "[ERROR] analizeResponse -> exchangeResponse = " + exchangeResponse);
notOkCallBack(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -442,6 +446,8 @@
if (exchangeErr) {
logger.write(MODULE_NAME, "[ERROR] analizeResponse -> Unexpected error trying to contact the Exchange.");
logger.write(MODULE_NAME, "[ERROR] analizeResponse -> exchangeErr = " + exchangeErr);
notOkCallBack(global.DEFAULT_FAIL_RESPONSE);
return;
TradingBotProcessMainLoop.js
+80
View File
@@ -275,6 +275,8 @@
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] run -> loop -> End of Backtesting Period reached. Exiting Bot Process Loop."); }
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
@@ -320,6 +322,8 @@
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] run -> loop -> End of Competition Period reached. Exiting Bot Process Loop."); }
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
}
@@ -330,6 +334,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> Unexpected bot.startMode.");
logger.write(MODULE_NAME, "[ERROR] run -> loop -> bot.startMode = " + bot.startMode);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -385,6 +391,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -393,6 +401,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -401,6 +411,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -408,6 +420,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -443,6 +457,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -451,6 +467,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -459,6 +477,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -466,6 +486,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -500,6 +522,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -508,6 +532,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -516,6 +542,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -523,6 +551,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -558,6 +588,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -566,6 +598,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -574,6 +608,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -581,6 +617,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -615,6 +653,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -623,6 +663,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -631,6 +673,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -638,6 +682,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -673,6 +719,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -681,6 +729,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -689,6 +739,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -696,6 +748,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -729,6 +783,8 @@
case global.DEFAULT_FAIL_RESPONSE.result: { // This is an unexpected exception that we do not know how to handle.
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -737,6 +793,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -745,6 +803,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -752,6 +812,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -780,12 +842,16 @@
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(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> onFinished -> Can not retry at this point.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
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(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> onFinished -> Operation Failed. Aborting the process.");
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
return;
}
@@ -794,6 +860,8 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> onFinished -> Unhandled err.result received. -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -802,6 +870,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> onFinished -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -809,6 +879,8 @@
} catch (err) {
logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> err = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -828,6 +900,8 @@
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] run -> loop -> loopControl -> onStop -> Stopping the Loop Gracefully. See you next time!"); }
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_OK_RESPONSE);
return;
@@ -931,6 +1005,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onInizialized -> global.CURRENT_EXECUTION_AT = " + global.CURRENT_EXECUTION_AT);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -946,6 +1021,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onFileReceived -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -964,6 +1040,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> onFileReceived -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -975,6 +1052,7 @@
logger.write(MODULE_NAME, "[ERROR] run -> loop -> shallWeStop -> err.message = " + err.message);
logger.persist();
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
@@ -983,6 +1061,7 @@
} catch (err) {
parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.message);
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(err);
}
}
@@ -991,6 +1070,7 @@
catch (err) {
parentLogger.write(MODULE_NAME, "[ERROR] run -> err = " + err.message);
clearInterval(intervalHandle);
clearTimeout(timeoutHandle);
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
}
}