fixed supernode_went_down case in onMessage

This commit is contained in:
Abhishek Sinha 2019-11-28 15:38:14 +05:30
parent 00d1cd9b6e
commit c3b11c60bd

View File

@ -21109,15 +21109,20 @@
tableArray, tableArray,
su_obj.trader_flo_address su_obj.trader_flo_address
).then(su_db_data=>{ ).then(su_db_data=>{
RM_RPC.send_rpc
.call( for(recvr in localbitcoinplusplus.backupWS) {
this, su_db_data.trader_flo_address = su_obj.trader_flo_address;
"sync_backup_supernode_from_backup_supernode_response", su_db_data.receiver_flo_address = recvr;
su_db_data
) RM_RPC.send_rpc
.then(server_sync_response => .call(
doSend(server_sync_response, su_obj.trader_flo_address) this,
); "sync_backup_supernode_from_backup_supernode_response",
su_db_data
)
.then(server_sync_response => doSend(server_sync_response, recvr)
);
}
}); });
// Sync data from other Supernodes as well // Sync data from other Supernodes as well
@ -26666,8 +26671,7 @@
); );
} else { } else {
latest_data.trader_flo_address = primarySupernodeOfThisUser; latest_data.trader_flo_address = primarySupernodeOfThisUser;
latest_data.receiver_flo_address = latest_data.receiver_flo_address = res_obj.globalParams.senderFloId;
res_obj.globalParams.senderFloId;
RM_RPC.send_rpc RM_RPC.send_rpc
.call( .call(
this, this,
@ -26763,8 +26767,7 @@
.then(function(su_db_data) { .then(function(su_db_data) {
if (typeof su_db_data == "object") { if (typeof su_db_data == "object") {
su_db_data.trader_flo_address = primarySupernodeOfThisUser; su_db_data.trader_flo_address = primarySupernodeOfThisUser;
su_db_data.receiver_flo_address = su_db_data.receiver_flo_address = res_obj.globalParams.senderFloId;
res_obj.globalParams.senderFloId;
RM_RPC.send_rpc RM_RPC.send_rpc
.call( .call(
this, this,