RanchiMall/localbitcoinplusplus
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed issue of right supernodes not running fireNodeGoodByeEvent function

Browse Source
This commit is contained in:
Abhishek Sinha 2019-10-07 21:54:42 +05:30
parent 5cb9671217
commit 44deb33bc5
1 changed files with 35 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
supernode/index.html
View File

@ -13472,8 +13472,34 @@
} }
/* ADD A CONDITION SO THAT ONLY ONE SUPERNODE IN THE LEFT CAN RUN THIS */ /* ADD A CONDITION SO THAT ONLY ONE SUPERNODE IN THE LEFT CAN RUN THIS */
if(1) { const mcsFloIds = Object.keys(localbitcoinplusplus.myClosestSupernodes)
localbitcoinplusplus.actions.informAllANodeLeft(getFLOId); .map(m=>m.trader_flo_address);
const idx = mcsFloIds.indexOf(getFLOId);
if(idx>=0) {
// Get the list of left Supernodes of disconnected Supernodes
console.table(mcs);
let getLeftSusOfDisconnectedSu = mcs
.filter((f,i)=>(i<=idx
&& localbitcoinplusplus.wallets.my_local_flo_address!==f.trader_flo_address));
console.table(getLeftSusOfDisconnectedSu);
let aNearerLeftSupernodeIsAlive = false;
for (let ln = 0; ln < getLeftSusOfDisconnectedSu.length; ln++) {
const leftNodeObj = getLeftSusOfDisconnectedSu[ln];
let conns = localbitcoinplusplus.backupWS[leftNodeObj.trader_flo_address];
if(typeof conns === "object"
&& leftNodeObj.trader_flo_address !== getFLOId
&& conns.ws_connection.readyState==1) {
console.log(conns);
aNearerLeftSupernodeIsAlive=true;
}
}
if(!aNearerLeftSupernodeIsAlive) {
localbitcoinplusplus.actions.informAllANodeLeft(getFLOId);
}
} }
msg = `INFO: Supernode ${getFLOId} left.`; msg = `INFO: Supernode ${getFLOId} left.`;
@ -14135,7 +14161,7 @@
if (nextSu===flo_id if (nextSu===flo_id
|| ||
nextSu===localbitcoinplusplus.wallets.my_local_flo_address) continue; nextSu===localbitcoinplusplus.wallets.my_local_flo_address) continue;
nextSupernodeObj = nextSu; nextSupernodeObj = nextSuObj;
break; break;
} }
return nextSupernodeObj; return nextSupernodeObj;
@ -14173,17 +14199,17 @@
const switchMyWS = new backupSupernodesWebSocketObject(); const switchMyWS = new backupSupernodesWebSocketObject();
let closedFloId = await switchMyWS.getFloIdFromWSUrl(evt.srcElement.url); let closedFloId = await switchMyWS.getFloIdFromWSUrl(evt.srcElement.url);
let nxtSu = await getNextSupernode(closedFloId); let nxtSu = await getNextSupernode(closedFloId);
if ((nxtSu==localbitcoinplusplus.wallets.my_local_flo_address if ((nxtSu.trader_flo_address==localbitcoinplusplus.wallets.my_local_flo_address
|| nxtSu==msg_obj.subject_flo_id)) { || nxtSu.trader_flo_address==msg_obj.subject_flo_id)) {
let nxtSu2 = await getNextSupernode(nxtSu); let nxtSu2 = await getNextSupernode(nxtSu.trader_flo_address);
informOneSupernode(nxtSu2); informOneSupernode(nxtSu2.trader_flo_address);
} else if(typeof nxtSu !== "undefined") { } else if(typeof nxtSu !== "undefined") {
informOneSupernode(nxtSu); informOneSupernode(nxtSu.trader_flo_address);
} }
} }
}; };
} }
})(); })(sn);
//} //}
} }
}); });