diff --git a/Assistant.js b/Assistant.js index bf6168baf..1ef164205 100644 --- a/Assistant.js +++ b/Assistant.js @@ -114,13 +114,13 @@ validateExchangeSyncronicity(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getMarketRateFromExchange -> onTicker -> err = ", err); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> getPositionTradesAtExchange -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -704,7 +704,7 @@ next(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasExecuted -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasExecuted -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } @@ -790,7 +790,7 @@ next(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasPartiallyExecuted -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> confirmOrderWasPartiallyExecuted -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } @@ -865,14 +865,14 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> applyTradesToContext -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> loopBody -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); return; } @@ -911,7 +911,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] ordersExecutionCheck -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -1075,12 +1075,12 @@ break; } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] putPosition -> onResponse -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] putPosition -> onResponse -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] putPosition -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] putPosition -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -1199,12 +1199,12 @@ break; } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] movePosition -> onResponse -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] movePosition -> onResponse -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] movePosition -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] movePosition -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/CloudUtilities.js b/CloudUtilities.js index 09d5d848d..a22f9e2a3 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); + logger.write(MODULE_NAME, "[ERROR] createFolderIfNeeded -> loop -> checkLoop -> err = "+ err); callBackFunction(err); return; } diff --git a/Context.js b/Context.js index 62adb5a56..5bee4f029 100644 --- a/Context.js +++ b/Context.js @@ -120,7 +120,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> onDone -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> onDone -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -151,7 +151,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getStatusReport -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> getStatusReport -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -170,7 +170,7 @@ function onFileReceived(err, text) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> onFileReceived -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> onFileReceived -> err = "+ err); callBack(err); return; } @@ -205,7 +205,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionHistory -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -231,7 +231,7 @@ function onFileReceived(err, text) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> onFileReceived -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> onFileReceived -> err = "+ err); callBack(err); return; } @@ -272,7 +272,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> getExecutionContext -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -338,13 +338,13 @@ callBack(global.DEFAULT_OK_RESPONSE); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> createConext -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> createConext -> err = "+ err); callBack(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -385,7 +385,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> onDone -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> onDone -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -415,7 +415,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); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> onFileCreated -> err = "+ err); callBack(err); return; } @@ -426,7 +426,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExecutionContext -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -476,7 +476,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); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> onFileCreated -> err = "+ err); callBack(err); return; } @@ -498,7 +498,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); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> onFileCreated -> onSequenceFileCreated -> err = "+ err); callBack(err); return; } @@ -510,7 +510,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeExucutionHistory -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -526,7 +526,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeStatusReport -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] saveThemAll -> writeStatusReport -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/DataDependencies.js b/DataDependencies.js index 7fb40a38c..f4f508103 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); + 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); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/DataSet.js b/DataSet.js index 3ad3bccfd..f1f370a1c 100644 --- a/DataSet.js +++ b/DataSet.js @@ -33,7 +33,7 @@ exports.newDataSet = function newDataSet(BOT, logger) { callBackFunction(global.DEFAULT_OK_RESPONSE); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -59,7 +59,7 @@ exports.newDataSet = function newDataSet(BOT, logger) { } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] 'getTextFile' -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] 'getTextFile' -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -100,7 +100,7 @@ exports.newDataSet = function newDataSet(BOT, logger) { } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] 'createTextFile' -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] 'createTextFile' -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/DebugLog.js b/DebugLog.js index 867500cb2..39eaae594 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); + console.log("[ERROR] Debug Log -> initialize -> err = "+ err); } } @@ -94,7 +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); + console.log("[ERROR] DebugLog -> persist -> onInizialized -> onFileCreated -> err = "+ err); setTimeout(writeLog, 10000); // Lets retry until we make it. return; @@ -105,7 +105,7 @@ exports.newDebugLog = function newDebugLog() { } } } catch (err) { - console.log("[ERROR] DebugLog -> persist -> err = ", err); + console.log("[ERROR] DebugLog -> persist -> err = "+ err); console.log("[ERROR] DebugLog -> persist -> onInizialized -> contentToPersist = " + contentToPersist); } } @@ -134,7 +134,7 @@ exports.newDebugLog = function newDebugLog() { accumulatedLog = accumulatedLog + logLine; } catch (err) { - console.log("[ERROR] DebugLog -> write -> err = ", err); + console.log("[ERROR] DebugLog -> write -> err = "+ err); } } diff --git a/IndicatorBotProcessMainLoop.js b/IndicatorBotProcessMainLoop.js index cc1e4bcc4..bee07beff 100644 --- a/IndicatorBotProcessMainLoop.js +++ b/IndicatorBotProcessMainLoop.js @@ -75,7 +75,7 @@ } } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + parentLogger.write(MODULE_NAME, "[ERROR] run -> err = "+ err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); diff --git a/Integrations/Strategy.js b/Integrations/Strategy.js index de41b75c5..a54b937b9 100644 --- a/Integrations/Strategy.js +++ b/Integrations/Strategy.js @@ -1,51 +1,51 @@ const axios = require('axios') let fs = require('fs') const { promisify } = require('util') -const readFileAsync = promisify(fs.readFile); +const readFileAsync = promisify(fs.readFile) exports.getStrategy = async function () { - try { - if (!global.STRATEGY) { - let executionOnCloud = false - if (process.env.ON_CLOUD !== undefined) { - executionOnCloud = JSON.parse(process.env.ON_CLOUD) - } + try { + if (!global.STRATEGY) { + let executionOnCloud = false + if (process.env.ON_CLOUD !== undefined) { + executionOnCloud = JSON.parse(process.env.ON_CLOUD) + } - if (executionOnCloud) { - const strategizerResponse = await axios({ - url: process.env.GATEWAY_ENDPOINT_K8S, - method: 'post', - data: { - query: ` + if (executionOnCloud) { + const strategizerResponse = await axios({ + url: process.env.GATEWAY_ENDPOINT_K8S, + method: 'post', + data: { + query: ` query($fbSlug: String!){ strategizer_TradingSystemByFb(fbSlug: $fbSlug){ data } } `, - variables: { - fbSlug: process.env.BOT - }, - }, - headers: { - authorization: process.env.AUTHORIZATION - } - }) - - if (strategizerResponse.data.errors) - throw new Error(strategizerResponse.data.errors[0].message) - - global.STRATEGY = strategizerResponse.data.data.strategizer_TradingSystemByFb.data; - } else { - let fileLocation = process.env.INTER_PROCESS_FILES_PATH + '/definition.json' - let strategy = await readFileAsync(fileLocation, { encoding: 'utf8' }) - global.STRATEGY = JSON.parse(strategy) + variables: { + fbSlug: process.env.BOT } + }, + headers: { + authorization: process.env.AUTHORIZATION + } + }) + + if (strategizerResponse.data.errors) { + throw new Error(strategizerResponse.data.errors[0].message) } - return global.STRATEGY - - } catch (error) { - throw new Error('There has been an error getting the strategy: ', JSON.stringify(error)) + global.STRATEGY = strategizerResponse.data.data.strategizer_TradingSystemByFb.data + } else { + let fileLocation = process.env.INTER_PROCESS_FILES_PATH + '/definition.json' + let strategy = await readFileAsync(fileLocation, { encoding: 'utf8' }) + global.STRATEGY = JSON.parse(strategy) + } } + + return global.STRATEGY + } catch (error) { + throw new Error('There has been an error getting the strategy: ', JSON.stringify(error)) + } } diff --git a/MultiPeriodDaily.js b/MultiPeriodDaily.js index c8e9b7590..66a220f4e 100644 --- a/MultiPeriodDaily.js +++ b/MultiPeriodDaily.js @@ -21,7 +21,7 @@ let usertBot; const FILE_STORAGE = require('./Integrations/FileStorage.js'); - let fileStorage = FILE_STORAGE.newFileStorage(); + let fileStorage = FILE_STORAGE.newFileStorage(); let processConfig; @@ -62,7 +62,7 @@ usertBot.initialize(dataDependencies, callBackFunction, pAssistant); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + 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); + 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)); @@ -299,7 +299,7 @@ console.log(new Date().toISOString() + " " + pad(bot.codeName, 20) + " " + pad(bot.process, 30) + " " + " bot.multiPeriodDailyProcessDatetime = " + bot.multiPeriodDailyProcessDatetime.toISOString()); - if(global.FULL_LOG === 'true'){ + if (global.FULL_LOG === 'true') { logger.newInternalLoop(bot.codeName, bot.process); } @@ -321,7 +321,7 @@ periodsLoop(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> advanceTime -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -421,7 +421,7 @@ if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> Entering function."); } if (LOG_FILE_CONTENT === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> text = " + text); } - if ((err.message === "File does not exist." && botNeverRan === true) || err.code === 'The specified key does not exist.') { + if ((err.message === "File does not exist." && botNeverRan === true) || err.code === 'The specified key does not exist.') { /* Sometimes one of the dependencies of an indicator for some reasons are not calculated from the begining of the market. @@ -438,14 +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); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> err = " + err); callBackFunction(err); return; } @@ -456,13 +456,13 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> onFileReceived -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getPreviousFile -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -488,14 +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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = " + err.code); 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = " + err.code); callBackFunction(err); return; } @@ -509,19 +509,19 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getCurrentFile -> onFileReceived -> err = ", err); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> dependencyLoopBody -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -545,7 +545,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -585,19 +585,19 @@ periodsControlLoop(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> onBotFinished -> err = ", err); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -627,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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> controlLoop -> onWritten -> err = " + err); callBackFunction(err); return; } @@ -635,21 +635,21 @@ writeStatusReport(bot.multiPeriodDailyProcessDatetime, advanceTime); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> controlLoop -> onWritten -> err = ", err); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -682,7 +682,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeDataRanges -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> writeDataRanges -> err = " + err); callBack(global.DEFAULT_FAIL_RESPONSE); } @@ -711,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); + logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> onFileCreated -> err = " + err); callBack(err); return; } @@ -724,7 +724,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> writeDataRange -> err = " + err); callBack(global.DEFAULT_FAIL_RESPONSE); } } @@ -747,14 +747,14 @@ bot.hasTheBotJustStarted = false; } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> err = " + err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/MultiPeriodMarket.js b/MultiPeriodMarket.js index d5bf944ee..d2f902d15 100644 --- a/MultiPeriodMarket.js +++ b/MultiPeriodMarket.js @@ -58,7 +58,7 @@ usertBot.initialize(dataDependencies, callBackFunction, pAssistant); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -183,7 +183,7 @@ if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = "+ err); callBackFunction(err); return; } @@ -195,20 +195,20 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> dependencyLoopBody -> getFile -> onFileReceived -> err = ", err); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoop -> dependencyLoopBody -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -232,7 +232,7 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> dependencyControlLoop -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -269,19 +269,19 @@ periodsControlLoop(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> callTheBot -> onBotFinished -> err = ", err); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsLoopBody -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -305,14 +305,14 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> periodsControlLoop -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] start -> processTimePeriods -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -331,14 +331,14 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> writeStatusReport -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] start -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] start -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/Root.js b/Root.js index 1c230da11..65196deaa 100644 --- a/Root.js +++ b/Root.js @@ -133,7 +133,7 @@ } } - function start() { + function start(callback) { /* Now we will run according to what we see at the config file. */ @@ -176,7 +176,7 @@ function onFileReceived(err, text) { if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = ", err); + console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = "+ err); return; } @@ -186,7 +186,7 @@ botConfig.repo = cloneToExecute.repo; findProcess(); } catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = ", err); + console.log(logDisplace + "Root : [ERROR] start -> getBotConfig -> onInizialized -> onFileReceived -> err = "+ err); return; } } @@ -536,7 +536,7 @@ } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> err = ", err); + 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); @@ -545,19 +545,89 @@ console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> whenStartFinishes -> Bot execution was aborted."); logger.persist(); } + callback(err, pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process) } } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runSensorBot -> onInitializeReady -> err = ", err); + 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); + 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); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runSensorBot -> err = "+ err); + } + } + + function runIndicatorBot(pBotConfig, pProcessConfig, pMonth, pYear) { + + try { + const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); + let logger; + + logger = DEBUG_MODULE.newDebugLog(); + logger.bot = pBotConfig; + + if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> Entering function."); } + if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> pMonth = " + pMonth); } + if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> pYear = " + pYear); } + + let indicatorBotMainLoop = INDICATOR_BOT_MAIN_LOOP_MODULE.newIndicatorBotProcessMainLoop(pBotConfig, logger); + indicatorBotMainLoop.initialize(UI_COMMANDS, pProcessConfig, onInitializeReady); + + function onInitializeReady(err) { + + if (err.result === global.DEFAULT_OK_RESPONSE.result) { + + indicatorBotMainLoop.run(pMonth, pYear, whenRunFinishes); + + function whenRunFinishes(err) { + + pBotConfig.loopCounter = 0; + + let botId; + if (pYear !== undefined) { + botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process + "." + pYear + "." + pMonth; + } else { + botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process; + } + + if (err.result === global.DEFAULT_OK_RESPONSE.result) { + + logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot execution finished sucessfully."); + logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot Id = " + botId); + + console.log(logDisplace + "Root : [INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> botId = " + botId); + console.log(logDisplace + "Root : [INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot execution finished sucessfully."); + + logger.persist(); + + } else { + + 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); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot execution finished with errors. Please check the logs."); + logger.persist(); + } + callback(err, pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process) + } + + } else { + 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); + logger.persist(); + } + } + } + catch (err) { + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> err = "+ err); + } } @@ -715,19 +785,20 @@ } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> err = ", err); + 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); console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> whenStartFinishes -> Bot execution finished with errors. Please check the logs."); logger.persist(); } + callback(err, pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process) } } else { - logger.write(MODULE_NAME, "[ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> err = ", err); + 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); + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> createBotInstance -> onInitializeReady -> err = "+ err); logger.persist(); } @@ -735,75 +806,7 @@ } } catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> err = ", err); - } - } - - function runIndicatorBot(pBotConfig, pProcessConfig, pMonth, pYear) { - - try { - const DEBUG_MODULE = require(ROOT_DIR + 'DebugLog'); - let logger; - - logger = DEBUG_MODULE.newDebugLog(); - logger.bot = pBotConfig; - - if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> Entering function."); } - if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> pMonth = " + pMonth); } - if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> pYear = " + pYear); } - - let indicatorBotMainLoop = INDICATOR_BOT_MAIN_LOOP_MODULE.newIndicatorBotProcessMainLoop(pBotConfig, logger); - indicatorBotMainLoop.initialize(UI_COMMANDS, pProcessConfig, onInitializeReady); - - function onInitializeReady(err) { - - if (err.result === global.DEFAULT_OK_RESPONSE.result) { - - indicatorBotMainLoop.run(pMonth, pYear, whenRunFinishes); - - function whenRunFinishes(err) { - - pBotConfig.loopCounter = 0; - - let botId; - if (pYear !== undefined) { - botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process + "." + pYear + "." + pMonth; - } else { - botId = pBotConfig.devTeam + "." + pBotConfig.codeName + "." + pBotConfig.process; - } - - if (err.result === global.DEFAULT_OK_RESPONSE.result) { - - logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot execution finished sucessfully."); - logger.write(MODULE_NAME, "[INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot Id = " + botId); - - console.log(logDisplace + "Root : [INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> botId = " + botId); - console.log(logDisplace + "Root : [INFO] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot execution finished sucessfully."); - - logger.persist(); - - } else { - - 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); - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> onInitializeReady -> whenStartFinishes -> Bot execution finished with errors. Please check the logs."); - logger.persist(); - } - } - - } else { - 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); - logger.persist(); - } - } - } - catch (err) { - console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runIndicatorBot -> err = ", err); - + console.log(logDisplace + "Root : [ERROR] start -> findProcess -> runTradingBot -> err = "+ err); } } diff --git a/Run.js b/Run.js index 41af39c4c..351d451f3 100644 --- a/Run.js +++ b/Run.js @@ -1,213 +1,266 @@ -require('dotenv').config() +require('dotenv').config() const strategy = require('./Integrations/Strategy') +const sequenceList = require('./sequence'); -global.SHALL_BOT_STOP = false; -global.AT_BREAKPOINT = false; // This is used only when running at the browser. -global.FULL_LOG = process.env.FULL_LOG; +global.SHALL_BOT_STOP = false +global.AT_BREAKPOINT = false // This is used only when running at the browser. +global.FULL_LOG = process.env.FULL_LOG /* Default parameters can be changed by the execution configuration */ -global.EXCHANGE_NAME = process.env.EXCHANGE_NAME; -global.MARKET = { - assetA: "USDT", - assetB: "BTC" -}; +global.EXCHANGE_NAME = process.env.EXCHANGE_NAME +global.MARKET = { assetA: 'USDT', assetB: 'BTC' } +global.CLONE_EXECUTOR = { codeName: 'AACloud', version: '1.1' } process.on('uncaughtException', function (err) { - console.log('[INFO] Run -> uncaughtException -> err.message = ' + err.message); - console.log('[INFO] Run -> uncaughtException -> err.stack = ', err.stack); - process.exit(1) -}); + console.log('[INFO] Run -> uncaughtException -> err.message = ' + err.message) + console.log('[INFO] Run -> uncaughtException -> err.stack = ' + err.stack) + process.exit(1) +}) process.on('unhandledRejection', (reason, p) => { - console.log('[INFO] Run -> unhandledRejection -> reason = ' + JSON.stringify(reason)); - console.log('[INFO] Run -> unhandledRejection -> p = ' + JSON.stringify(p)); - process.exit(1) -}); + console.log('[INFO] Run -> unhandledRejection -> reason = ' + JSON.stringify(reason)) + console.log('[INFO] Run -> unhandledRejection -> p = ' + JSON.stringify(p)) + process.exit(1) +}) process.on('exit', function (code) { - console.log('[INFO] Run -> process.on.exit -> About to exit -> code = ' + code); -}); + console.log('[INFO] Run -> process.on.exit -> About to exit -> code = ' + code) +}) -readExecutionConfiguration(); +let isRunSequence = false +let sequenceStep = 0 +let processedSteps = new Map() +if (process.env.RUN_SEQUENCE !== undefined) { + isRunSequence = JSON.parse(process.env.RUN_SEQUENCE) +} -async function readExecutionConfiguration() { - try { - console.log("[INFO] Run -> readExecutionConfiguration -> Entering function. "); +if (isRunSequence) { + sequenceExecution(sequenceStep) +} else { + readExecutionConfiguration() +} - /*Try to get the begin and end dates from the Definition*/ - let definition = await strategy.getStrategy(); - let initialDatetime = process.env.BEGIN_DATE_TIME - let finalDatetime = process.env.END_DATE_TIME +function sequenceExecution (currentStep) { + let execution = sequenceList[currentStep] + process.env.STOP_GRACEFULLY = true + process.env.DEV_TEAM = execution.devTeam + process.env.BOT = execution.bot + process.env.START_MODE = execution.mode + process.env.RESUME_EXECUTION = execution.resumeExecution + process.env.TYPE = execution.type + process.env.PROCESS = execution.process + process.env.MIN_YEAR = execution.startYear + process.env.MAX_YEAR = execution.endYear + process.env.MONTH = execution.month + process.env.BEGIN_DATE_TIME = execution.beginDatetime + process.env.TIME_PERIOD = execution.timePeriod - if (definition !== undefined) { - if (definition.tradingSystem !== undefined) { - if (definition.tradingSystem.parameters !== undefined) { - if (definition.tradingSystem.parameters.baseAsset !== undefined) { - if (definition.tradingSystem.parameters.baseAsset.formula !== undefined) { - if (definition.tradingSystem.parameters.baseAsset.formula.code !== undefined) { - let code = JSON.parse(definition.tradingSystem.parameters.baseAsset.formula.code) - initialDatetime = code.initialDatetime - finalDatetime = code.finalDatetime - } - } - } - } + global.EXCHANGE_NAME = execution.exchangeName + // global.FULL_LOG = execution.fullLog; + + let stepKey = execution.devTeam + '.' + execution.bot + '.' + execution.process + if (processedSteps.has(stepKey)) { + processedSteps.set(stepKey, processedSteps.get(stepKey) + 1) + } else { + processedSteps.set(stepKey, 0) + } + console.log('EXECUTION: ' + JSON.stringify(execution)) + readExecutionConfiguration() + sequenceStep++ +} + +function onExecutionFinish (result, finishStepKey) { + processedSteps.set(finishStepKey, processedSteps.get(finishStepKey) + 1) + if (processedSteps.get(finishStepKey) > 1) { + console.log('[INFO] onExecutionFinish -> Step already processed.') + } else { + if (sequenceStep < sequenceList.length) { + sequenceExecution(sequenceStep) + } else { + setTimeout(function () { + console.log('[INFO] onExecutionFinish -> New round for sequence execution started.') + sequenceStep = 0 + processedSteps = new Map() + sequenceExecution(sequenceStep) + }, process.env.EXECUTION_LOOP_DELAY) + } + } +} + +async function readExecutionConfiguration () { + try { + console.log('[INFO] Run -> readExecutionConfiguration -> Entering function. ') + + /* Try to get the begin and end dates from the Definition */ + let definition = await strategy.getStrategy() + let initialDatetime = process.env.BEGIN_DATE_TIME + let finalDatetime = process.env.END_DATE_TIME + + if (definition !== undefined) { + if (definition.tradingSystem !== undefined) { + if (definition.tradingSystem.parameters !== undefined) { + if (definition.tradingSystem.parameters.baseAsset !== undefined) { + if (definition.tradingSystem.parameters.baseAsset.formula !== undefined) { + if (definition.tradingSystem.parameters.baseAsset.formula.code !== undefined) { + let code = JSON.parse(definition.tradingSystem.parameters.baseAsset.formula.code) + initialDatetime = code.initialDatetime + finalDatetime = code.finalDatetime + } } + } } + } + } - let startMode + let startMode // General Financial Being Configuration - global.DEV_TEAM = process.env.DEV_TEAM - global.CURRENT_BOT_REPO = process.env.BOT + "-" + process.env.TYPE + "-Bot" + global.DEV_TEAM = process.env.DEV_TEAM + global.CURRENT_BOT_REPO = process.env.BOT + '-' + process.env.TYPE + '-Bot' - if (process.env.TYPE === 'Trading' || process.env.TYPE === 'Trading-Engine') { - let live = { - run: "false", - resumeExecution: process.env.RESUME_EXECUTION, - beginDatetime: initialDatetime, - endDatetime: finalDatetime - } + if (process.env.TYPE === 'Trading' || process.env.TYPE === 'Trading-Engine') { + let live = { + run: 'false', + resumeExecution: process.env.RESUME_EXECUTION, + beginDatetime: initialDatetime, + endDatetime: finalDatetime + } - let backtest = { - run: "false", - resumeExecution: process.env.RESUME_EXECUTION, - beginDatetime: initialDatetime, - endDatetime: finalDatetime - } + let backtest = { + run: 'false', + resumeExecution: process.env.RESUME_EXECUTION, + beginDatetime: initialDatetime, + endDatetime: finalDatetime + } - let competition = { - run: "false", - resumeExecution: process.env.RESUME_EXECUTION, - beginDatetime: initialDatetime, - endDatetime: finalDatetime - } + let competition = { + run: 'false', + resumeExecution: process.env.RESUME_EXECUTION, + beginDatetime: initialDatetime, + endDatetime: finalDatetime + } - startMode = { - live: live, - backtest: backtest, - competition: competition - } - } else if (process.env.TYPE === 'Indicator' || process.env.TYPE === 'Sensor') { - let allMonths = { - run: "false", - minYear: process.env.MIN_YEAR, - maxYear: process.env.MAX_YEAR - } - let oneMonth = { - run: "false", - year: process.env.MIN_YEAR, - month: process.env.MONTH - } - let noTime = { - run: "false", - beginDatetime: process.env.BEGIN_DATE_TIME, - resumeExecution: process.env.RESUME_EXECUTION - } - let fixedInterval = { - run: "false", - interval: process.env.INTERVAL - } + startMode = { + live: live, + backtest: backtest, + competition: competition + } + } else if (process.env.TYPE === 'Indicator' || process.env.TYPE === 'Sensor') { + let allMonths = { + run: 'false', + minYear: process.env.MIN_YEAR, + maxYear: process.env.MAX_YEAR + } + let oneMonth = { + run: 'false', + year: process.env.MIN_YEAR, + month: process.env.MONTH + } + let noTime = { + run: 'false', + beginDatetime: process.env.BEGIN_DATE_TIME, + resumeExecution: process.env.RESUME_EXECUTION + } + let fixedInterval = { + run: 'false', + interval: process.env.INTERVAL + } - startMode = { - allMonths: allMonths, - oneMonth: oneMonth, - noTime: noTime, - fixedInterval: fixedInterval - } - } else { - console.log("[ERROR] readExecutionConfiguration -> Bot Type is invalid."); - throw new Error("readExecutionConfiguration -> Bot Type is invalid.") - } - - startMode[process.env.START_MODE].run = "true" - - let cloneToExecute = { - enabled: "true", - devTeam: process.env.DEV_TEAM, - bot: process.env.BOT, - process: process.env.PROCESS, - repo: global.CURRENT_BOT_REPO - } - - global.EXECUTION_CONFIG = { - cloneToExecute: cloneToExecute, - startMode: startMode, - timePeriod: getTimePeriod(process.env.TIME_PERIOD), - timePeriodFileStorage: process.env.TIME_PERIOD, - dataSet: process.env.DATA_SET - }; - - global.CLONE_EXECUTOR = { - codeName: 'AACloud', - version: '1.1' - } - - startRoot(); - } - - catch (err) { - 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); - } -} - -function getTimePeriod(timePeriod) { - if (timePeriod !== undefined) { - try { - let timePeriodMap = new Map() - timePeriodMap.set("24-hs", 86400000) - timePeriodMap.set("12-hs", 43200000) - timePeriodMap.set("08-hs", 28800000) - timePeriodMap.set("06-hs", 21600000) - timePeriodMap.set("04-hs", 14400000) - timePeriodMap.set("03-hs", 10800000) - timePeriodMap.set("02-hs", 7200000) - timePeriodMap.set("01-hs", 3600000) - timePeriodMap.set("45-min", 2700000) - timePeriodMap.set("40-min", 2400000) - timePeriodMap.set("30-min", 1800000) - timePeriodMap.set("20-min", 1200000) - timePeriodMap.set("15-min", 900000) - timePeriodMap.set("10-min", 600000) - timePeriodMap.set("05-min", 300000) - timePeriodMap.set("04-min", 240000) - timePeriodMap.set("03-min", 180000) - timePeriodMap.set("02-min", 120000) - timePeriodMap.set("01-min", 60000) - return timePeriodMap.get(timePeriod) - } catch (error) { - console.log("[WARN] Run -> readExecutionConfiguration -> getTimePeriod -> Error: ", error); - } + startMode = { + allMonths: allMonths, + oneMonth: oneMonth, + noTime: noTime, + fixedInterval: fixedInterval + } } else { - return undefined + console.log('[ERROR] readExecutionConfiguration -> Bot Type is invalid.') + throw new Error('readExecutionConfiguration -> Bot Type is invalid.') } + + startMode[process.env.START_MODE].run = 'true' + + let cloneToExecute = { + enabled: 'true', + devTeam: process.env.DEV_TEAM, + bot: process.env.BOT, + process: process.env.PROCESS, + repo: global.CURRENT_BOT_REPO + } + + global.EXECUTION_CONFIG = { + cloneToExecute: cloneToExecute, + startMode: startMode, + timePeriod: getTimePeriod(process.env.TIME_PERIOD), + timePeriodFileStorage: process.env.TIME_PERIOD, + dataSet: process.env.DATA_SET + } + + global.CLONE_EXECUTOR = { + codeName: 'AACloud', + version: '1.1' + } + + startRoot() + } catch (err) { + 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) + } } -function startRoot() { - - console.log("[INFO] Run -> startRoot -> Entering function. "); - - const ROOT_DIR = './'; - const ROOT_MODULE = require(ROOT_DIR + 'Root'); - let root = ROOT_MODULE.newRoot(); - - let UI_COMMANDS = { - beginDatetime: undefined, - endDatetime: undefined, - timePeriod: undefined, - startMode: undefined, - eventHandler: undefined - }; - - root.initialize(UI_COMMANDS, onInitialized); - - function onInitialized() { - - console.log("[INFO] Run -> startRoot -> onInitialized -> Entering function. "); - - root.start(); +function getTimePeriod (timePeriod) { + if (timePeriod !== undefined) { + try { + let timePeriodMap = new Map() + timePeriodMap.set('24-hs', 86400000) + timePeriodMap.set('12-hs', 43200000) + timePeriodMap.set('08-hs', 28800000) + timePeriodMap.set('06-hs', 21600000) + timePeriodMap.set('04-hs', 14400000) + timePeriodMap.set('03-hs', 10800000) + timePeriodMap.set('02-hs', 7200000) + timePeriodMap.set('01-hs', 3600000) + timePeriodMap.set('45-min', 2700000) + timePeriodMap.set('40-min', 2400000) + timePeriodMap.set('30-min', 1800000) + timePeriodMap.set('20-min', 1200000) + timePeriodMap.set('15-min', 900000) + timePeriodMap.set('10-min', 600000) + timePeriodMap.set('05-min', 300000) + timePeriodMap.set('04-min', 240000) + timePeriodMap.set('03-min', 180000) + timePeriodMap.set('02-min', 120000) + timePeriodMap.set('01-min', 60000) + return timePeriodMap.get(timePeriod) + } catch (error) { + console.log('[WARN] Run -> readExecutionConfiguration -> getTimePeriod -> Error: ', error) } + } else { + return undefined + } +} + +function startRoot () { + console.log('[INFO] Run -> startRoot -> Entering function. ') + + const ROOT_DIR = './' + const ROOT_MODULE = require(ROOT_DIR + 'Root') + let root = ROOT_MODULE.newRoot() + + let UI_COMMANDS = { + beginDatetime: undefined, + endDatetime: undefined, + timePeriod: undefined, + startMode: undefined, + eventHandler: undefined + } + + root.initialize(UI_COMMANDS, onInitialized) + + function onInitialized () { + console.log('[INFO] Run -> startRoot -> onInitialized -> Entering function. ') + + root.start(onExecutionFinish) + } } diff --git a/SensorBotProcessMainLoop.js b/SensorBotProcessMainLoop.js index a21d1402a..3730c6cc9 100644 --- a/SensorBotProcessMainLoop.js +++ b/SensorBotProcessMainLoop.js @@ -73,7 +73,7 @@ } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + parentLogger.write(MODULE_NAME, "[ERROR] run -> err = "+ err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); diff --git a/StatusDependencies.js b/StatusDependencies.js index 1f36a6885..13a100455 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); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] initialize -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } diff --git a/StatusReport.js b/StatusReport.js index 69248015a..9d2ca43f6 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); + 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); + 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); + 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); + logger.write(MODULE_NAME, "[ERROR] load -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -190,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); + logger.write(MODULE_NAME, "[ERROR] save -> onFileCreated -> err = "+ err); callBackFunction(err); return; } @@ -205,7 +205,7 @@ } catch (err) { - logger.write(MODULE_NAME, "[ERROR] save -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] save -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); } } @@ -246,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); + logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> onLoad -> err = "+ err); /* The first month of the market didnt create the main report yet. Aborting verification. */ @@ -257,7 +257,7 @@ } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = "+ err); callBackFunction(err); return; } @@ -270,7 +270,7 @@ loopCycle(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> onLoad -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -300,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); + logger.write(MODULE_NAME, "[INFO] verifyMarketComplete -> loopCycle -> onLoad -> err = "+ err); /* The first month of the market didnt create the main report yet. Aborting verification. */ @@ -311,7 +311,7 @@ } if (err.result !== global.DEFAULT_OK_RESPONSE.result) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = "+ err); callBackFunction(err); return; } @@ -331,13 +331,13 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> onLoad -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -364,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); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> err = "+ err); callBackFunction(err); return; } @@ -384,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); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = "+ err); callBackFunction(err); return; } @@ -392,7 +392,7 @@ loop(); // Lets see the next month. } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = ", err); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> onSave -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -407,13 +407,13 @@ } } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> readAndWriteNewReport -> onLoad -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loopCycle -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } @@ -447,14 +447,14 @@ loopCycle(); } catch (err) { - logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> loop -> err = ", err); + 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); + logger.write(MODULE_NAME, "[ERROR] verifyMarketComplete -> err = "+ err); callBackFunction(global.DEFAULT_FAIL_RESPONSE); return; } diff --git a/TradingBotProcessMainLoop.js b/TradingBotProcessMainLoop.js index e4dda0911..dc00aa04f 100644 --- a/TradingBotProcessMainLoop.js +++ b/TradingBotProcessMainLoop.js @@ -72,7 +72,7 @@ } } } catch (err) { - parentLogger.write(MODULE_NAME, "[ERROR] initialize -> err = ", err); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + 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); + parentLogger.write(MODULE_NAME, "[ERROR] run -> err = "+ err); clearInterval(fixedTimeLoopIntervalHandle); clearTimeout(nextLoopTimeoutHandle); clearTimeout(checkLoopHealthHandle); diff --git a/sequence.json b/sequence.json new file mode 100644 index 000000000..ae710da07 --- /dev/null +++ b/sequence.json @@ -0,0 +1,15 @@ +[ + + { + "devTeam": "AAMasters", + "bot": "AAPaula", + "mode": "noTime", + "resumeExecution": true, + "type": "Indicator", + "exchangeName": "Poloniex", + "process": "Multi-Period-Daily", + "startYear": 2019, + "endYear": 2021, + "month": 1 + } +]