From df61289965c58e879b917e1f626b8154e4585061 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Thu, 17 Oct 2019 10:44:17 +0200 Subject: [PATCH 1/4] session foldername --- src/FileCloud.js | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/src/FileCloud.js b/src/FileCloud.js index e6730e8e3..42fc246ad 100644 --- a/src/FileCloud.js +++ b/src/FileCloud.js @@ -113,7 +113,19 @@ function newFileCloud () { } if (pSession !== undefined) { - filePath = filePath.replace('@Session', pSession.id) + let code + let sessionFolderName = pSession.id + if (pSession.code !== undefined) { + try { + code = JSON.parse(pSession.code) + if (code.folderName !== undefined) { + sessionFolderName = code.folderName + } + } catch (err) { + sessionFolderName = pSession.id + } + } + filePath = filePath.replace('@Session', sessionFolderName) } if (pExchange !== undefined) { From 192362a4af766fdbfbac4491bf3bbc1b863a7c73 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Mon, 21 Oct 2019 14:23:53 +0200 Subject: [PATCH 2/4] id added to foldername --- src/FileCloud.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/FileCloud.js b/src/FileCloud.js index 42fc246ad..85843234b 100644 --- a/src/FileCloud.js +++ b/src/FileCloud.js @@ -119,7 +119,7 @@ function newFileCloud () { try { code = JSON.parse(pSession.code) if (code.folderName !== undefined) { - sessionFolderName = code.folderName + sessionFolderName = code.folderName + '-' + pSession.id } } catch (err) { sessionFolderName = pSession.id From 3930f58f7e9c046d410bb81eb5dc673fdfc1c1d4 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Mon, 21 Oct 2019 15:31:03 +0200 Subject: [PATCH 3/4] Data Range Updated by Events --- src/FileCursor.js | 39 +++++++++++++++++++++++++++++++++++++-- 1 file changed, 37 insertions(+), 2 deletions(-) diff --git a/src/FileCursor.js b/src/FileCursor.js index 9952a314b..f1452062f 100644 --- a/src/FileCursor.js +++ b/src/FileCursor.js @@ -38,12 +38,15 @@ function newFileCursor () { let finalized = false let eventSubscriptionIdDatasetUpdated + let eventSubscriptionIdDataRangeUpdated return thisObject function finalize () { try { systemEventHandler.stopListening('Dataset Updated', eventSubscriptionIdDatasetUpdated) + systemEventHandler.stopListening('Data Range Updated', eventSubscriptionIdDataRangeUpdated) + thisObject.eventHandler = undefined market = undefined @@ -87,19 +90,51 @@ function newFileCursor () { endDateRange = pEndDateRange let key = devTeam.codeName + '-' + bot.codeName + '-' + product.codeName + '-' + thisSet.codeName - systemEventHandler.listenToEvent(key, 'Dataset Updated', undefined, key + '-' + periodName, onResponse, updateFiles) + systemEventHandler.listenToEvent(key, 'Dataset Updated', undefined, key + '-' + periodName, onResponseDataSet, updateFiles) + key = devTeam.codeName + '-' + bot.codeName + '-' + product.codeName + '-' + pPeriodName + systemEventHandler.listenToEvent(key, 'Data Range Updated', undefined, key, onResponseDataRange, updateDataRange) + console.log(key) callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE) - function onResponse (message) { + function onResponseDataSet (message) { eventSubscriptionIdDatasetUpdated = message.eventSubscriptionId } + + function onResponseDataRange (message) { + eventSubscriptionIdDataRangeUpdated = message.eventSubscriptionId + } } catch (err) { if (ERROR_LOG === true) { logger.write('[ERROR] initialize -> err = ' + err.stack) } callBackFunction(GLOBAL.DEFAULT_FAIL_RESPONSE) } } + function updateDataRange (message) { + try { + if (finalized === true) { return } + + if (message.event === undefined || message.event.dateRange === undefined) { return } + + beginDateRange = new Date(message.event.dateRange.begin) + endDateRange = new Date(message.event.dateRange.end) + + let minDate = beginDateRange.valueOf() + let maxDate = endDateRange.valueOf() + ONE_DAY_IN_MILISECONDS + + for (let key of thisObject.files.keys()) { + let keyDate = new Date(key) + + if (keyDate.valueOf() < minDate || keyDate.valueOf() > maxDate) { + thisObject.files.delete(key) + thisObject.eventHandler.raiseEvent('Files Updated') + } + } + } catch (err) { + if (ERROR_LOG === true) { logger.write('[ERROR] updateDataRange -> err = ' + err.stack) } + } + } + function updateFiles (message) { try { if (finalized === true) { return } From 9a329a0818bb5409385a3ba21e928cb9628f0cc9 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Mon, 21 Oct 2019 17:15:14 +0200 Subject: [PATCH 4/4] Removing Log --- src/FileCursor.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/FileCursor.js b/src/FileCursor.js index f1452062f..16b97ecfc 100644 --- a/src/FileCursor.js +++ b/src/FileCursor.js @@ -94,7 +94,7 @@ function newFileCursor () { key = devTeam.codeName + '-' + bot.codeName + '-' + product.codeName + '-' + pPeriodName systemEventHandler.listenToEvent(key, 'Data Range Updated', undefined, key, onResponseDataRange, updateDataRange) - console.log(key) + callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE) function onResponseDataSet (message) {