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

Data Range Updated by Events

Browse Source
This commit is contained in:
Luis Fernando Molina committed 2019-10-21 15:31:10 +02:00
1 parent 88d9c630da
commit 0a53e27abc
1 file changed
+17 -10
Download Patch File Download Diff File Expand all files Collapse all files
MultiPeriod.js
+17 -10
View File
@@ -89,7 +89,7 @@
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> Entering function."); }
let currentTimePeriod
let currentOutputPeriodLabel
let currentOutputPeriodName
let market = global.MARKET;
let botNeverRan = true;
@@ -297,7 +297,7 @@
if (bot.VALUES_TO_USE.timePeriod === outputPeriodLabel) {
currentTimePeriod = global.marketFilesPeriods[n][0];
currentOutputPeriodLabel = global.marketFilesPeriods[n][1];
currentOutputPeriodName = global.marketFilesPeriods[n][1];
}
dependencyLoopBody();
@@ -598,7 +598,7 @@
if (bot.VALUES_TO_USE.timePeriod === outputPeriodLabel) {
currentTimePeriod = global.dailyFilePeriods[n][0];
currentOutputPeriodLabel = global.dailyFilePeriods[n][1];
currentOutputPeriodName = global.dailyFilePeriods[n][1];
}
let dependencyIndex = 0;
@@ -850,7 +850,7 @@
usertBot.start(
multiPeriodDataFiles,
currentTimePeriod,
currentOutputPeriodLabel,
currentOutputPeriodName,
bot.multiPeriodProcessDatetime,
interExecutionMemoryArray[n],
onBotFinished);
@@ -872,7 +872,7 @@
writeMarketStatusReport(onMarketStatusReport)
} else {
writeDataRanges(onWritten);
writeDataRanges(currentOutputPeriodName, onWritten);
}
function onWritten(err) {
@@ -953,7 +953,7 @@
}
}
function writeDataRanges(callBack) {
function writeDataRanges(currentOutputPeriodName, callBack) {
try {
@@ -964,9 +964,9 @@
function productLoopBody() {
let folderName = bot.products[productIndex].codeName;
let product = bot.products[productIndex];
writeDataRange(contextVariables.dateBeginOfMarket, bot.multiPeriodProcessDatetime, folderName, controlLoop);
writeDataRange(contextVariables.dateBeginOfMarket, bot.multiPeriodProcessDatetime, product, currentOutputPeriodName, controlLoop);
}
function controlLoop() {
@@ -987,7 +987,7 @@
}
function writeDataRange(pBegin, pEnd, pProductFolder, callBack) {
function writeDataRange(pBegin, pEnd, product, currentOutputPeriodName, callBack) {
try {
@@ -1001,7 +1001,7 @@
let fileContent = JSON.stringify(dataRange);
let fileName = '/Data.Range.' + market.assetA + '_' + market.assetB + '.json';
let filePath = bot.filePathRoot + "/Output/" + bot.SESSION.folderName + "/" + pProductFolder + "/" + 'Multi-Period-Daily' + fileName;
let filePath = bot.filePathRoot + "/Output/" + bot.SESSION.folderName + "/" + product.codeName + "/" + 'Multi-Period-Daily' + fileName;
fileStorage.createTextFile(bot.devTeam, filePath, fileContent + '\n', onFileCreated);
@@ -1019,6 +1019,13 @@
logger.write(MODULE_NAME, "[INFO] start -> writeDataRange -> onFileCreated -> Content written = " + fileContent);
}
let key = bot.devTeam + "-" + bot.codeName + "-" + product.codeName + "-" + currentOutputPeriodName
let event = {
dateRange: dataRange
}
console.log(key)
global.SYSTEM_EVENT_HANDLER.raiseEvent(key, 'Data Range Updated', event)
callBack(global.DEFAULT_OK_RESPONSE);
}
}