Huge Refactoring

IndicatorOutput.js

@@ -0,0 +1,168 @@
+exports.newIndicatorOutput = function newIndicatorOutput(bot, logger, UTILITIES, FILE_STORAGE) {
+
+    const FULL_LOG = true;
+    const LOG_FILE_CONTENT = false;
+    const ONE_DAY_IN_MILISECONDS = 24 * 60 * 60 * 1000;
+
+    const MODULE_NAME = "Indicator Bot";
+
+    let thisObject = {
+        initialize: initialize,
+        finalize: finalize,
+        start: start
+    };
+
+    let utilities = UTILITIES.newCloudUtilities(logger);
+    let fileStorage = FILE_STORAGE.newFileStorage(logger);
+
+    const COMMONS = require('./Commons.js');
+    let commons = COMMONS.newCommons(bot, logger, UTILITIES, FILE_STORAGE);
+
+    return thisObject;
+
+    function finalize() {
+        thisObject = undefined
+        utilities = undefined
+        fileStorage = undefined
+        commons = undefined
+    }
+
+    function initialize(callBackFunction) {
+
+        try {
+
+            logger.fileName = MODULE_NAME;
+            logger.initialize();
+
+            if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] initialize -> Entering function."); }
+
+            callBackFunction(global.DEFAULT_OK_RESPONSE);
+
+        } catch (err) {
+            logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.stack);
+            callBackFunction(global.DEFAULT_FAIL_RESPONSE);
+        }
+    }
+
+    function start(dataFiles, timeFrame, timeFrameLabel, currentDay, interExecutionMemory, callBackFunction) {
+
+        try {
+
+            if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> Entering function."); }
+
+            let products = {}
+            let mainDependency = {}
+            let processingDailyFiles
+
+            if (currentDay !== undefined) {
+                processingDailyFiles = true
+            } else {
+                processingDailyFiles = false
+            }
+
+            /* The first phase here is about checking that we have everything we need at the definition level. */
+            let dataDependencies = bot.processNode.referenceParent.processDependencies.dataDependencies
+            if (commons.validateDataDependencies(dataDependencies, callBackFunction) !== true) { return }
+
+            let outputDatasets = bot.processNode.referenceParent.processOutput.outputDatasets
+            if (commons.validateOutputDatasets(outputDatasets, callBackFunction) !== true) { return }
+
+            /* The second phase is about transforming the inputs into a format that can be used to apply the user defined code. */
+            commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
+
+            /* During the third phase, we need to generate the data of the different products this process produces an output */
+            for (let i = 0; i < outputDatasets.length; i++) {
+
+                let outputDatasetNode = outputDatasets[i]
+                let jsonData                        // Just build data as Json objects
+                let outputData                      // Data built as a result of applying user defined code and formulas at the Data Building Procedure
+                let singularVariableName            // Name of the variable for this product
+                let recordDefinition                // Record as defined by the user at the UI
+                let fileContent                     // Here we store the contents of the new data built just before writing it to a file.
+                let resultsWithIrregularPeriods     // A product will have irregular periods when the User Code inserts new result records at will, in contrast with normal procedure where the platform insert one record per loop execution.
+
+                /*
+                For each outputDatasetNode in our process output, we will build the information based on our input products.
+                */
+
+                recordDefinition = outputDatasetNode.referenceParent.parentNode.record
+                singularVariableName = outputDatasetNode.referenceParent.parentNode.config.singularVariableName
+
+                /* Check Irregular Periods */
+
+                if (outputDatasetNode.referenceParent.parentNode.dataBuilding.loop.javascriptCode !== undefined) {
+                    if (outputDatasetNode.referenceParent.parentNode.dataBuilding.loop.javascriptCode.code.indexOf('results.push') >= 0) {
+                        resultsWithIrregularPeriods = true
+                    }
+                }
+
+                /* Build the data */
+                jsonData = commons.dataBuildingProcedure(
+                    products,
+                    mainDependency,
+                    recordDefinition,
+                    outputDatasetNode.referenceParent.parentNode.dataBuilding,
+                    singularVariableName,
+                    outputDatasetNode.referenceParent.parentNode.config.codeName,
+                    timeFrame,
+                    timeFrameLabel,
+                    resultsWithIrregularPeriods,
+                    interExecutionMemory,
+                    processingDailyFiles,
+                    currentDay
+                )
+
+                /* Add the calculated properties */
+                if (outputDatasetNode.referenceParent.parentNode.calculations !== undefined) {
+                    outputData = commons.calculationsProcedure(jsonData, recordDefinition, outputDatasetNode.referenceParent.parentNode.calculations, singularVariableName, timeFrame)
+                } else {
+                    outputData = jsonData
+                }
+                products[outputDatasetNode.referenceParent.parentNode.config.pluralVariableName] = outputData
+            }
+
+            /*At the fourth and last phase, we will save the new information generated into files corresponding to each output outputDatasetNode.*/
+            let totalFilesWritten = 0
+            for (let i = 0; i < outputDatasets.length; i++) {
+                let outputDatasetNode = outputDatasets[i]
+                let outputData = products[outputDatasetNode.referenceParent.parentNode.config.pluralVariableName]
+                let resultsWithIrregularPeriods     // A product will have irregular periods when the User Code inserts new result records at will, in contrast with normal procedure where the platform insert one record per loop execution.
+                let contextSummary = {}
+
+                /* Check Irregular Periods */
+                if (outputDatasetNode.referenceParent.parentNode.dataBuilding.loop.javascriptCode.code.indexOf('results.push') >= 0) {
+                    resultsWithIrregularPeriods = true
+                }
+
+                /* Simplifying the access to basic info */
+
+                contextSummary.dataset = outputDatasetNode.referenceParent.config.codeName
+                contextSummary.product = outputDatasetNode.referenceParent.parentNode.config.codeName
+                contextSummary.bot = outputDatasetNode.referenceParent.parentNode.parentNode.config.codeName
+                contextSummary.dataMine = outputDatasetNode.referenceParent.parentNode.parentNode.parentNode.config.codeName
+
+                /* This stuff is still hardcoded and unresolved. */
+                contextSummary.botVersion = {
+                    "major": 1,
+                    "minor": 0
+                }
+                contextSummary.dataSetVersion = "dataSet.V1"
+
+                let fileContent = commons.generateFileContent(outputData, outputDatasetNode.referenceParent.parentNode.record, resultsWithIrregularPeriods, processingDailyFiles, currentDay, callBackFunction)
+                commons.writeFile(contextSummary, fileContent, anotherFileWritten, processingDailyFiles, timeFrameLabel, currentDay, callBackFunction)
+            }
+
+
+            function anotherFileWritten() {
+                totalFilesWritten++
+                if (totalFilesWritten === outputDatasets.length) {
+                    callBackFunction(global.DEFAULT_OK_RESPONSE);
+                }
+            }
+        }
+        catch (err) {
+            logger.write(MODULE_NAME, "[ERROR] start -> err = " + err.stack);
+            callBackFunction(global.DEFAULT_FAIL_RESPONSE);
+        }
+    }
+};

