diff --git a/Projects/Network/SA/Modules/HttpNetworkClient.js b/Projects/Network/SA/Modules/HttpNetworkClient.js index d22174578..71d3d0c41 100644 --- a/Projects/Network/SA/Modules/HttpNetworkClient.js +++ b/Projects/Network/SA/Modules/HttpNetworkClient.js @@ -40,7 +40,7 @@ exports.newNetworkModulesHttpNetworkClient = function newNetworkModulesHttpNetwo function sendMessage(message) { return new Promise(sendHttpMessage) - function sendHttpMessage(resolve, reject) { + async function sendHttpMessage(resolve, reject) { try { let signature = web3.eth.accounts.sign(JSON.stringify(message), SA.secrets.map.get(thisObject.p2pNetworkClientCodeName).privateKey) diff --git a/Projects/Trading-Signals/TS/Modules/OutgoingTradingSignals.js b/Projects/Trading-Signals/TS/Modules/OutgoingTradingSignals.js index 62dd6917a..0c7edc77e 100644 --- a/Projects/Trading-Signals/TS/Modules/OutgoingTradingSignals.js +++ b/Projects/Trading-Signals/TS/Modules/OutgoingTradingSignals.js @@ -9,7 +9,6 @@ exports.newTradingSignalsModulesOutgoingTradingSignals = function (processIndex) return thisObject function initialize() { - } function finalize() { @@ -17,6 +16,17 @@ exports.newTradingSignalsModulesOutgoingTradingSignals = function (processIndex) function broadcastSignal(node) { if (node === undefined) { return } - if (node.outgoingSignals === undefined) { return } + if (node.outgoingSignals === undefined) { return } + if (node.outgoingSignals.signalReference === undefined) { return } + if (node.outgoingSignals.signalReference.referenceParent === undefined) { return } + + let signalMessage = { + signalId: SA.projects.foundations.utilities.miscellaneousFunctions.genereteUniqueId(), + tradingSystemNodeType: node.type, + socialTradingBotNodeType: node.outgoingSignals.signalReference.referenceParent.id, + socialTradingBotNodeId: node.outgoingSignals.signalReference.referenceParent.id + } + + TS.projects.foundations.globals.taskConstants.P2P_NETWORK.p2pNetworkStart.sendMessage(signalMessage) } }