From 50264e967596b4613faa41d5bcb4a824cf413072 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Mon, 6 Apr 2020 17:48:32 +0200 Subject: [PATCH] Bug fixed with caller Id --- src/FileCursor.js | 6 ++++-- src/MarketFiles.js | 3 ++- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/FileCursor.js b/src/FileCursor.js index d1bede545..88c1463e1 100644 --- a/src/FileCursor.js +++ b/src/FileCursor.js @@ -90,10 +90,12 @@ function newFileCursor () { endDateRange = pEndDateRange let key = dataMine.code.codeName + '-' + bot.code.codeName + '-' + product.code.codeName + '-' + dataset.code.codeName + '-' + exchange.name + '-' + market.baseAsset + '/' + market.quotedAsset - eventsServerClient.listenToEvent(key, 'Dataset Updated', undefined, key + '-' + periodName, onResponseDataSet, updateFiles) + let callerId = key + '-' + periodName + newUniqueId() + eventsServerClient.listenToEvent(key, 'Dataset Updated', undefined, callerId, onResponseDataSet, updateFiles) key = dataMine.code.codeName + '-' + bot.code.codeName + '-' + product.code.codeName + '-' + exchange.name + '-' + market.baseAsset + '/' + market.quotedAsset - eventsServerClient.listenToEvent(key, 'Data Range Updated', undefined, key, onResponseDataRange, updateDataRange) + callerId = key + '-' + periodName + newUniqueId() + eventsServerClient.listenToEvent(key, 'Data Range Updated', undefined, callerId, onResponseDataRange, updateDataRange) callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE) diff --git a/src/MarketFiles.js b/src/MarketFiles.js index 734314cfd..ec1a45ee2 100644 --- a/src/MarketFiles.js +++ b/src/MarketFiles.js @@ -109,7 +109,8 @@ function newMarketFiles () { if (filesLoaded + filesNotLoaded === marketFilesPeriods.length) { let key = dataMine.code.codeName + '-' + bot.code.codeName + '-' + product.code.codeName + '-' + dataset.code.codeName + '-' + exchange.name + '-' + market.baseAsset + '/' + market.quotedAsset - eventsServerClient.listenToEvent(key, 'Dataset Updated', undefined, key + '-' + periodName, onResponse, updateFiles) + let callerId = key + '-' + periodName + newUniqueId() + eventsServerClient.listenToEvent(key, 'Dataset Updated', undefined, callerId, onResponse, updateFiles) callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE, thisObject)