Following Reference Parents Implemented

This commit is contained in:
Luis Fernando Molina committed 2019-11-07 17:32:46 +01:00
1 parent 0e2874cfaa
commit b95a58cbfd
2 files changed
+133 -106

No files matched your search

@@ -4,7 +4,7 @@ function newProtocolNode () {
}
return thisObject
function getProtocolNode (node, removePersonalData, parseCode, includeIds, includePayload, includeReferences) {
function getProtocolNode (node, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent) {
if (node === undefined) { return }
switch (node.type) {
case 'Code':
@@ -29,7 +29,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -48,7 +48,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.conditions.length; m++) {
let condition = getProtocolNode(node.conditions[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let condition = getProtocolNode(node.conditions[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (condition !== undefined) {
object.conditions.push(condition)
}
@@ -87,13 +87,13 @@ function newProtocolNode () {
announcements: []
}
for (let m = 0; m < node.situations.length; m++) {
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (situation !== undefined) {
object.situations.push(situation)
}
}
for (let m = 0; m < node.announcements.length; m++) {
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (announcement !== undefined) {
object.announcements.push(announcement)
}
@@ -112,11 +112,11 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
announcements: [],
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
nextPhaseEvent: getProtocolNode(node.nextPhaseEvent, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
nextPhaseEvent: getProtocolNode(node.nextPhaseEvent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
for (let m = 0; m < node.announcements.length; m++) {
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (announcement !== undefined) {
object.announcements.push(announcement)
}
@@ -138,7 +138,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.phases.length; m++) {
let phase = getProtocolNode(node.phases[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let phase = getProtocolNode(node.phases[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (phase !== undefined) {
object.phases.push(phase)
}
@@ -160,7 +160,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.phases.length; m++) {
let phase = getProtocolNode(node.phases[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let phase = getProtocolNode(node.phases[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (phase !== undefined) {
object.phases.push(phase)
}
@@ -183,13 +183,13 @@ function newProtocolNode () {
}
for (let m = 0; m < node.situations.length; m++) {
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (situation !== undefined) {
object.situations.push(situation)
}
}
for (let m = 0; m < node.announcements.length; m++) {
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (announcement !== undefined) {
object.announcements.push(announcement)
}
@@ -212,11 +212,11 @@ function newProtocolNode () {
}
for (let m = 0; m < node.situations.length; m++) {
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
object.situations.push(situation)
}
for (let m = 0; m < node.announcements.length; m++) {
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (announcement !== undefined) {
object.announcements.push(announcement)
}
@@ -239,13 +239,13 @@ function newProtocolNode () {
}
for (let m = 0; m < node.situations.length; m++) {
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let situation = getProtocolNode(node.situations[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (situation !== undefined) {
object.situations.push(situation)
}
}
for (let m = 0; m < node.announcements.length; m++) {
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (announcement !== undefined) {
object.announcements.push(announcement)
}
@@ -263,10 +263,10 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
stopLoss: getProtocolNode(node.stopLoss, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
takeProfit: getProtocolNode(node.takeProfit, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
positionSize: getProtocolNode(node.positionSize, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
positionRate: getProtocolNode(node.positionRate, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
stopLoss: getProtocolNode(node.stopLoss, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
takeProfit: getProtocolNode(node.takeProfit, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
positionSize: getProtocolNode(node.positionSize, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
positionRate: getProtocolNode(node.positionRate, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -309,7 +309,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -324,7 +324,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -339,9 +339,9 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
triggerOn: getProtocolNode(node.triggerOn, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
triggerOff: getProtocolNode(node.triggerOff, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
takePosition: getProtocolNode(node.takePosition, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
triggerOn: getProtocolNode(node.triggerOn, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
triggerOff: getProtocolNode(node.triggerOff, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
takePosition: getProtocolNode(node.takePosition, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -356,8 +356,8 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
initialDefinition: getProtocolNode(node.initialDefinition, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
openExecution: getProtocolNode(node.openExecution, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
initialDefinition: getProtocolNode(node.initialDefinition, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
openExecution: getProtocolNode(node.openExecution, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -372,8 +372,8 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
stopLoss: getProtocolNode(node.stopLoss, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
takeProfit: getProtocolNode(node.takeProfit, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
stopLoss: getProtocolNode(node.stopLoss, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
takeProfit: getProtocolNode(node.takeProfit, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -388,7 +388,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
closeExecution: getProtocolNode(node.closeExecution, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
closeExecution: getProtocolNode(node.closeExecution, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -403,10 +403,10 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
triggerStage: getProtocolNode(node.triggerStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
openStage: getProtocolNode(node.openStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
manageStage: getProtocolNode(node.manageStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
closeStage: getProtocolNode(node.closeStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
triggerStage: getProtocolNode(node.triggerStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
openStage: getProtocolNode(node.openStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
manageStage: getProtocolNode(node.manageStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
closeStage: getProtocolNode(node.closeStage, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -508,12 +508,12 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
baseAsset: getProtocolNode(node.baseAsset, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
timeRange: getProtocolNode(node.timeRange, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
timePeriod: getProtocolNode(node.timePeriod, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
slippage: getProtocolNode(node.slippage, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
feeStructure: getProtocolNode(node.feeStructure, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
key: getProtocolNode(node.key, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
baseAsset: getProtocolNode(node.baseAsset, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
timeRange: getProtocolNode(node.timeRange, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
timePeriod: getProtocolNode(node.timePeriod, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
slippage: getProtocolNode(node.slippage, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
feeStructure: getProtocolNode(node.feeStructure, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
key: getProtocolNode(node.key, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -529,11 +529,11 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
strategies: [],
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
for (let m = 0; m < node.strategies.length; m++) {
let strategy = getProtocolNode(node.strategies[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let strategy = getProtocolNode(node.strategies[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (strategy !== undefined) {
object.strategies.push(strategy)
}
@@ -556,7 +556,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.exchangeAccounts.length; m++) {
let exchangeAccount = getProtocolNode(node.exchangeAccounts[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let exchangeAccount = getProtocolNode(node.exchangeAccounts[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (exchangeAccount !== undefined) {
object.exchangeAccounts.push(exchangeAccount)
}
@@ -580,13 +580,13 @@ function newProtocolNode () {
}
for (let m = 0; m < node.assets.length; m++) {
let asset = getProtocolNode(node.assets[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let asset = getProtocolNode(node.assets[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (asset !== undefined) {
object.assets.push(asset)
}
}
for (let m = 0; m < node.keys.length; m++) {
let key = getProtocolNode(node.keys[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let key = getProtocolNode(node.keys[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (key !== undefined) {
object.keys.push(key)
}
@@ -639,7 +639,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.bots.length; m++) {
let bot = getProtocolNode(node.bots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let bot = getProtocolNode(node.bots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (bot !== undefined) {
object.bots.push(bot)
}
@@ -663,7 +663,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.announcements.length; m++) {
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let announcement = getProtocolNode(node.announcements[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (announcement !== undefined) {
object.announcements.push(announcement)
}
@@ -685,7 +685,7 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -704,7 +704,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.layers.length; m++) {
let layer = getProtocolNode(node.layers[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let layer = getProtocolNode(node.layers[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (layer !== undefined) {
object.layers.push(layer)
}
@@ -744,7 +744,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.tasks.length; m++) {
let task = getProtocolNode(node.tasks[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let task = getProtocolNode(node.tasks[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (task !== undefined) {
object.tasks.push(task)
}
@@ -762,7 +762,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
bot: getProtocolNode(node.bot, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
bot: getProtocolNode(node.bot, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -782,7 +782,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.processes.length; m++) {
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (process !== undefined) {
object.processes.push(process)
}
@@ -808,7 +808,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.processes.length; m++) {
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (process !== undefined) {
object.processes.push(process)
}
@@ -834,7 +834,7 @@ function newProtocolNode () {
}
for (let m = 0; m < node.processes.length; m++) {
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (process !== undefined) {
object.processes.push(process)
}
@@ -856,7 +856,7 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
session: getProtocolNode(node.session, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
session: getProtocolNode(node.session, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (parseCode) {
object.code = JSON.parse(node.code)
@@ -867,6 +867,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Backtesting Session': {
@@ -875,9 +878,9 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (parseCode) {
object.code = JSON.parse(object.code)
@@ -888,6 +891,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Live Trading Session': {
@@ -896,9 +902,9 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (parseCode) {
object.code = JSON.parse(node.code)
@@ -909,6 +915,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Fordward Testing Session': {
@@ -917,9 +926,9 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (parseCode) {
object.code = JSON.parse(object.code)
@@ -930,6 +939,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Paper Trading Session': {
@@ -938,9 +950,9 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
parameters: getProtocolNode(node.parameters, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
layerManager: getProtocolNode(node.layerManager, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
socialBots: getProtocolNode(node.socialBots, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (parseCode) {
object.code = JSON.parse(node.code)
@@ -951,6 +963,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Network Node': {
@@ -962,7 +977,7 @@ function newProtocolNode () {
}
if (node.taskManagers !== undefined) {
for (let m = 0; m < node.taskManagers.length; m++) {
let taskManager = getProtocolNode(node.taskManagers[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let taskManager = getProtocolNode(node.taskManagers[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (taskManager !== undefined) {
object.taskManagers.push(taskManager)
}
@@ -985,7 +1000,7 @@ function newProtocolNode () {
}
if (node.networkNodes !== undefined) {
for (let m = 0; m < node.networkNodes.length; m++) {
let networkNode = getProtocolNode(node.networkNodes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let networkNode = getProtocolNode(node.networkNodes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (networkNode !== undefined) {
object.networkNodes.push(networkNode)
}
@@ -1004,8 +1019,8 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
tradingSystem: getProtocolNode(node.tradingSystem, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
personalData: getProtocolNode(node.personalData, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
tradingSystem: getProtocolNode(node.tradingSystem, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
personalData: getProtocolNode(node.personalData, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1028,7 +1043,7 @@ function newProtocolNode () {
}
if (node.sensorBots !== undefined) {
for (let m = 0; m < node.sensorBots.length; m++) {
let sensorBot = getProtocolNode(node.sensorBots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let sensorBot = getProtocolNode(node.sensorBots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (sensorBot !== undefined) {
object.sensorBots.push(sensorBot)
}
@@ -1036,7 +1051,7 @@ function newProtocolNode () {
}
if (node.indicatorBots !== undefined) {
for (let m = 0; m < node.indicatorBots.length; m++) {
let indicatorBot = getProtocolNode(node.indicatorBots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let indicatorBot = getProtocolNode(node.indicatorBots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (indicatorBot !== undefined) {
object.indicatorBots.push(indicatorBot)
}
@@ -1044,7 +1059,7 @@ function newProtocolNode () {
}
if (node.tradingBots !== undefined) {
for (let m = 0; m < node.tradingBots.length; m++) {
let tradingBot = getProtocolNode(node.tradingBots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let tradingBot = getProtocolNode(node.tradingBots[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (tradingBot !== undefined) {
object.tradingBots.push(tradingBot)
}
@@ -1052,7 +1067,7 @@ function newProtocolNode () {
}
if (node.plotters !== undefined) {
for (let m = 0; m < node.plotters.length; m++) {
let plotter = getProtocolNode(node.plotters[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let plotter = getProtocolNode(node.plotters[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (plotter !== undefined) {
object.plotters.push(plotter)
}
@@ -1077,7 +1092,7 @@ function newProtocolNode () {
}
if (node.processes !== undefined) {
for (let m = 0; m < node.processes.length; m++) {
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (process !== undefined) {
object.processes.push(process)
}
@@ -1085,7 +1100,7 @@ function newProtocolNode () {
}
if (node.products !== undefined) {
for (let m = 0; m < node.products.length; m++) {
let product = getProtocolNode(node.products[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let product = getProtocolNode(node.products[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (product !== undefined) {
object.products.push(product)
}
@@ -1110,7 +1125,7 @@ function newProtocolNode () {
}
if (node.processes !== undefined) {
for (let m = 0; m < node.processes.length; m++) {
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (process !== undefined) {
object.processes.push(process)
}
@@ -1118,7 +1133,7 @@ function newProtocolNode () {
}
if (node.products !== undefined) {
for (let m = 0; m < node.products.length; m++) {
let product = getProtocolNode(node.products[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let product = getProtocolNode(node.products[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (product !== undefined) {
object.products.push(product)
}
@@ -1143,7 +1158,7 @@ function newProtocolNode () {
}
if (node.processes !== undefined) {
for (let m = 0; m < node.processes.length; m++) {
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let process = getProtocolNode(node.processes[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (process !== undefined) {
object.processes.push(process)
}
@@ -1151,7 +1166,7 @@ function newProtocolNode () {
}
if (node.products !== undefined) {
for (let m = 0; m < node.products.length; m++) {
let product = getProtocolNode(node.products[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let product = getProtocolNode(node.products[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (product !== undefined) {
object.products.push(product)
}
@@ -1171,13 +1186,13 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
processOutput: getProtocolNode(node.processOutput, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
processDependencies: getProtocolNode(node.processDependencies, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
statusReport: getProtocolNode(node.statusReport, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
executionStartedEvent: getProtocolNode(node.executionStartedEvent, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
executionFinishedEvent: getProtocolNode(node.executionFinishedEvent, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
calculations: getProtocolNode(node.calculations, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
dataBuilding: getProtocolNode(node.dataBuilding, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
processOutput: getProtocolNode(node.processOutput, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
processDependencies: getProtocolNode(node.processDependencies, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
statusReport: getProtocolNode(node.statusReport, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
executionStartedEvent: getProtocolNode(node.executionStartedEvent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
executionFinishedEvent: getProtocolNode(node.executionFinishedEvent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
calculations: getProtocolNode(node.calculations, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
dataBuilding: getProtocolNode(node.dataBuilding, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1196,7 +1211,7 @@ function newProtocolNode () {
}
if (node.outputDatasets !== undefined) {
for (let m = 0; m < node.outputDatasets.length; m++) {
let outputDataset = getProtocolNode(node.outputDatasets[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let outputDataset = getProtocolNode(node.outputDatasets[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (outputDataset !== undefined) {
object.outputDatasets.push(outputDataset)
}
@@ -1220,7 +1235,7 @@ function newProtocolNode () {
}
if (node.statusDependencies !== undefined) {
for (let m = 0; m < node.statusDependencies.length; m++) {
let statusDependency = getProtocolNode(node.statusDependencies[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let statusDependency = getProtocolNode(node.statusDependencies[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (statusDependency !== undefined) {
object.statusDependencies.push(statusDependency)
}
@@ -1228,7 +1243,7 @@ function newProtocolNode () {
}
if (node.dataDependencies !== undefined) {
for (let m = 0; m < node.dataDependencies.length; m++) {
let dataDependency = getProtocolNode(node.dataDependencies[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let dataDependency = getProtocolNode(node.dataDependencies[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (dataDependency !== undefined) {
object.dataDependencies.push(dataDependency)
}
@@ -1268,6 +1283,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Execution Finished Event': {
@@ -1289,8 +1307,8 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
initialization: getProtocolNode(node.initialization, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
loop: getProtocolNode(node.loop, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
initialization: getProtocolNode(node.initialization, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
loop: getProtocolNode(node.loop, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1305,8 +1323,8 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
initialization: getProtocolNode(node.initialization, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
loop: getProtocolNode(node.loop, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
initialization: getProtocolNode(node.initialization, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
loop: getProtocolNode(node.loop, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1321,7 +1339,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1336,7 +1354,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1358,6 +1376,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Status Dependency': {
@@ -1372,6 +1393,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Data Dependency': {
@@ -1386,6 +1410,9 @@ function newProtocolNode () {
if (includePayload) {
object.savedPayload = getSavedPayload(node, includeReferences)
}
if (followReferenceParent) {
object.referenceParent = getProtocolNode(node.payload.referenceParent, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
return object
}
case 'Product Definition': {
@@ -1394,12 +1421,12 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
record: getProtocolNode(node.record, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
record: getProtocolNode(node.record, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
datasets: []
}
if (node.datasets !== undefined) {
for (let m = 0; m < node.datasets.length; m++) {
let dataset = getProtocolNode(node.datasets[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let dataset = getProtocolNode(node.datasets[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (dataset !== undefined) {
object.datasets.push(dataset)
}
@@ -1422,7 +1449,7 @@ function newProtocolNode () {
}
if (node.properties !== undefined) {
for (let m = 0; m < node.properties.length; m++) {
let property = getProtocolNode(node.properties[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let property = getProtocolNode(node.properties[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (property !== undefined) {
object.properties.push(property)
}
@@ -1442,7 +1469,7 @@ function newProtocolNode () {
subType: node.subType,
name: node.name,
code: node.code,
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
formula: getProtocolNode(node.formula, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -1476,7 +1503,7 @@ function newProtocolNode () {
}
if (node.modules !== undefined) {
for (let m = 0; m < node.modules.length; m++) {
let module = getProtocolNode(node.modules[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let module = getProtocolNode(node.modules[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (module !== undefined) {
object.modules.push(module)
}
@@ -1495,12 +1522,12 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences),
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent),
panels: []
}
if (node.panels !== undefined) {
for (let m = 0; m < node.panels.length; m++) {
let panel = getProtocolNode(node.panels[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences)
let panel = getProtocolNode(node.panels[m], removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
if (panel !== undefined) {
object.panels.push(panel)
}
@@ -1519,7 +1546,7 @@ function newProtocolNode () {
type: node.type,
subType: node.subType,
name: node.name,
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences)
code: getProtocolNode(node.code, removePersonalData, parseCode, includeIds, includePayload, includeReferences, followReferenceParent)
}
if (includeIds) {
object.id = node.id
@@ -29,7 +29,7 @@ function newTaskFunctions () {
let event = {
taskId: node.id,
taskName: node.name,
definition: JSON.stringify(functionLibraryProtocolNode.getProtocolNode(node, false, true, true)) // <- We need to do this workaround in order no to send unescaped charactars to the taskManager.
definition: JSON.stringify(functionLibraryProtocolNode.getProtocolNode(node, false, true, true, false, false, true)) // <- We need to do this workaround in order no to send unescaped charactars to the taskManager.
}
systemEventHandler.raiseEvent('Task Manager', 'Run Task', event)
}