Commit d7055843 authored by Eriksson Monteiro's avatar Eriksson Monteiro

update millix node

parent 7eb39c8b
...@@ -461,7 +461,7 @@ export class WalletTransactionConsensus { ...@@ -461,7 +461,7 @@ export class WalletTransactionConsensus {
console.log('[wallet-transaction-consensus-oracle] request received to validate transaction ', transactionID); console.log('[wallet-transaction-consensus-oracle] request received to validate transaction ', transactionID);
eventBus.emit('wallet_event_log', { eventBus.emit('wallet_event_log', {
type : 'transaction_validation_request', type : 'transaction_validation_start',
content: data, content: data,
from : node from : node
}); });
......
...@@ -1734,7 +1734,7 @@ class Wallet { ...@@ -1734,7 +1734,7 @@ class Wallet {
eventBus.on('shard_sync_request', this._onSyncShard.bind(this)); eventBus.on('shard_sync_request', this._onSyncShard.bind(this));
eventBus.on('wallet_transaction_sync', this._onSyncWalletBalance.bind(this)); eventBus.on('wallet_transaction_sync', this._onSyncWalletBalance.bind(this));
eventBus.on('wallet_transaction_sync_response', this._onSyncWalletBalanceResponse.bind(this)); eventBus.on('wallet_transaction_sync_response', this._onSyncWalletBalanceResponse.bind(this));
eventBus.on('transaction_validation_request', this._onTransactionValidationRequest.bind(this)); eventBus.on('transaction_validation_start', this._onTransactionValidationRequest.bind(this));
eventBus.on('transaction_validation_response', this._onTransactionValidationResponse.bind(this)); eventBus.on('transaction_validation_response', this._onTransactionValidationResponse.bind(this));
eventBus.on('transaction_spend_request', this._onSyncTransactionSpendTransaction.bind(this)); eventBus.on('transaction_spend_request', this._onSyncTransactionSpendTransaction.bind(this));
eventBus.on('transaction_output_spend_request', this._onSyncOutputSpendTransaction.bind(this)); eventBus.on('transaction_output_spend_request', this._onSyncOutputSpendTransaction.bind(this));
......
...@@ -668,7 +668,7 @@ class Peer { ...@@ -668,7 +668,7 @@ class Peer {
transactionValidationRequest(content, ws) { transactionValidationRequest(content, ws) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
let payload = { let payload = {
type: 'transaction_validation_request', type: 'transaction_validation_start',
content content
}; };
...@@ -678,7 +678,7 @@ class Peer { ...@@ -678,7 +678,7 @@ class Peer {
let data = JSON.stringify(payload); let data = JSON.stringify(payload);
try { try {
let callbackCalled = false; let callbackCalled = false;
if (ws.nodeConnectionReady && !(ws.inBound && !ws.bidirectional)) { if (ws.nodeConnectionReady) {
const messageID = 'transaction_validation_response:' + content.transaction_id; const messageID = 'transaction_validation_response:' + content.transaction_id;
eventBus.removeAllListeners(messageID); eventBus.removeAllListeners(messageID);
eventBus.once(messageID, function(eventData, eventWS) { eventBus.once(messageID, function(eventData, eventWS) {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment