181 lines
5.3 KiB
JavaScript
181 lines
5.3 KiB
JavaScript
|
|
function newStorage(pName) {
|
|
|
|
const CONSOLE_LOG = false;
|
|
|
|
/*
|
|
|
|
This object will initialize children objects that will end up loading the data of each set defined at each product of the bot received at initialization.
|
|
Once all the underlaying objects are fully initialized it will callback.
|
|
|
|
At the same time it will raise an event for each underlaying file being loaded, so that the UI can reflect the progress to the end user.
|
|
|
|
*/
|
|
|
|
let thisObject = {
|
|
|
|
fileCache: undefined,
|
|
fileCursorCache: undefined,
|
|
file: undefined,
|
|
|
|
eventHandler: undefined,
|
|
initialize: initialize
|
|
|
|
}
|
|
|
|
thisObject.eventHandler = newEventHandler();
|
|
|
|
/* We name the event Handler to easy debugging. */
|
|
|
|
thisObject.eventHandler.name = "Storage-" + pName;
|
|
|
|
return thisObject;
|
|
|
|
function initialize(pDevTeam, pBot, pProduct, pExchange, pMarket, pDatetime, pTimePeriod, callBackFunction) {
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
|
|
let dataSetsToLoad = 0;
|
|
let dataSetsLoaded = 0;
|
|
|
|
for (let i = 0; i < pProduct.sets.length; i++) {
|
|
|
|
let thisSet = pProduct.sets[i];
|
|
|
|
switch (thisSet.type) {
|
|
case 'Market Files': {
|
|
|
|
thisObject.fileCache = newFileCache();
|
|
thisObject.fileCache.initialize(pDevTeam, pBot, pProduct, thisSet, pExchange, pMarket, onCacheFileReady);
|
|
dataSetsToLoad++;
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize Market Files for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
}
|
|
break;
|
|
|
|
case 'Daily Files': {
|
|
|
|
thisObject.fileCursorCache = newFileCursorCache();
|
|
thisObject.fileCursorCache.initialize(pDevTeam, pBot, pProduct, thisSet, pExchange, pMarket, pDatetime, pTimePeriod, onFileCursorReady);
|
|
dataSetsToLoad++;
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize Daily Files for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
}
|
|
break;
|
|
|
|
case 'Single File': {
|
|
|
|
thisObject.file = newFile();
|
|
thisObject.file.initialize(pDevTeam, pBot, pProduct, thisSet, pExchange, pMarket, onSingleFileReady);
|
|
dataSetsToLoad++;
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize Single File for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
}
|
|
break;
|
|
|
|
}
|
|
|
|
function onCacheFileReady() {
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize onCacheFileReady for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
|
|
let event = {
|
|
totalValue: thisObject.fileCache.getExpectedFiles(),
|
|
currentValue: thisObject.fileCache.getFilesLoaded()
|
|
}
|
|
|
|
thisObject.eventHandler.raiseEvent('Market File Loaded', event);
|
|
|
|
if (event.currentValue === event.totalValue) {
|
|
|
|
dataSetsLoaded++;
|
|
|
|
checkInitializeComplete();
|
|
}
|
|
}
|
|
|
|
function onFileCursorReady() {
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize onFileCursorReady for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
|
|
let event = {
|
|
totalValue: thisObject.fileCursorCache.getExpectedFiles(),
|
|
currentValue: thisObject.fileCursorCache.getFilesLoaded()
|
|
}
|
|
|
|
thisObject.eventHandler.raiseEvent('Daily File Loaded', event);
|
|
|
|
if (event.currentValue === event.totalValue) {
|
|
|
|
dataSetsLoaded++;
|
|
|
|
checkInitializeComplete();
|
|
}
|
|
}
|
|
|
|
function onSingleFileReady() {
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize onSingleFileReady for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
|
|
let event = {
|
|
totalValue: 1,
|
|
currentValue: 1
|
|
}
|
|
|
|
thisObject.eventHandler.raiseEvent('Single File Loaded', event);
|
|
|
|
if (event.currentValue === event.totalValue) {
|
|
|
|
dataSetsLoaded++;
|
|
|
|
checkInitializeComplete();
|
|
}
|
|
}
|
|
|
|
function checkInitializeComplete() {
|
|
|
|
if (CONSOLE_LOG === true) {
|
|
|
|
console.log("Storage initialize checkInitializeComplete for " + pDevTeam.codeName + "-" + pBot.codeName + "-" + pProduct.codeName);
|
|
|
|
}
|
|
|
|
if (dataSetsLoaded === dataSetsToLoad) {
|
|
|
|
callBackFunction();
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|