fez5587/Superalgos
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

FILE_STORAGE.newFileStorage(processIndex,

Browse Source
This commit is contained in:
Luis Fernando Molina committed 2020-12-01 13:33:46 +01:00
1 parent 1dafffd1af
commit 84a18c7e77
22 files changed
+23 -23
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Bollinger-Bands-Indicator-Bot/Multi-Period-Daily/User.Bot.js
+1 -1
View File
@@ -21,7 +21,7 @@
};
let utilities = UTILITIES.newCloudUtilities();
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let statusDependencies;
let beginingOfMarket
Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Bollinger-Bands-Indicator-Bot/Multi-Period-Market/User.Bot.js
+1 -1
View File
@@ -18,7 +18,7 @@
let statusDependencies;
let utilities = UTILITIES.newCloudUtilities();
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
return thisObject;
Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Candles-Volumes-Indicator-Bot/Multi-Period-Daily/User.Bot.js
+1 -1
View File
@@ -23,7 +23,7 @@
};
let utilities = UTILITIES.newCloudUtilities();
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let statusDependencies;
let beginingOfMarket
Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Candles-Volumes-Indicator-Bot/Multi-Period-Market/User.Bot.js
+1 -1
View File
@@ -23,7 +23,7 @@
};
let utilities = UTILITIES.newCloudUtilities();
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let statusDependencies;
let beginingOfMarket
Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Exchange-Raw-Data-Sensor-Bot/Historic-OHLCVs/User.Bot.js
+1 -1
View File
@@ -13,7 +13,7 @@ exports.newUserBot = function (processIndex, COMMONS, UTILITIES, FILE_STORAGE, S
};
let utilities = UTILITIES.newCloudUtilities()
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let statusDependencies
const ONE_MIN = 60000
Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Exchange-Raw-Data-Sensor-Bot/Historic-Trades/User.Bot.js
+1 -1
View File
@@ -14,7 +14,7 @@ exports.newUserBot = function (processIndex, COMMONS, UTILITIES, FILE_STORAGE, S
};
let utilities = UTILITIES.newCloudUtilities()
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let statusDependencies
const ONE_MINUTE = 60000
Projects/Superalgos/Bots-Plotters-Code/Masters/bots/Webhooks-Sensor-Bot/Check-Webhook/User.Bot.js
+1 -1
View File
@@ -12,7 +12,7 @@ exports.newUserBot = function (processIndex, COMMONS, UTILITIES, FILE_STORAGE, S
};
let utilities = UTILITIES.newCloudUtilities()
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let statusDependencies
return thisObject;
TaskServer/Commons.js
+1 -1
View File
@@ -13,7 +13,7 @@
};
let utilities = UTILITIES.newCloudUtilities();
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
return thisObject;
TaskServer/DataSet.js
+1 -1
View File
@@ -91,7 +91,7 @@ exports.newDataSet = function (processIndex) {
/* We found where the data is located on the network. */
TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE.write(MODULE_NAME, "[INFO] initialize -> Retrieving data from " + networkNode.name + " -> host = " + networkNode.config.host + ' -> port = ' + networkNode.config.webPort + '.')
fileStorage = FILE_STORAGE.newFileStorage(networkNode.config.host, networkNode.config.webPort);
fileStorage = FILE_STORAGE.newFileStorage(processIndex, networkNode.config.host, networkNode.config.webPort);
callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE, true);
} catch (err) {
TaskServer/DebugLog.js
+1 -1
View File
@@ -94,7 +94,7 @@ exports.newDebugLog = function (processIndex) {
accumulatedLog = "[";
const FILE_STORAGE = require('./FileStorage.js');
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let filePath = TS.projects.superalgos.globals.processVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).FILE_PATH_ROOT + "/Logs/" + TS.projects.superalgos.globals.taskConstants.TASK_NODE.bot.processes[processIndex].referenceParent.config.codeName + "/"
TaskServer/FileStorage.js
+1 -1
View File
@@ -1,7 +1,7 @@
const path = require('path')
exports.newFileStorage = function newFileStorage(host, port) {
exports.newFileStorage = function newFileStorage(processIndex, host, port) {
const MODULE_NAME = 'FileStorage'
const MAX_RETRY = 10
TaskServer/IndicatorBot.js
+1 -1
View File
@@ -8,7 +8,7 @@
const MULTI_PERIOD_MARKET = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'MultiPeriodMarket');
const MULTI_PERIOD_DAILY = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'MultiPeriodDaily');
const FILE_STORAGE = require('./FileStorage.js');
let fileStorage = FILE_STORAGE.newFileStorage(TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE);
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE);
const DEBUG_MODULE = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'DebugLog');
TaskServer/IndicatorOutput.js
+1 -1
View File
@@ -8,7 +8,7 @@
};
let utilities = UTILITIES.newCloudUtilities();
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
const COMMONS = require('./Commons.js');
let commons = COMMONS.newCommons(UTILITIES, FILE_STORAGE);
TaskServer/LowFrequencyTrading/Snapshots.js
+1 -1
View File
@@ -295,7 +295,7 @@ exports.newSnapshots = function (processIndex) {
function writeSnapshotFile(snapshotArray, pFileName) {
try {
const FILE_STORAGE = require('../FileStorage.js');
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
let fileContent = "";
let separator = "\r\n";
TaskServer/LowFrequencyTrading/TradingOutput.js
+1 -1
View File
@@ -12,7 +12,7 @@ exports.newTradingOutput = function (processIndex, tradingEngineModule, UTILITIE
}
let utilities = UTILITIES.newCloudUtilities()
let fileStorage = FILE_STORAGE.newFileStorage()
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, )
return thisObject
TaskServer/LowFrequencyTrading/TradingProcess.js
+1 -1
View File
@@ -21,7 +21,7 @@
let multiPeriodDataFiles = new Map();
const FILE_STORAGE = require('../FileStorage.js');
let fileStorage = FILE_STORAGE.newFileStorage();
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, );
const TRADING_ENGINE_MODULE = require('./TradingEngine.js')
let tradingEngineModule = TRADING_ENGINE_MODULE.newTradingEngine(processIndex)
TaskServer/MultiPeriodDaily.js
+1 -1
View File
@@ -9,7 +9,7 @@
};
let utilities = UTILITIES.newCloudUtilities()
let fileStorage = FILE_STORAGE.newFileStorage()
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, )
let statusDependencies;
let dataDependenciesModule;
TaskServer/MultiPeriodMarket.js
+1 -1
View File
@@ -7,7 +7,7 @@
};
let utilities = UTILITIES.newCloudUtilities()
let fileStorage = FILE_STORAGE.newFileStorage()
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, )
let statusDependencies;
let dataDependenciesModule;
TaskServer/ReinforcementLearning/LearningBot.js
+1 -1
View File
@@ -7,7 +7,7 @@ exports.newLearningBot = function (processIndex, parentLogger) {
const FILE_STORAGE = require('./FileStorage.js');
const SESSION = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'TradingSession');
let fileStorage = FILE_STORAGE.newFileStorage(parentLogger);
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, parentLogger);
let session = SESSION.newLearningSession(processIndex, parentLogger)
const DEBUG_MODULE = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'DebugLog');
TaskServer/SensorBot.js
+1 -1
View File
@@ -6,7 +6,7 @@
let COMMONS_MODULE;
const FILE_STORAGE = require('./FileStorage.js');
let fileStorage = FILE_STORAGE.newFileStorage(TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE);
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE);
const DEBUG_MODULE = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'DebugLog');
TaskServer/StatusReport.js
+2 -2
View File
@@ -153,7 +153,7 @@
thisObject.networkNode = networkNode
TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE.write(MODULE_NAME, "[INFO] initialize -> Retrieving status report from " + networkNode.name + " -> host = " + networkNode.config.host + ' -> port = ' + networkNode.config.webPort + '.')
fileStorage = FILE_STORAGE.newFileStorage(networkNode.config.host, networkNode.config.webPort)
fileStorage = FILE_STORAGE.newFileStorage(processIndex, networkNode.config.host, networkNode.config.webPort)
callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE)
return true
}
@@ -204,7 +204,7 @@
thisObject.networkNode = networkNode
TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).BOT_MAIN_LOOP_LOGGER_MODULE.write(MODULE_NAME, "[INFO] initialize -> Retrieving status report from " + networkNode.name + " -> host = " + networkNode.config.host + ' -> port = ' + networkNode.config.webPort + '.')
fileStorage = FILE_STORAGE.newFileStorage(networkNode.config.host, networkNode.config.webPort)
fileStorage = FILE_STORAGE.newFileStorage(processIndex, networkNode.config.host, networkNode.config.webPort)
callBackFunction(TS.projects.superalgos.globals.standardResponses.DEFAULT_OK_RESPONSE)
return true
}
TaskServer/TradingBot.js
+1 -1
View File
@@ -7,7 +7,7 @@
const FILE_STORAGE = require('./FileStorage.js');
const SESSION = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'TradingSession');
let fileStorage = FILE_STORAGE.newFileStorage(TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE);
let fileStorage = FILE_STORAGE.newFileStorage(processIndex, TS.projects.superalgos.globals.loggerVariables.VARIABLES_BY_PROCESS_INDEX_MAP.get(processIndex).PROCESS_INSTANCE_LOGGER_MODULE);
let session = SESSION.newTradingSession(processIndex)
const DEBUG_MODULE = require(TS.projects.superalgos.globals.nodeJSConstants.REQUIRE_ROOT_DIR + 'DebugLog');