diff --git a/src/FileCursor.js b/src/FileCursor.js index 755cacc03..e25dc3a3d 100644 --- a/src/FileCursor.js +++ b/src/FileCursor.js @@ -33,6 +33,7 @@ function newFileCursor () { let endDateRange let intervalHandle + let finalized = false return thisObject @@ -47,6 +48,7 @@ function newFileCursor () { fileCloud = undefined periodName = undefined timePeriod = undefined + finalized = true } catch (err) { if (ERROR_LOG === true) { logger.write('[ERROR] finalize -> err = ' + err) } } @@ -88,6 +90,7 @@ function newFileCursor () { function updateFiles () { try { + if (finalized === true) { return } if (INFO_LOG === true) { logger.write('[INFO] updateFiles -> Entering function.') } /* diff --git a/src/FileSequence.js b/src/FileSequence.js index ff68362ee..615ea4225 100644 --- a/src/FileSequence.js +++ b/src/FileSequence.js @@ -24,6 +24,8 @@ function newFileSequence () { let bot let thisSet let product + let finalized = false + let initialized = false thisObject.eventHandler = newEventHandler() @@ -45,6 +47,7 @@ function newFileSequence () { fileCloud = undefined files = undefined maxSequence = undefined + finalized = true } catch (err) { if (ERROR_LOG === true) { logger.write('[ERROR] finalize -> err = ' + err) } } @@ -83,6 +86,8 @@ function newFileSequence () { if (INFO_LOG === true) { logger.write('[INFO] initialize -> onSequenceFileReceived -> Entering function.') } if (INFO_LOG === true) { logger.write('[INFO] initialize -> onSequenceFileReceived -> key = ' + devTeam.codeName + '-' + bot.codeName + '-' + product.codeName) } + initialized = true + switch (err.result) { case GLOBAL.DEFAULT_OK_RESPONSE.result: { if (INFO_LOG === true) { logger.write('[INFO] initialize -> onSequenceFileReceived -> Received OK Response.') } @@ -180,6 +185,8 @@ function newFileSequence () { function updateFiles () { try { + if (finalized === true || initialized === false) { return } + let updateFiles = 0 if (INFO_LOG === true) { logger.write('[INFO] updateFiles -> Entering function.') } diff --git a/src/MarketFiles.js b/src/MarketFiles.js index 324a2c1f7..7bd256cc9 100644 --- a/src/MarketFiles.js +++ b/src/MarketFiles.js @@ -31,6 +31,7 @@ function newMarketFiles () { thisObject.eventHandler = newEventHandler() let intervalHandle + let finalized = false return thisObject @@ -42,6 +43,7 @@ function newMarketFiles () { filesLoaded = undefined files = undefined + finalized = true } catch (err) { if (ERROR_LOG === true) { logger.write('[ERROR] finalize -> err = ' + err) } } @@ -128,6 +130,7 @@ function newMarketFiles () { function updateFiles () { try { + if (finalized === true) { return } let updateFiles = 0 if (INFO_LOG === true) { logger.write('[INFO] updateFiles -> Entering function.') }