From 84149cc293f068c226d6ac91b625ba1b566e4edd Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Thu, 17 May 2018 09:01:13 +0200 Subject: [PATCH] Implementing Automatic Updates in Sequences part 1 --- Files/FileSequence.js | 67 +++++++++++++++++++++++++++++++++++++------ 1 file changed, 58 insertions(+), 9 deletions(-) diff --git a/Files/FileSequence.js b/Files/FileSequence.js index 2665e0840..eca8c348e 100644 --- a/Files/FileSequence.js +++ b/Files/FileSequence.js @@ -11,19 +11,43 @@ function newFileSequence() { getFile: getFile, getExpectedFiles: getExpectedFiles, getFilesLoaded: getFilesLoaded, - initialize: initialize + initialize: initialize, + finalize: finalize } let filesLoaded = 0; - let fileCloud; - let files = new Map; - let maxSequence = -1; // This is replaced by the content of the sequence file, which contains an index that starts on zero. In the case that the sequence file is not found the default value is -1 sin when you add 1 it gives you the amount of files in the sequence, zero. + let intervalHandle; return thisObject; + function finalize() { + + try { + + if (INFO_LOG === true) { logger.write("[INFO] finalize -> Entering function."); } + + clearInterval(intervalHandle); + + filesLoaded = undefined; + fileCloud = undefined; + files = undefined; + maxSequence = undefined; + devTeam = undefined; + bot = undefined; + product = undefined; + thisSet = undefined; + exchange = undefined; + market = undefined; + + } catch (err) { + + if (ERROR_LOG === true) { logger.write("[ERROR] finalize -> err = " + err); } + } + } + function initialize(pDevTeam, pBot, pProduct, pSet, pExchange, pMarket, callBackFunction) { try { @@ -31,7 +55,7 @@ function newFileSequence() { if (INFO_LOG === true) { logger.write("[INFO] initialize -> Entering function."); } if (INFO_LOG === true) { logger.write("[INFO] initialize -> key = " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName); } - let exchange = ecosystem.getExchange(pProduct, pExchange); + exchange = ecosystem.getExchange(pProduct, pExchange); if (exchange === undefined) { @@ -39,19 +63,27 @@ function newFileSequence() { } + market = pMarket; + devTeam = pDevTeam; + bot = pBot; + product = pProduct; + thisSet = pSet; + + intervalHandle = setInterval(updateFiles, _1_MINUTE_IN_MILISECONDS); + fileCloud = newFileCloud(); - fileCloud.initialize(pBot); + fileCloud.initialize(bot); /* First we will get the sequence max number */ - fileCloud.getFile(pDevTeam, pBot, pSet, exchange, pMarket, undefined, undefined, "Sequence", undefined, onSequenceFileReceived); + fileCloud.getFile(devTeam, bot, thisSet, exchange, market, undefined, undefined, "Sequence", undefined, onSequenceFileReceived); function onSequenceFileReceived(err, file) { try { if (INFO_LOG === true) { logger.write("[INFO] initialize -> onSequenceFileReceived -> Entering function."); } - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onSequenceFileReceived -> key = " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName); } + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onSequenceFileReceived -> key = " + devTeam.codeName + "-" + bot.codeName + "-" + product.codeName); } switch (err.result) { case GLOBAL.DEFAULT_OK_RESPONSE.result: { @@ -99,7 +131,7 @@ function newFileSequence() { for (let i = 0; i <= maxSequence; i++) { - fileCloud.getFile(pDevTeam, pBot, pSet, exchange, pMarket, undefined, undefined, i, undefined, onFileReceived); + fileCloud.getFile(devTeam, bot, thisSet, exchange, market, undefined, undefined, i, undefined, onFileReceived); function onFileReceived(err, file) { @@ -164,6 +196,23 @@ function newFileSequence() { } } + function updateFiles() { + + try { + + let updateFiles = 0; + + if (INFO_LOG === true) { logger.write("[INFO] updateFiles -> Entering function."); } + + + + + } catch (err) { + + if (ERROR_LOG === true) { logger.write("[ERROR] updateFiles -> err = " + err); } + } + } + function getFile(pSequence) { if (INFO_LOG === true) { logger.write("[INFO] getFile -> Entering function."); }