LowFrequencyTrading/TradingOutput.js

@@ -1,4 +1,4 @@
-exports.newTradingBot = function newTradingBot(bot, logger, UTILITIES, FILE_STORAGE) {
+exports.newTradingOutput = function newTradingOutput(bot, logger, UTILITIES, FILE_STORAGE) {
     const FULL_LOG = true
     const MODULE_NAME = 'Trading Bot'
 
@@ -11,9 +11,6 @@ exports.newTradingBot = function newTradingBot(bot, logger, UTILITIES, FILE_STOR
     let utilities = UTILITIES.newCloudUtilities(logger)
     let fileStorage = FILE_STORAGE.newFileStorage(logger)
 
-    const COMMONS = require('../Commons.js')
-    let commons = COMMONS.newCommons(bot, logger, UTILITIES, FILE_STORAGE)
-
     return thisObject
 
     function finalize() {
@@ -35,7 +32,7 @@ exports.newTradingBot = function newTradingBot(bot, logger, UTILITIES, FILE_STOR
         }
     }
 
-    function start(multiPeriodDataFiles, timeFrame, timeFrameLabel, currentDay, simulationState, callBackFunction) {
+    function start(chart, timeFrame, timeFrameLabel, currentDay, simulationState, callBackFunction) {
         try {
             bot.processingDailyFiles
             if (timeFrame > global.dailyFilePeriods[0][0]) {
@@ -43,61 +40,8 @@ exports.newTradingBot = function newTradingBot(bot, logger, UTILITIES, FILE_STOR
             } else {
                 bot.processingDailyFiles = true
             }
-            let chart = {}
-            let mainDependency = {}
 
-            /* The first phase here is about checking that we have everything we need at the definition level. */
-            let dataDependencies = bot.processNode.referenceParent.processDependencies.dataDependencies
-            if (commons.validateDataDependencies(dataDependencies, callBackFunction) !== true) { return }
-
-            let outputDatasets = bot.processNode.referenceParent.processOutput.outputDatasets
-            if (commons.validateOutputDatasets(outputDatasets, callBackFunction) !== true) { return }
-
-            /* The second phase is about transforming the inputs into a format that can be used to apply the user defined code. */
-            for (let j = 0; j < global.marketFilesPeriods.length; j++) {
-                let timeFrameLabel = marketFilesPeriods[j][1]
-                let dataFiles = multiPeriodDataFiles.get(timeFrameLabel)
-                let products = {}
-
-                if (FULL_LOG === true) { logger.write(MODULE_NAME, '[INFO] start -> Inflating Data Files for timeFrame = ' + timeFrameLabel) }
-
-                if (dataFiles !== undefined) {
-                    commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
-
-                    let propertyName = 'at' + timeFrameLabel.replace('-', '')
-                    chart[propertyName] = products
-                }
-            }
-
-            for (let j = 0; j < global.dailyFilePeriods.length; j++) {
-                let timeFrameLabel = global.dailyFilePeriods[j][1]
-                let dataFiles = multiPeriodDataFiles.get(timeFrameLabel)
-                let products = {}
-
-                if (FULL_LOG === true) { logger.write(MODULE_NAME, '[INFO] start -> Inflating Data Files for timeFrame = ' + timeFrameLabel) }
-
-                if (dataFiles !== undefined) {
-                    commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
-
-                    let propertyName = 'at' + timeFrameLabel.replace('-', '')
-                    chart[propertyName] = products
-                }
-            }
-
-            /* Single Files */
-            let dataFiles = multiPeriodDataFiles.get('Single Files')
-            let products = {}
-
-            if (FULL_LOG === true) { logger.write(MODULE_NAME, '[INFO] start -> Inflating Data Files from Single Files.') }
-
-            if (dataFiles !== undefined) {
-                commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
-
-                let propertyName = 'atAnyTimeFrame'
-                chart[propertyName] = products
-            }
-
-            /* Simulation */
+            /* Preparing everything for the Simulation */
             const TRADING_SIMULATION = require('./TradingSimulation.js')
             let tradingSimulation = TRADING_SIMULATION.newTradingSimulation(bot, logger, UTILITIES)
 

LowFrequencyTrading/TradingProcess.js

@@ -1,4 +1,4 @@
-exports.newTradingProcess = function newTradingProcess(bot, logger, UTILITIES, USER_BOT_MODULE, USER_BOT_COMMONS) {
+exports.newTradingProcess = function newTradingProcess(bot, logger, UTILITIES, TRADING_OUTPUT_MODULE, USER_BOT_COMMONS) {
 
     /*
     This Module will load all the process data dependencies from files and send them to the Trading Bot.
@@ -23,7 +23,7 @@
     let dataFiles = new Map();
     let multiPeriodDataFiles = new Map();
 
-    let botInstance;
+    let tradingOutputModule;
 
     const FILE_STORAGE = require('../FileStorage.js');
     let fileStorage = FILE_STORAGE.newFileStorage(logger);
@@ -41,9 +41,9 @@
             dataDependenciesModule = pDataDependencies;
             processConfig = pProcessConfig;
 
-            let USER_BOT_MODULE = require("./TradingBot")
-            botInstance = USER_BOT_MODULE.newTradingBot(bot, logger, UTILITIES, FILE_STORAGE);
-            botInstance.initialize(callBackFunction);
+            let TRADING_OUTPUT_MODULE = require("./TradingOutput")
+            tradingOutputModule = TRADING_OUTPUT_MODULE.newTradingOutput(bot, logger, UTILITIES, FILE_STORAGE);
+            tradingOutputModule.initialize(callBackFunction);
 
         } catch (err) {
             logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.stack);
@@ -56,8 +56,8 @@
         multiPeriodDataFiles = undefined
         statusDependencies = undefined
         dataDependenciesModule = undefined
-        botInstance.finalize()
-        botInstance = undefined
+        tradingOutputModule.finalize()
+        tradingOutputModule = undefined
         fileStorage = undefined
         processConfig = undefined
         thisObject = undefined
@@ -360,7 +360,7 @@
             function processDailyFiles() {
                 let n = 0;
                 if (currentTimeFrame) {
-                    callTheBot()
+                    buildCharts()
                     return
                 }
                 bot.tradingProcessDate = new Date(contextVariables.lastFile.valueOf() - ONE_DAY_IN_MILISECONDS); // Go back one day to start well when we advance time at the begining of the loop.
@@ -528,7 +528,7 @@
                     } else {
                         n = 0;
                         if (currentTimeFrame !== undefined) {
-                            callTheBot();
+                            buildCharts();
                         } else {
                             logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> timeFramesControlLoop -> Time Frame not Recognized. Can not continue.");
                             callBackFunction(global.DEFAULT_FAIL_RESPONSE);
@@ -537,16 +537,67 @@
                 }
             }
 
-            function callTheBot() {
-                botInstance.start(
-                    multiPeriodDataFiles,
+            function buildCharts() {
+                const COMMONS = require('../Commons.js')
+                let commons = COMMONS.newCommons(bot, logger, UTILITIES, FILE_STORAGE)
+
+                let chart = {}
+                let mainDependency = {}
+
+                /* The first phase here is about checking that we have everything we need at the definition level. */
+                let dataDependencies = bot.processNode.referenceParent.processDependencies.dataDependencies
+                if (commons.validateDataDependencies(dataDependencies, callBackFunction) !== true) { return }
+
+                let outputDatasets = bot.processNode.referenceParent.processOutput.outputDatasets
+                if (commons.validateOutputDatasets(outputDatasets, callBackFunction) !== true) { return }
+
+                /* The second phase is about transforming the inputs into a format that can be used to apply the user defined code. */
+                for (let j = 0; j < global.marketFilesPeriods.length; j++) {
+                    let timeFrameLabel = marketFilesPeriods[j][1]
+                    let dataFiles = multiPeriodDataFiles.get(timeFrameLabel)
+                    let products = {}
+
+                    if (dataFiles !== undefined) {
+                        commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
+
+                        let propertyName = 'at' + timeFrameLabel.replace('-', '')
+                        chart[propertyName] = products
+                    }
+                }
+
+                for (let j = 0; j < global.dailyFilePeriods.length; j++) {
+                    let timeFrameLabel = global.dailyFilePeriods[j][1]
+                    let dataFiles = multiPeriodDataFiles.get(timeFrameLabel)
+                    let products = {}
+
+                    if (dataFiles !== undefined) {
+                        commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
+
+                        let propertyName = 'at' + timeFrameLabel.replace('-', '')
+                        chart[propertyName] = products
+                    }
+                }
+
+                /* Single Files */
+                let dataFiles = multiPeriodDataFiles.get('Single Files')
+                let products = {}
+
+                if (dataFiles !== undefined) {
+                    commons.inflateDatafiles(dataFiles, dataDependencies, products, mainDependency, timeFrame)
+
+                    let propertyName = 'atAnyTimeFrame'
+                    chart[propertyName] = products
+                }
+
+                tradingOutputModule.start(
+                    chart,
                     currentTimeFrame,
                     currentTimeFrameLabel,
                     bot.tradingProcessDate,
                     simulationState,
-                    onBotFinished);
+                    onOutputGenerated);
 
-                function onBotFinished(err) {
+                function onOutputGenerated(err) {
                     try {
                         if (err.result !== global.DEFAULT_OK_RESPONSE.result) {
                             callBackFunction(err);
@@ -567,14 +618,14 @@
                             try {
 
                                 if (err.result !== global.DEFAULT_OK_RESPONSE.result) {
-                                    logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> callTheBot -> onBotFinished -> onWritten -> err = " + err.stack);
+                                    logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> buildCharts -> onOutputGenerated -> onWritten -> err = " + err.stack);
                                     callBackFunction(err);
                                     return;
                                 }
 
                                 writeDailyStatusReport(bot.tradingProcessDate, onDailyStatusReport);
                             } catch (err) {
-                                logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> callTheBot -> onBotFinished -> onWritten -> err = " + err.stack);
+                                logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> buildCharts -> onOutputGenerated -> onWritten -> err = " + err.stack);
                                 callBackFunction(global.DEFAULT_FAIL_RESPONSE);
                             }
                         }
@@ -590,7 +641,7 @@
                             const now = new Date()
                             if (now.valueOf() >= bot.VALUES_TO_USE.timeRange.finalDatetime.valueOf()) {
                                 const logText = "User Defined End Datetime reached @ " + now.getUTCFullYear() + "/" + (now.getUTCMonth() + 1) + "/" + now.getUTCDate() + ".";
-                                if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processDailyFiles -> callTheBot -> onBotFinished -> onMarketStatusReport -> " + logText); }
+                                if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processDailyFiles -> buildCharts -> onOutputGenerated -> onMarketStatusReport -> " + logText); }
 
                                 bot.STOP_SESSION = true
                                 callBackFunction(global.DEFAULT_OK_RESPONSE);
@@ -600,7 +651,7 @@
                         }
                     }
                     catch (err) {
-                        logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> callTheBot -> onBotFinished -> err = " + err.stack);
+                        logger.write(MODULE_NAME, "[ERROR] start -> processDailyFiles -> buildCharts -> onOutputGenerated -> err = " + err.stack);
                         callBackFunction(global.DEFAULT_FAIL_RESPONSE);
                     }
                 }

MultiPeriodDaily.js

@@ -18,7 +18,7 @@
     let dataDependenciesModule;
     let dataFiles = new Map;
 
-    let botInstance;
+    let indicatorOutputModule;
 
     let fileStorage = FILE_STORAGE.newFileStorage(logger);
 
@@ -42,10 +42,10 @@
             dataDependenciesModule = pDataDependencies;
             processConfig = pProcessConfig;
 
-            let USER_BOT_MODULE = require("./IndicatorBot")
+            let INDICATOR_OUTPUT_MODULE = require("./IndicatorOutput")
 
-            botInstance = USER_BOT_MODULE.newIndicatorBot(bot, logger, UTILITIES, FILE_STORAGE);
-            botInstance.initialize(callBackFunction);
+            indicatorOutputModule = INDICATOR_OUTPUT_MODULE.newIndicatorOutput(bot, logger, UTILITIES, FILE_STORAGE);
+            indicatorOutputModule.initialize(callBackFunction);
 
         } catch (err) {
             logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.stack);
@@ -57,7 +57,7 @@
         dataFiles = undefined
         statusDependencies = undefined
         dataDependenciesModule = undefined
-        botInstance = undefined
+        indicatorOutputModule = undefined
         fileStorage = undefined
         processConfig = undefined
         thisObject = undefined
@@ -574,7 +574,7 @@
 
                                     } else {
 
-                                        callTheBot();
+                                        generateOutput();
 
                                     }
                                 }
@@ -584,28 +584,28 @@
                                 }
                             }
 
-                            function callTheBot() {
+                            function generateOutput() {
 
                                 try {
 
-                                    if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> Entering function."); }
+                                    if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> Entering function."); }
 
                                     const timeFrame = global.dailyFilePeriods[n][0];
                                     const timeFrameLabel = global.dailyFilePeriods[n][1];
 
-                                    botInstance.start(
+                                    indicatorOutputModule.start(
                                         dataFiles,
                                         timeFrame,
                                         timeFrameLabel,
                                         bot.multiPeriodDailyProcessDatetime,
                                         interExecutionMemoryArray[n],
-                                        onBotFinished);
+                                        onOutputGenerated);
 
-                                    function onBotFinished(err) {
+                                    function onOutputGenerated(err) {
 
                                         try {
 
-                                            if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> onBotFinished -> Entering function."); }
+                                            if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> onOutputGenerated -> Entering function."); }
 
                                             if (err.result !== global.DEFAULT_OK_RESPONSE.result) {
 
@@ -617,13 +617,13 @@
                                             periodsControlLoop();
                                         }
                                         catch (err) {
-                                            logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> onBotFinished -> err = " + err.stack);
+                                            logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> onOutputGenerated -> err = " + err.stack);
                                             callBackFunction(global.DEFAULT_FAIL_RESPONSE);
                                         }
                                     }
                                 }
                                 catch (err) {
-                                    logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> err = " + err.stack);
+                                    logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> err = " + err.stack);
                                     callBackFunction(global.DEFAULT_FAIL_RESPONSE);
                                 }
                             }

MultiPeriodMarket.js

@@ -16,7 +16,7 @@
     let dataDependenciesModule;
     let dataFiles = new Map();
 
-    let botInstance;
+    let indicatorOutputModule;
 
     let processConfig;
 
@@ -35,10 +35,10 @@
             dataDependenciesModule = pDataDependencies;
             processConfig = pProcessConfig;
 
-            let USER_BOT_MODULE = require("./IndicatorBot")
+            let INDICATOR_OUTPUT_MODULE = require("./IndicatorOutput")
 
-            botInstance = USER_BOT_MODULE.newIndicatorBot(bot, logger, UTILITIES, FILE_STORAGE);
-            botInstance.initialize(callBackFunction);
+            indicatorOutputModule = INDICATOR_OUTPUT_MODULE.newIndicatorOutput(bot, logger, UTILITIES, FILE_STORAGE);
+            indicatorOutputModule.initialize(callBackFunction);
 
         } catch (err) {
             logger.write(MODULE_NAME, "[ERROR] initialize -> err = " + err.stack);
@@ -50,7 +50,7 @@
         dataFiles = undefined
         statusDependencies = undefined
         dataDependenciesModule = undefined
-        botInstance = undefined
+        indicatorOutputModule = undefined
         processConfig = undefined
         thisObject = undefined
     }
@@ -200,7 +200,7 @@
 
                                     } else {
 
-                                        callTheBot();
+                                        generateOutput();
 
                                     }
                                 }
@@ -210,28 +210,28 @@
                                 }
                             }
 
-                            function callTheBot() {
+                            function generateOutput() {
 
                                 try {
 
-                                    if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> Entering function."); }
+                                    if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> Entering function."); }
 
                                     const timeFrame = global.marketFilesPeriods[n][0];
                                     const timeFrameLabel = global.marketFilesPeriods[n][1];
 
-                                    botInstance.start(
+                                    indicatorOutputModule.start(
                                         dataFiles,
                                         timeFrame,
                                         timeFrameLabel,
                                         undefined,
                                         undefined,
-                                        onBotFinished);
+                                        onOutputGenerated);
 
-                                    function onBotFinished(err) {
+                                    function onOutputGenerated(err) {
 
                                         try {
 
-                                            if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> onBotFinished -> Entering function."); }
+                                            if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> onOutputGenerated -> Entering function."); }
 
                                             if (err.result !== global.DEFAULT_OK_RESPONSE.result) {
 
@@ -242,13 +242,13 @@
                                             periodsControlLoop();
                                         }
                                         catch (err) {
-                                            logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> onBotFinished -> err = " + err.stack);
+                                            logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> onOutputGenerated -> err = " + err.stack);
                                             callBackFunction(global.DEFAULT_FAIL_RESPONSE);
                                         }
                                     }
                                 }
                                 catch (err) {
-                                    logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> callTheBot -> err = " + err.stack);
+                                    logger.write(MODULE_NAME, "[ERROR] start -> processTimeFrames -> periodsLoopBody -> generateOutput -> err = " + err.stack);
                                     callBackFunction(global.DEFAULT_FAIL_RESPONSE);
                                 }
                             }

Root.js

@@ -132,9 +132,9 @@
 
             /* Process Loops Declarations. */
 
-            const INDICATOR_BOT_MAIN_LOOP_MODULE = require('./IndicatorBotProcessMainLoop');
-            const SENSOR_BOT_MAIN_LOOP_MODULE = require('./SensorBotProcessMainLoop');
-            const TRADING_ENGINE_MAIN_LOOP_MODULE = require('./TradingBotProcessMainLoop');
+            const INDICATOR_BOT_MODULE = require('./IndicatorBot');
+            const SENSOR_BOT = require('./SensorBot');
+            const TRADING_BOT_MODULE = require('./TradingBot');
 
             let botConfig;
             let processInstance = global.TASK_NODE.bot.processes[processIndex]
@@ -144,7 +144,7 @@
                 processInstance.referenceParent.config.framework !== undefined &&
                 (processInstance.referenceParent.config.framework.name === 'Multi-Period-Market' ||
                     processInstance.referenceParent.config.framework.name === 'Multi-Period-Daily' ||
-                    processInstance.referenceParent.config.framework.name === 'Trading-Process')
+                    processInstance.referenceParent.config.framework.name === 'Low-Frequency-Trading-Process')
             ) {
                 botConfig = processInstance.referenceParent.parentNode.config
                 botConfig.definedByUI = true
@@ -396,14 +396,14 @@
 
                             if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> bootingBot -> runSensorBot -> Entering function."); }
 
-                            let extractionBotMainLoop = SENSOR_BOT_MAIN_LOOP_MODULE.newSensorBotProcessMainLoop(pBotConfig, logger);
-                            extractionBotMainLoop.initialize(pProcessConfig, onInitializeReady);
+                            let sensorBot = SENSOR_BOT.newSensorBot(pBotConfig, logger);
+                            sensorBot.initialize(pProcessConfig, onInitializeReady);
 
                             function onInitializeReady(err) {
 
                                 if (err.result === global.DEFAULT_OK_RESPONSE.result) {
 
-                                    extractionBotMainLoop.run(whenRunFinishes);
+                                    sensorBot.run(whenRunFinishes);
 
                                     function whenRunFinishes(err) {
 
@@ -461,14 +461,14 @@
 
                             if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> bootingBot -> runIndicatorBot -> Entering function."); }
 
-                            let indicatorBotMainLoop = INDICATOR_BOT_MAIN_LOOP_MODULE.newIndicatorBotProcessMainLoop(pBotConfig, logger);
-                            indicatorBotMainLoop.initialize(pProcessConfig, onInitializeReady);
+                            let indicatorBot = INDICATOR_BOT_MODULE.newIndicatorBot(pBotConfig, logger);
+                            indicatorBot.initialize(pProcessConfig, onInitializeReady);
 
                             function onInitializeReady(err) {
 
                                 if (err.result === global.DEFAULT_OK_RESPONSE.result) {
 
-                                    indicatorBotMainLoop.run(whenRunFinishes);
+                                    indicatorBot.run(whenRunFinishes);
 
                                     function whenRunFinishes(err) {
 
@@ -524,14 +524,14 @@
 
                             if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> bootingBot -> runTradingBot -> Entering function."); }
 
-                            let tradingBotMainLoop = TRADING_ENGINE_MAIN_LOOP_MODULE.newTradingBotProcessMainLoop(pBotConfig, logger);
-                            tradingBotMainLoop.initialize(pProcessConfig, onInitializeReady);
+                            let tradingBot = TRADING_BOT_MODULE.newTradingBot(pBotConfig, logger);
+                            tradingBot.initialize(pProcessConfig, onInitializeReady);
 
                             function onInitializeReady(err) {
 
                                 if (err.result === global.DEFAULT_OK_RESPONSE.result) {
 
-                                    tradingBotMainLoop.run(whenRunFinishes);
+                                    tradingBot.run(whenRunFinishes);
 
                                     function whenRunFinishes(err) {
 

SensorBot.js

@@ -1,4 +1,4 @@
-exports.newSensorBotProcessMainLoop = function newSensorBotProcessMainLoop(bot, parentLogger) {
+exports.newSensorBot = function newSensorBot(bot, parentLogger) {
 
     const ROOT_DIR = './';
 
@@ -825,6 +825,16 @@
                 global.EVENT_SERVER_CLIENT.raiseEvent(bot.processKey, 'Heartbeat', event)
             }
 
+            function processError(node, errorMessage) {
+                let event = {
+                    nodeName: node.name,
+                    nodeType: node.type,
+                    nodeId: node.id,
+                    errorMessage: errorMessage
+                }
+                global.EVENT_SERVER_CLIENT.raiseEvent(bot.processKey, 'Error', event)
+            }
+
             function processStopped() {
                 global.EVENT_SERVER_CLIENT.raiseEvent(bot.processKey, 'Stopped')
             }

TradingBot.js

@@ -1,4 +1,4 @@
-exports.newTradingBotProcessMainLoop = function newTradingBotProcessMainLoop(bot, parentLogger) {
+exports.newTradingBot = function newTradingBot(bot, parentLogger) {
 
     const ROOT_DIR = './';
 
@@ -8,7 +8,7 @@
     let USER_BOT_MODULE;
     let USER_BOT_COMMONS;
 
-    const TRADING_PROCESS_MODULE = require(ROOT_DIR + '/Trading/TradingProcess.js');
+    const TRADING_PROCESS_MODULE = require(ROOT_DIR + '/LowFrequencyTrading/TradingProcess.js');
     const FILE_STORAGE = require('./FileStorage.js');
     const SESSION = require(ROOT_DIR + 'Session');
 
@@ -400,7 +400,7 @@
                                         case global.DEFAULT_OK_RESPONSE.result: {
                                             if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] run -> loop -> initializeDataDependencies -> onInizialized -> Execution finished well."); }
                                             switch (processConfig.framework.name) {
-                                                case 'Trading-Process': {
+                                                case 'Low-Frequency-Trading-Process': {
                                                     processFramework = TRADING_PROCESS_MODULE.newTradingProcess(bot, logger, UTILITIES, USER_BOT_MODULE, USER_BOT_COMMONS);
                                                     intitializeProcessFramework();
                                                     break;