diff --git a/.vs/AAWeb/v15/.suo b/.vs/AAWeb/v15/.suo index 01576ca0c..0540a584a 100644 Binary files a/.vs/AAWeb/v15/.suo and b/.vs/AAWeb/v15/.suo differ diff --git a/Files/DailyFiles.js b/Files/DailyFiles.js index 0e2dd4571..7506dc06d 100644 --- a/Files/DailyFiles.js +++ b/Files/DailyFiles.js @@ -29,128 +29,164 @@ function newDailyFiles() { function initialize(pDevTeam, pBot, pProduct, pSet, pExchange, pMarket, pDatetime, pTimePeriod, callBackFunction) { - 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); } + try { - callBackWhenFileReceived = callBackFunction; + 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); + callBackWhenFileReceived = callBackFunction; - if (exchange === undefined) { + let exchange = ecosystem.getExchange(pProduct, pExchange); - throw "Exchange not supoorted by this product of the ecosystem! - pDevTeam.codeName = " + pDevTeam.codeName + ", pBot.codeName = " + pBot.codeName + ", pProduct.codeName = " + pProduct.codeName + ", pExchange = " + pExchange; + if (exchange === undefined) { - } - - fileCloud = newFileCloud(); - fileCloud.initialize(pBot); - - /* Now we will get the daily files */ - - for (i = 0; i < dailyFilePeriods.length; i++) { - - let periodTime = dailyFilePeriods[i][0]; - let periodName = dailyFilePeriods[i][1]; - - if (pSet.validPeriods.includes(periodName) === true) { - - let fileCursor = newFileCursor(); - fileCursor.initialize(fileCloud, pDevTeam, pBot, pSet, exchange, pMarket, periodName, periodTime, pDatetime, pTimePeriod, onFileReceived); - - fileCursors.set(periodTime, fileCursor); - - expectedFiles = expectedFiles + fileCursor.getExpectedFiles(); + throw "Exchange not supoorted by this product of the ecosystem! - pDevTeam.codeName = " + pDevTeam.codeName + ", pBot.codeName = " + pBot.codeName + ", pProduct.codeName = " + pProduct.codeName + ", pExchange = " + pExchange; } + + fileCloud = newFileCloud(); + fileCloud.initialize(pBot); + + /* Now we will get the daily files */ + + for (i = 0; i < dailyFilePeriods.length; i++) { + + let periodTime = dailyFilePeriods[i][0]; + let periodName = dailyFilePeriods[i][1]; + + if (pSet.validPeriods.includes(periodName) === true) { + + let fileCursor = newFileCursor(); + fileCursor.initialize(fileCloud, pDevTeam, pBot, pSet, exchange, pMarket, periodName, periodTime, pDatetime, pTimePeriod, onFileReceived); + + fileCursors.set(periodTime, fileCursor); + + expectedFiles = expectedFiles + fileCursor.getExpectedFiles(); + + } + } + + } catch (err) { + + if (ERROR_LOG === true) { logger.write("[ERROR] initialize -> err = " + err); } + callBackFunction(GLOBAL.CUSTOM_FAIL_RESPONSE); } } function onFileReceived(err) { - if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Entering function."); } + try { - switch (err.result) { - case GLOBAL.DEFAULT_OK_RESPONSE.result: { + if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Entering function."); } - if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received OK Response."); } - break; + switch (err.result) { + case GLOBAL.DEFAULT_OK_RESPONSE.result: { + + if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received OK Response."); } + break; + } + + case GLOBAL.DEFAULT_FAIL_RESPONSE.result: { + + if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received FAIL Response."); } + callBackWhenFileReceived(GLOBAL.DEFAULT_FAIL_RESPONSE); + return; + } + + case GLOBAL.CUSTOM_FAIL_RESPONSE.result: { + + if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received CUSTOM FAIL Response."); } + if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> err.message = " + err.message); } + + callBackWhenFileReceived(err); + return; + } + + default: { + + if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received Unexpected Response."); } + callBackWhenFileReceived(err); + return; + } } - case GLOBAL.DEFAULT_FAIL_RESPONSE.result: { + filesLoaded++; + callBackWhenFileReceived(GLOBAL.DEFAULT_OK_RESPONSE, thisObject); // Note that the call back is called for every file loaded at each cursor. - if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received FAIL Response."); } - callBackWhenFileReceived(GLOBAL.DEFAULT_FAIL_RESPONSE); - return; - } + } catch (err) { - case GLOBAL.CUSTOM_FAIL_RESPONSE.result: { - - if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received CUSTOM FAIL Response."); } - if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> err.message = " + err.message); } - - callBackWhenFileReceived(err); - return; - } - - default: { - - if (INFO_LOG === true) { logger.write("[INFO] onFileReceived -> Received Unexpected Response."); } - callBackWhenFileReceived(err); - return; - } + if (ERROR_LOG === true) { logger.write("[ERROR] onFileReceived -> err = " + err); } + callBackWhenFileReceived(GLOBAL.CUSTOM_FAIL_RESPONSE); } - - filesLoaded++; - callBackWhenFileReceived(GLOBAL.DEFAULT_OK_RESPONSE, thisObject); // Note that the call back is called for every file loaded at each cursor. - } function getFileCursor(pPeriod) { - if (INFO_LOG === true) { logger.write("[INFO] getFileCursor -> Entering function."); } + try { - return fileCursors.get(pPeriod); + if (INFO_LOG === true) { logger.write("[INFO] getFileCursor -> Entering function."); } + return fileCursors.get(pPeriod); + + } catch (err) { + + if (ERROR_LOG === true) { logger.write("[ERROR] getFileCursor -> err = " + err); } + + } } function setDatetime(pDatetime) { - if (INFO_LOG === true) { logger.write("[INFO] setDatetime -> Entering function."); } + try { - filesLoaded = 0; - expectedFiles = 0; + if (INFO_LOG === true) { logger.write("[INFO] setDatetime -> Entering function."); } - fileCursors.forEach(setDatetimeToEach) + filesLoaded = 0; + expectedFiles = 0; - function setDatetimeToEach(fileCursor, key, map) { + fileCursors.forEach(setDatetimeToEach) - fileCursor.setDatetime(pDatetime, onFileReceived); - expectedFiles = expectedFiles + fileCursor.getExpectedFiles(); + function setDatetimeToEach(fileCursor, key, map) { + fileCursor.setDatetime(pDatetime, onFileReceived); + expectedFiles = expectedFiles + fileCursor.getExpectedFiles(); + + } + + if (INFO_LOG === true) { logger.write("[INFO] setDatetime -> expectedFiles = " + expectedFiles); } + + } catch (err) { + + if (ERROR_LOG === true) { logger.write("[ERROR] setDatetime -> err = " + err); } + } - - if (INFO_LOG === true) { logger.write("[INFO] setDatetime -> expectedFiles = " + expectedFiles); } - } function setTimePeriod(pTimePeriod, pDatetime) { - if (INFO_LOG === true) { logger.write("[INFO] setTimePeriod -> Entering function."); } + try { - filesLoaded = 0; - expectedFiles = 0; + if (INFO_LOG === true) { logger.write("[INFO] setTimePeriod -> Entering function."); } - fileCursors.forEach(setTimePeriodToEach) + filesLoaded = 0; + expectedFiles = 0; - function setTimePeriodToEach(fileCursor, key, map) { + fileCursors.forEach(setTimePeriodToEach) - fileCursor.setTimePeriod(pTimePeriod, pDatetime, onFileReceived); - expectedFiles = expectedFiles + fileCursor.getExpectedFiles(); + function setTimePeriodToEach(fileCursor, key, map) { + + fileCursor.setTimePeriod(pTimePeriod, pDatetime, onFileReceived); + expectedFiles = expectedFiles + fileCursor.getExpectedFiles(); + + } + + if (INFO_LOG === true) { logger.write("[INFO] setTimePeriod -> expectedFiles = " + expectedFiles); } + + } catch (err) { + + if (ERROR_LOG === true) { logger.write("[ERROR] setTimePeriod -> err = " + err); } } - - if (INFO_LOG === true) { logger.write("[INFO] setTimePeriod -> expectedFiles = " + expectedFiles); } - } function getExpectedFiles() { diff --git a/Files/MarketFiles.js b/Files/MarketFiles.js index 45be19298..6dbdd60b6 100644 --- a/Files/MarketFiles.js +++ b/Files/MarketFiles.js @@ -53,45 +53,52 @@ function newMarketFiles() { function onFileReceived(err, file) { - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Entering function."); } + try { - switch (err.result) { - case GLOBAL.DEFAULT_OK_RESPONSE.result: { + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Entering function."); } - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received OK Response."); } - break; + switch (err.result) { + case GLOBAL.DEFAULT_OK_RESPONSE.result: { + + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received OK Response."); } + break; + } + + case GLOBAL.DEFAULT_FAIL_RESPONSE.result: { + + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received FAIL Response."); } + callBackFunction(GLOBAL.DEFAULT_FAIL_RESPONSE); + return; + } + + case GLOBAL.CUSTOM_FAIL_RESPONSE.result: { + + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received CUSTOM FAIL Response."); } + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> err.message = " + err.message); } + + callBackFunction(err); + return; + } + + default: { + + if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received Unexpected Response."); } + callBackFunction(err); + return; + } } - case GLOBAL.DEFAULT_FAIL_RESPONSE.result: { + files.set(periodTime, file); - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received FAIL Response."); } - callBackFunction(GLOBAL.DEFAULT_FAIL_RESPONSE); - return; - } + filesLoaded++; - case GLOBAL.CUSTOM_FAIL_RESPONSE.result: { + callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE, thisObject); // Note that the callback is called for every file loaded. - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received CUSTOM FAIL Response."); } - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> err.message = " + err.message); } + } catch (err) { - callBackFunction(err); - return; - } - - default: { - - if (INFO_LOG === true) { logger.write("[INFO] initialize -> onFileReceived -> Received Unexpected Response."); } - callBackFunction(err); - return; - } + if (ERROR_LOG === true) { logger.write("[ERROR] initialize -> onFileReceived -> err = " + err); } + callBackFunction(GLOBAL.CUSTOM_FAIL_RESPONSE); } - - files.set(periodTime, file); - - filesLoaded++; - - callBackFunction(GLOBAL.DEFAULT_OK_RESPONSE, thisObject); // Note that the callback is called for every file loaded. - } } }