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

Merge pull request #4 from AAVikings/develop

Browse Source 
Changing default daily files data dependency config
This commit is contained in:
benme authored and GitHub committed 2019-03-27 10:38:18 +01:00
2 parents 3246019721 67ad17177c
commit 7c4fc27481
2 files changed
+22 -23
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

AABrowserAPI/CopySimulator.js
+9 -23
View File
@@ -1,13 +1,4 @@
// let financialBeingsCopy = newFinancialBeingClone()
// const simulatorTemplatePath = "aaplatform/AATemplate/bots/AAJason-Indicator-Bot1";
// const blobName = "this.bot.config.json";
// financialBeingsCopy.copySimulator("team-a", "team a", "matias", "bot-a", "bot a")
// async function copySimulator(pTeamCodeName, pTeamDisplayName, pUserName, pBotCodeName, pBotDisplayName, pUserId) {
const {
const {
Aborter,
BlobURL,
BlockBlobURL,
@@ -77,8 +68,8 @@ exports.newCopySimulator = function newCopySimulator() {
if (parsedConfig.processes[0].statusDependencies[i].devTeam === "AAMasters" &&
parsedConfig.processes[0].statusDependencies[i].bot === "AAJason") {
parsedConfig.processes[0].statusDependencies[i].devTeam = parsedConfig.devTeam;
parsedConfig.processes[0].statusDependencies[i].bot = parsedConfig.codeName;
parsedConfig.processes[0].statusDependencies[i].devTeam = parsedConfig.devTeam;
parsedConfig.processes[0].statusDependencies[i].bot = parsedConfig.codeName;
}
}
@@ -87,8 +78,8 @@ exports.newCopySimulator = function newCopySimulator() {
if (parsedConfig.processes[1].statusDependencies[i].devTeam === "AAMasters" &&
parsedConfig.processes[1].statusDependencies[i].bot === "AAJason") {
parsedConfig.processes[1].statusDependencies[i].devTeam = parsedConfig.devTeam;
parsedConfig.processes[1].statusDependencies[i].bot = parsedConfig.codeName;
parsedConfig.processes[1].statusDependencies[i].devTeam = parsedConfig.devTeam;
parsedConfig.processes[1].statusDependencies[i].bot = parsedConfig.codeName;
}
}
@@ -104,8 +95,8 @@ exports.newCopySimulator = function newCopySimulator() {
parsedConfig.products[1].dataSets[1].dataRange.filePath = pTeamCodeName + "/" + parsedConfig.codeName + ".1.0/AACloud.1.1/@Exchange/dataSet.V1/Output/Simulation-Conditions/Multi-Period-Daily"
// Write the new files
let newSimulatorName = "simulator-"+ pBotCodeName + "-Indicator-Bot"
let newSimulatorPath = "aaplatform/"+ pTeamCodeName + "/bots/" + newSimulatorName
let newSimulatorName = "simulator-" + pBotCodeName + "-Indicator-Bot"
let newSimulatorPath = "aaplatform/" + pTeamCodeName + "/bots/" + newSimulatorName
await writeFileContent(newSimulatorPath, "Commons.js", commons)
await writeFileContent(newSimulatorPath, "this.bot.config.json", beautify(parsedConfig, null, 2, 80))
await writeFileContent(newSimulatorPath + "/Multi-Period-Daily", "User.Bot.js", codeDaily)
@@ -125,7 +116,7 @@ exports.newCopySimulator = function newCopySimulator() {
// Delete simulator code
let newSimulatorName = "simulator-" + pBotCodeName + "-Indicator-Bot"
let newSimulatorPath = "aaplatform/"+ pTeamCodeName + "/bots/" + newSimulatorName
let newSimulatorPath = "aaplatform/" + pTeamCodeName + "/bots/" + newSimulatorName
await deleteBlob(newSimulatorPath, "Commons.js")
await deleteBlob(newSimulatorPath, "this.bot.config.json")
await deleteBlob(newSimulatorPath + "/Multi-Period-Daily", "User.Bot.js")
@@ -158,7 +149,7 @@ exports.newCopySimulator = function newCopySimulator() {
}
async function deleteBlob(containerName, blobName) {
try{
try {
const containerURL = ContainerURL.fromServiceURL(serviceURL, containerName)
const blockBlobURL = BlockBlobURL.fromContainerURL(containerURL, blobName)
await blockBlobURL.delete(Aborter.none)
@@ -167,11 +158,6 @@ exports.newCopySimulator = function newCopySimulator() {
}
}
async function deleteContainer(containerName) {
const containerURL = ContainerURL.fromServiceURL(serviceURL, containerName)
let containerRemoveResponse = await containerURL.delete(Aborter.none)
}
// A helper method used to read a Node.js readable stream into string
async function streamToString(readableStream) {
return new Promise((resolve, reject) => {
AABrowserAPI/TeamSetup.js
+13
View File
@@ -214,6 +214,7 @@
}
}
// Market Files
for (let i = 0; i < botConfig.processes[0].dataDependencies.length; i++) {
// Add a copy of the simulator indicator in the configuration
@@ -225,6 +226,18 @@
}
}
// Daily Files
for (let i = 0; i < botConfig.processes[1].dataDependencies.length; i++) {
// Add a copy of the simulator indicator in the configuration
if ( botConfig.processes[1].dataDependencies[i].devTeam === "AAMasters" &&
botConfig.processes[1].dataDependencies[i].bot === "AAJason" ) {
botConfig.processes[1].dataDependencies[i].devTeam = pTeamCodeName;
botConfig.processes[1].dataDependencies[i].bot = "simulator-" + pBotCodeName;
}
}
botConfig.displayName = pBotDisplayName;
botConfig.codeName = pBotCodeName;
botConfig.devTeam = pTeamCodeName;