From f23d917a4427a7f26869fdbb8abe96a7e9355c47 Mon Sep 17 00:00:00 2001 From: Matias Date: Wed, 10 Jul 2019 08:35:51 -0300 Subject: [PATCH] Error log entries and retry file on storage --- Assistant.js | 38 +++++++++---------- CloudUtilities.js | 2 +- Context.js | 35 ++++++++---------- DataDependencies.js | 4 +- DataSet.js | 6 +-- DebugLog.js | 15 ++++---- IndicatorBotProcessMainLoop.js | 30 +++++++-------- Integrations/FileStorage.js | 67 +++++++++++++++++++--------------- MultiPeriodDaily.js | 63 +++++++++++++------------------- MultiPeriodMarket.js | 30 +++++++-------- Root.js | 32 ++++++++-------- Run.js | 2 +- SensorBotProcessMainLoop.js | 22 +++++------ StatusDependencies.js | 6 +-- StatusReport.js | 44 ++++++++++------------ TradingBotProcessMainLoop.js | 38 +++++++++---------- docker-compose.yml | 2 +- package.json | 2 +- 18 files changed, 212 insertions(+), 226 deletions(-) diff --git a/Assistant.js b/Assistant.js index 1899ad19c..e63fe4932 100644 --- a/Assistant.js +++ b/Assistant.js @@ -114,13 +114,13 @@ validateExchangeSyncronicity(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromExchange -> onTicker -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromExchange -> onTicker -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromExchange -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromExchange -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -211,7 +211,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromIndicator -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromIndicator -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -253,13 +253,13 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> validateExchangeSyncronicity -> onDone -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> validateExchangeSyncronicity -> onDone -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> onDone -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> onDone -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -313,14 +313,14 @@ callBackFunction(global.DEFAULT_OK_RESPONSE); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> calculateProfits -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> calculateProfits -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -399,7 +399,7 @@ } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] getPositionsAtExchange -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] getPositionsAtExchange -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -626,12 +626,12 @@ break; } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> onResponse -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> onResponse -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -702,7 +702,7 @@ next(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasExecuted -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasExecuted -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } @@ -788,7 +788,7 @@ next(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasPartiallyExecuted -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasPartiallyExecuted -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } @@ -863,14 +863,14 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> applyTradesToContext -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> applyTradesToContext -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } @@ -909,7 +909,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -1073,12 +1073,12 @@ break; } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] putPosition -> onResponse -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] putPosition -> onResponse -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] putPosition -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] putPosition -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -1197,12 +1197,12 @@ break; } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] movePosition -> onResponse -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] movePosition -> onResponse -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] movePosition -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] movePosition -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/CloudUtilities.js b/CloudUtilities.js index 18bbcf05f..09d5d848d 100644 --- a/CloudUtilities.js +++ b/CloudUtilities.js @@ -46,7 +46,7 @@ exports.newCloudUtilities = function newCloudUtilities(logger) { if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] createFolderIfNeeded -> loop -> checkLoop -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] createFolderIfNeeded -> loop -> checkLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] createFolderIfNeeded -> loop -> checkLoop -> err = ", err); callBackFunction(err); return; } diff --git a/Context.js b/Context.js index a7d4987d6..5cbdf9fd9 100644 --- a/Context.js +++ b/Context.js @@ -119,7 +119,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> onDone -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> onDone -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -150,7 +150,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getStatusReport -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getStatusReport -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -169,7 +169,7 @@ function onFileReceived(err, text) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> onFileReceived -> err = ", err); callBack(err); return; } @@ -204,7 +204,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -230,7 +230,7 @@ function onFileReceived(err, text) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> onFileReceived -> err = ", err); callBack(err); return; } @@ -271,7 +271,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -333,13 +333,13 @@ callBack(global.DEFAULT_OK_RESPONSE); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> createConext -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> createConext -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -380,7 +380,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> onDone -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> onDone -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -401,8 +401,6 @@ callBackFunction(global.DEFAULT_ERROR_RESPONSE); } - if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExecutionContext -> fileName = " + fileName); } - if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExecutionContext -> filePath = " + filePath); } if (global.LOG_CONTROL[MODULE_NAME].logContent === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExecutionContext -> fileContent = " + fileContent); } fileStorage.createTextFile(global.DEV_TEAM, filePath, fileContent + '\n', onFileCreated); @@ -412,7 +410,7 @@ if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExecutionContext -> onFileCreated -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> onFileCreated -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> onFileCreated -> err = ", err); callBack(err); return; } @@ -423,7 +421,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -437,9 +435,6 @@ let fileName = "/Execution.History." + bot.startMode + "." + runIndex + ".json"; let filePath = bot.filePathRoot + "/Output/" + bot.process + fileName; - if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExucutionHistory -> fileName = " + fileName); } - if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExucutionHistory -> filePath = " + filePath); } - let newRecord = [ thisObject.newHistoryRecord.date.valueOf(), thisObject.newHistoryRecord.buyAvgRate, @@ -476,7 +471,7 @@ if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExucutionHistory -> onFileCreated -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> onFileCreated -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> onFileCreated -> err = ", err); callBack(err); return; } @@ -498,7 +493,7 @@ if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] saveThemAll -> writeExucutionHistory -> onFileCreated -> onSequenceFileCreated -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> onFileCreated -> onSequenceFileCreated -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> onFileCreated -> onSequenceFileCreated -> err = ", err); callBack(err); return; } @@ -510,7 +505,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -526,7 +521,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeStatusReport -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeStatusReport -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/DataDependencies.js b/DataDependencies.js index 5db7121d1..7fb40a38c 100644 --- a/DataDependencies.js +++ b/DataDependencies.js @@ -47,7 +47,7 @@ function onInitilized(err) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] initialize -> onInitilized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> onInitilized -> err = ", err); alreadyCalledBack = true; callBackFunction(err); @@ -82,7 +82,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/DataSet.js b/DataSet.js index 7a3c48c3e..5d63ec26d 100644 --- a/DataSet.js +++ b/DataSet.js @@ -33,7 +33,7 @@ callBackFunction(global.DEFAULT_OK_RESPONSE); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -59,7 +59,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] 'getTextFile' -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] 'getTextFile' -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -100,7 +100,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] 'createTextFile' -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] 'createTextFile' -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/DebugLog.js b/DebugLog.js index 06e758a42..867500cb2 100644 --- a/DebugLog.js +++ b/DebugLog.js @@ -35,7 +35,7 @@ exports.newDebugLog = function newDebugLog() { disableLogging = pdisableLogging } catch (err) { - console.log("[ERROR] Debug Log -> initialize -> err = " + err.message); + console.log("[ERROR] Debug Log -> initialize -> err = ", err); } } @@ -94,9 +94,7 @@ exports.newDebugLog = function newDebugLog() { function onFileCreated(err) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - console.log("[ERROR] DebugLog -> persist -> onInizialized -> onFileCreated -> err = " + err.message); - console.log("[ERROR] DebugLog -> persist -> onInizialized -> onFileCreated -> filePath = " + filePath); - console.log("[ERROR] DebugLog -> persist -> onInizialized -> onFileCreated -> fileName = " + fileName); + console.log("[ERROR] DebugLog -> persist -> onInizialized -> onFileCreated -> err = ", err); setTimeout(writeLog, 10000); // Lets retry until we make it. return; @@ -107,7 +105,7 @@ exports.newDebugLog = function newDebugLog() { } } } catch (err) { - console.log("[ERROR] DebugLog -> persist -> err = " + err.message); + console.log("[ERROR] DebugLog -> persist -> err = ", err); console.log("[ERROR] DebugLog -> persist -> onInizialized -> contentToPersist = " + contentToPersist); } } @@ -128,12 +126,15 @@ exports.newDebugLog = function newDebugLog() { /* When writting one file for all modules we use this. */ - let logLine = '\r\n' + "['" + newDate + "'," + messageId + ",'" + pModule + "','" + pMessage + "']"; + let message = "['" + newDate + "'," + messageId + ",'" + pModule + "','" + pMessage + "']" + let logLine = '\r\n' + message; + + console.log(message) accumulatedLog = accumulatedLog + logLine; } catch (err) { - console.log("[ERROR] DebugLog -> write -> err = " + err.message); + console.log("[ERROR] DebugLog -> write -> err = ", err); } } diff --git a/IndicatorBotProcessMainLoop.js b/IndicatorBotProcessMainLoop.js index e22c9979a..d322089bb 100644 --- a/IndicatorBotProcessMainLoop.js +++ b/IndicatorBotProcessMainLoop.js @@ -75,7 +75,7 @@ } } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -202,7 +202,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -213,7 +213,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -305,7 +305,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -316,7 +316,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -406,7 +406,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -417,7 +417,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -536,7 +536,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -547,7 +547,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -635,7 +635,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -646,7 +646,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> intitializeProcessFramework -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -765,7 +765,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> onFinished -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -776,7 +776,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startProcessFramework -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -908,7 +908,7 @@ } } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = ", err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); @@ -917,7 +917,7 @@ } } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] run -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] run -> err = ", err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); diff --git a/Integrations/FileStorage.js b/Integrations/FileStorage.js index b5a962be3..20620bdec 100644 --- a/Integrations/FileStorage.js +++ b/Integrations/FileStorage.js @@ -3,7 +3,8 @@ const Ecosystem = require('./Ecosystem') exports.newFileStorage = function newFileStorage() { const INFO_LOG = true - const ERROR_LOG = true + const MAX_RETRY = 30 + let currentRetry = 0 let thisObject = { getTextFile, @@ -14,11 +15,11 @@ exports.newFileStorage = function newFileStorage() { async function getTextFile(container, filePath, callBackFunction) { try { - if (INFO_LOG === true) { console.log('[INFO] getTextFile -> Entering function: ' + container.toLowerCase() + '/' + filePath) } + if (INFO_LOG === true) { console.log('[INFO] getTextFile: ' + container.toLowerCase() + '/' + filePath.substring(filePath.length -110 , filePath.length)) } let host = await getDevTeamHost(container) - axios({ + let response = await axios({ url: host.url + 'graphql', method: 'post', data: { @@ -36,36 +37,36 @@ exports.newFileStorage = function newFileStorage() { } } } - }).then(res => { - if (res.data.errors) { - let error = { - code: res.data.errors[0] - } - callBackFunction(error) - return - } - let response = res.data.data.web_FileContent - if (response) { - callBackFunction(global.DEFAULT_OK_RESPONSE, response) - } else { - let error = { code: 'The specified key does not exist.' } - callBackFunction(error) - } - }).catch(error => { - if (ERROR_LOG === true) { console.log('newFileStorage: [ERROR] getTextFile -> Invalid JSON received. ') } - if (ERROR_LOG === true) { console.log('newFileStorage: [ERROR] getTextFile -> error = ', error) } - callBackFunction(global.DEFAULT_FAIL_RESPONSE) }) + + currentRetry = 0 + if (response.data.errors) { + callBackFunction({ code: res.data.errors[0] }) + return + } + + if (response.data.data.web_FileContent) { + callBackFunction(global.DEFAULT_OK_RESPONSE, response.data.data.web_FileContent) + } else { + callBackFunction({ code: 'The specified key does not exist.' }) + } + } catch (err) { - if (ERROR_LOG === true) { console.log('[ERROR] getTextFile -> err = ', err) } - if (ERROR_LOG === true) { console.log('[ERROR] getTextFile -> stack = ', err.stack) } - callBackFunction(global.DEFAULT_FAIL_RESPONSE) + if ((err.code === 'ETIMEDOUT' || err.code === 'ECONNRESET') && currentRetry < MAX_RETRY) { + if (INFO_LOG === true) { console.log('[INFO] getTextFile -> Retrying connection to the server because received error: '+err.code) } + currentRetry++ + getTextFile(container, filePath, callBackFunction) + } else { + currentRetry = 0 + console.log('[ERROR] getTextFile -> error = ', err) + callBackFunction(global.DEFAULT_FAIL_RESPONSE) + } } } async function createTextFile(container, filePath, fileContent, callBackFunction) { try { - if (INFO_LOG === true) { console.log('[INFO] createTextFile -> Entering function: ' + container.toLowerCase() + '/' + filePath) } + if (INFO_LOG === true) { console.log('[INFO] createTextFile -> Entering function: ' + container.toLowerCase() + '/' + filePath.substring(filePath.length -110 , filePath.length)) } let host = await getDevTeamHost(container) @@ -90,15 +91,23 @@ exports.newFileStorage = function newFileStorage() { } }) + currentRetry = 0 + if (!response || response.data.errors) callBackFunction(global.CUSTOM_FAIL_RESPONSE) else callBackFunction(global.DEFAULT_OK_RESPONSE) } catch (err) { - if (ERROR_LOG === true) { console.log('[ERROR] createTextFile -> err = ', err.stack) } - if (ERROR_LOG === true) { console.log('[ERROR] createTextFile -> stack = ', err.stack) } - callBackFunction(global.DEFAULT_FAIL_RESPONSE) + if ((err.code === 'ETIMEDOUT' || err.code === 'ECONNRESET') && currentRetry < MAX_RETRY) { + if (INFO_LOG === true) { console.log('[INFO] createTextFile -> Retrying connection to the server because received error: '+err.code) } + currentRetry++ + createTextFile(container, filePath, fileContent, callBackFunction) + } else { + currentRetry = 0 + console.log('[ERROR] createTextFile -> error = ', err) + callBackFunction(global.DEFAULT_FAIL_RESPONSE) + } } } diff --git a/MultiPeriodDaily.js b/MultiPeriodDaily.js index 526867dfe..8650ef641 100644 --- a/MultiPeriodDaily.js +++ b/MultiPeriodDaily.js @@ -62,7 +62,7 @@ usertBot.initialize(dataDependencies, callBackFunction); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -266,7 +266,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> getContextVariables -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> getContextVariables -> err = ", err); if (err.message === "Cannot read property 'file' of undefined") { logger.write(MODULE_NAME, "[HINT] start -> getContextVariables -> Check the bot configuration to see if all of its statusDependencies declarations are correct. "); logger.write(MODULE_NAME, "[HINT] start -> getContextVariables -> Dependencies loaded -> keys = " + JSON.stringify(statusDependencies.keys)); @@ -321,7 +321,7 @@ periodsLoop(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> advanceTime -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> advanceTime -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -344,7 +344,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -438,18 +438,14 @@ if ((err.result === "Fail Because" && err.message === "File does not exist.") || err.code === 'The specified key does not exist.') { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = " + err.message); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> filePath = " + filePath); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> fileName = " + fileName); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = ", err); callBackFunction(global.DEFAULT_RETRY_RESPONSE); return; } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> err = " + err.message); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> filePath = " + filePath); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> fileName = " + fileName); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> err = ", err); callBackFunction(err); return; } @@ -460,13 +456,13 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -492,18 +488,14 @@ if ((err.result === "Fail Because" && err.message === "File does not exist.") || err.code === 'The specified key does not exist.') { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = " + err.message); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> filePath = " + filePath); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> fileName = " + fileName); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = ", err); callBackFunction(global.DEFAULT_RETRY_RESPONSE); return; } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = " + err.message); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> filePath = " + filePath); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> fileName = " + fileName); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = ", err); callBackFunction(err); return; } @@ -517,19 +509,19 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> dependencyLoopBody -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> dependencyLoopBody -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -553,7 +545,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -593,19 +585,19 @@ periodsControlLoop(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> onBotFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> onBotFinished -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -635,7 +627,7 @@ if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimePeriods -> controlLoop -> onWritten -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> controlLoop -> onWritten -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> controlLoop -> onWritten -> err = ", err); callBackFunction(err); return; } @@ -643,21 +635,21 @@ writeStatusReport(bot.processDatetime, advanceTime); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> controlLoop -> onWritten -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> controlLoop -> onWritten -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsControlLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsControlLoop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -690,7 +682,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeDataRanges -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> writeDataRanges -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } @@ -712,9 +704,6 @@ let fileName = '/Data.Range.' + market.assetA + '_' + market.assetB + '.json'; let filePath = bot.filePathRoot + "/Output/" + pProductFolder + "/" + bot.process + fileName; - if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> writeDataRange -> fileName = " + fileName); } - if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> writeDataRange -> filePath = " + filePath); } - fileStorage.createTextFile(global.DEV_TEAM, filePath, fileContent + '\n', onFileCreated); function onFileCreated(err) { @@ -722,7 +711,7 @@ if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> writeDataRange -> onFileCreated -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> onFileCreated -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> onFileCreated -> err = ", err); callBack(err); return; } @@ -735,7 +724,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> err = ", err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -758,14 +747,14 @@ bot.hasTheBotJustStarted = false; } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/MultiPeriodMarket.js b/MultiPeriodMarket.js index 12e05a729..2990cbc56 100644 --- a/MultiPeriodMarket.js +++ b/MultiPeriodMarket.js @@ -58,7 +58,7 @@ usertBot.initialize(dataDependencies, callBackFunction); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -124,7 +124,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -183,9 +183,7 @@ if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = " + err.message); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> filePath = " + filePath); - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> fileName = " + fileName); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = ", err); callBackFunction(err); return; } @@ -197,20 +195,20 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> dependencyLoopBody -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> dependencyLoopBody -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -234,7 +232,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -271,19 +269,19 @@ periodsControlLoop(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> onBotFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> onBotFinished -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch(err){ - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -307,14 +305,14 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsControlLoop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsControlLoop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -333,14 +331,14 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/Root.js b/Root.js index f8e36433a..ef5e0b714 100644 --- a/Root.js +++ b/Root.js @@ -117,7 +117,7 @@ logInfo: true, logWarnings: false, logErrors: true, - logContent: true, + logContent: false, intensiveLogging: false } }; @@ -175,9 +175,7 @@ function onFileReceived(err, text) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = " + err.message); - console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> filePath = " + filePath); - console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> fileName = " + fileName); + console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = ", err); return; } @@ -187,7 +185,7 @@ botConfig.repo = cloneToExecute.repo; findProcess(); } catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = ", err); return; } } @@ -523,7 +521,7 @@ } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> err = ", err); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> Execution will be stopped. "); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> Bye."); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> Bot Id = " + botId); @@ -535,16 +533,16 @@ } } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> err = ", err); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> Bot will not be started. "); - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> err = ", err); logger.persist(); } } } catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runSensorBot -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runSensorBot -> err = ", err); } } @@ -593,7 +591,7 @@ } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> err = ", err); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Execution will be stopped. "); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bye."); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot Id = " + botId); @@ -603,15 +601,15 @@ } } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> err = ", err); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> Failed to initialize the bot. "); - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> err = ", err); logger.persist(); } } } catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> err = ", err); } } @@ -770,7 +768,7 @@ } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> err = ", err); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> Execution will be stopped. "); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> Bye."); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> Bot Id = " + botId); @@ -780,9 +778,9 @@ } } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> err = ", err); logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> Bot will not be started. "); - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> err = ", err); logger.persist(); } @@ -790,7 +788,7 @@ } } catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> err = " + err.message); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> err = ", err); } } diff --git a/Run.js b/Run.js index b3e4a4463..b95601aa8 100644 --- a/Run.js +++ b/Run.js @@ -122,7 +122,7 @@ function readExecutionConfiguration() { } catch (err) { - console.log("[ERROR] readExecutionConfiguration -> err = " + err.message); + console.log("[ERROR] readExecutionConfiguration -> err = ", err); console.log("[ERROR] readExecutionConfiguration -> Please verify that the Start Mode for the type of Bot configured applies to that type."); console.log("[ERROR] readExecutionConfiguration -> err = " + err.stack); } diff --git a/SensorBotProcessMainLoop.js b/SensorBotProcessMainLoop.js index 21ceb375f..a21d1402a 100644 --- a/SensorBotProcessMainLoop.js +++ b/SensorBotProcessMainLoop.js @@ -73,7 +73,7 @@ } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -197,7 +197,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -208,7 +208,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -271,7 +271,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -282,7 +282,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -380,7 +380,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -391,7 +391,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -510,7 +510,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -521,7 +521,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -679,7 +679,7 @@ } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] run -> loop -> err = ", err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); @@ -690,7 +690,7 @@ } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] run -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] run -> err = ", err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); diff --git a/StatusDependencies.js b/StatusDependencies.js index 5159c4e24..1f36a6885 100644 --- a/StatusDependencies.js +++ b/StatusDependencies.js @@ -39,7 +39,7 @@ function onInitilized(err) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] initialize -> onInitilized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> onInitilized -> err = ", err); alreadyCalledBack = true; callBackFunction(err); @@ -94,7 +94,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> onLoad -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -128,7 +128,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/StatusReport.js b/StatusReport.js index d1c583b4c..69248015a 100644 --- a/StatusReport.js +++ b/StatusReport.js @@ -56,7 +56,7 @@ } callBackFunction(global.DEFAULT_OK_RESPONSE); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -98,7 +98,7 @@ if ( err.result === global.CUSTOM_FAIL_RESPONSE.result && (err.message === 'Folder does not exist.' || err.message === 'File does not exist.') || err.code === "The specified key does not exist.") { - logger.write(MODULE_NAME, "[INFO] load -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[INFO] load -> onFileReceived -> err = ", err); /* In this case we can assume that this is the first execution ever of this bot.*/ @@ -114,7 +114,7 @@ } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] load -> onFileReceived -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] load -> onFileReceived -> err = ", err); callBackFunction(err); return; } @@ -148,7 +148,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] load -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] load -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -181,10 +181,6 @@ } filePath += '/' + fileName - - if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] save -> fileName = " + fileName); } - if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] save -> filePath = " + filePath); } - let fileContent = JSON.stringify(thisObject.file); fileStorage.createTextFile(owner.devTeam, filePath, fileContent + '\n', onFileCreated); @@ -194,7 +190,7 @@ if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] save -> onFileCreated -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] save -> onFileCreated -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] save -> onFileCreated -> err = ", err); callBackFunction(err); return; } @@ -209,7 +205,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] save -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] save -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -250,7 +246,7 @@ err.result === global.CUSTOM_FAIL_RESPONSE.result && (err.message === 'Status Report was never created.') ) { - logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> onLoad -> err = ", err); /* The first month of the market didnt create the main report yet. Aborting verification. */ @@ -261,7 +257,7 @@ } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = ", err); callBackFunction(err); return; } @@ -274,7 +270,7 @@ loopCycle(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -304,7 +300,7 @@ err.result === global.CUSTOM_FAIL_RESPONSE.result && (err.message === 'Status Report was never created.') ) { - logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> loopCycle -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> loopCycle -> onLoad -> err = ", err); /* The first month of the market didnt create the main report yet. Aborting verification. */ @@ -315,7 +311,7 @@ } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = ", err); callBackFunction(err); return; } @@ -335,13 +331,13 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -368,7 +364,7 @@ if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> err = ", err); callBackFunction(err); return; } @@ -388,7 +384,7 @@ if (global.LOG_CONTROL[MODULE_NAME].logInfo === true) { logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> Entering function."); } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = ", err); callBackFunction(err); return; } @@ -396,7 +392,7 @@ loop(); // Lets see the next month. } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -411,13 +407,13 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -451,14 +447,14 @@ loopCycle(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loop -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loop -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } diff --git a/TradingBotProcessMainLoop.js b/TradingBotProcessMainLoop.js index 1c39f67dd..416b13e94 100644 --- a/TradingBotProcessMainLoop.js +++ b/TradingBotProcessMainLoop.js @@ -72,7 +72,7 @@ } } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -334,7 +334,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -345,7 +345,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeStatusDependencies -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -408,7 +408,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -419,7 +419,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeDataDependencies -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -481,7 +481,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -492,7 +492,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -555,7 +555,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeContext -> onInizialized -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -566,7 +566,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeExchangeAPI -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -628,7 +628,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -639,7 +639,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeAssistant -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -702,7 +702,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> onInizialized -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -713,7 +713,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> initializeUserBot -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -774,7 +774,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> onFinished -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -785,7 +785,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> startUserBot -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -851,7 +851,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> onFinished -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> onFinished -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -862,7 +862,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> saveContext -> err = ", err); logger.persist(); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); @@ -882,7 +882,7 @@ loopControl(nextWaitTime); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] run -> loop -> updateClonesModule -> err = " + err.message); + logger.write(MODULE_NAME, "[ERROR] run -> loop -> updateClonesModule -> err = ", err); logger.write(MODULE_NAME, "[ERROR] run -> loop -> updateClonesModule -> Execution will continue anyways. "); nextWaitTime = 'Normal'; loopControl(nextWaitTime); @@ -1030,7 +1030,7 @@ } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] run -> err = " + err.message); + parentLogger.write(MODULE_NAME, "[ERROR] run -> err = ", err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); diff --git a/docker-compose.yml b/docker-compose.yml index 9af751fd0..7f531bd5b 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -1,7 +1,7 @@ version: '3' services: node: - image: superalgos/clone-executor:1.0.37 + image: superalgos/clone-executor:1.0.40 build: context: . dockerfile: ./Dockerfile diff --git a/package.json b/package.json index 31a8422e0..bf4cdac65 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@superalgos/clone-executor", - "version": "1.0.37", + "version": "1.0.40", "description": "Module responsible for executing the bots on the cloud.", "author": "Superalgos, ltd.", "license": "Apache-2.0",