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

added can_serve_FLO_ID property to confirm sync before serving users

Browse Source
This commit is contained in:
Abhishek Sinha 2019-07-05 20:05:09 +05:30
parent d666b767ea
commit b66d91c721
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
supernode/index.html
View File

@ -15615,8 +15615,8 @@
|| res_obj.method==="retrieve_shamirs_secret_btc_pvtkey" || res_obj.method==="retrieve_shamirs_secret_btc_pvtkey"
|| res_obj.method==="do_you_have_latest_data_for_this_supernode" || res_obj.method==="do_you_have_latest_data_for_this_supernode"
) { ) {
handle_backup_server_messages(response); handle_backup_server_messages(response);
return; return;
} }
if (res_obj.method==="sync_backup_supernode_from_backup_supernode" if (res_obj.method==="sync_backup_supernode_from_backup_supernode"
|| res_obj.method==="sync_primary_supernode_from_backup_supernode_response" || res_obj.method==="sync_primary_supernode_from_backup_supernode_response"
@ -15789,7 +15789,6 @@
} }
function onOpen(evt) { function onOpen(evt) {
localbitcoinplusplus.amIreadyToServePrimaryUsers = false;
reactor.dispatchEvent('new_supernode_connected', evt); reactor.dispatchEvent('new_supernode_connected', evt);
readAllDB('myClosestSupernodes').then(sconn=>{ readAllDB('myClosestSupernodes').then(sconn=>{
const switchMyWS = new backupSupernodesWebSocketObject(); const switchMyWS = new backupSupernodesWebSocketObject();
@ -16913,7 +16912,7 @@
await localbitcoinplusplus.actions.delay(180000).then(()=>{ await localbitcoinplusplus.actions.delay(180000).then(()=>{
showMessage(`INFO: Balance syncing is complete.`); showMessage(`INFO: Balance syncing is complete.`);
localbitcoinplusplus.amIreadyToServePrimaryUsers = true; localbitcoinplusplus.services[`can_serve_${su_db_data.trader_flo_address}`] = true;
const RM_RPC = new localbitcoinplusplus.rpc; const RM_RPC = new localbitcoinplusplus.rpc;
@ -16958,7 +16957,7 @@
// await localbitcoinplusplus.actions.delay(180000).then(()=>{ // await localbitcoinplusplus.actions.delay(180000).then(()=>{
// showMessage(`INFO: Balance syncing is complete.`); // showMessage(`INFO: Balance syncing is complete.`);
localbitcoinplusplus.amIreadyToServePrimaryUsers = true; localbitcoinplusplus.services[`can_serve_${su_db_data[`trader_flo_address`]}`] = true;
//}); //});
} }
@ -19386,7 +19385,7 @@
// await localbitcoinplusplus.actions.delay(180000).then(()=>{ // await localbitcoinplusplus.actions.delay(180000).then(()=>{
// showMessage(`INFO: Balance syncing is complete.`); // showMessage(`INFO: Balance syncing is complete.`);
localbitcoinplusplus.amIreadyToServePrimaryUsers = true; localbitcoinplusplus.services[`can_serve_${su_db_data.trader_flo_address}`] = true;
//}); //});
} }
@ -19502,7 +19501,7 @@
for (var i = 0; i < mismatched_fields.length; i++) { for (var i = 0; i < mismatched_fields.length; i++) {
const mf = mismatched_fields[i]; const mf = mismatched_fields[i];
const res_data_obj = await _readAllDB(mf) const res_data_obj = await _readAllDB(mf);
let filtered_data = res_data_obj.filter(odho=>{ let filtered_data = res_data_obj.filter(odho=>{
if (typeof odho.timestamp=="number" if (typeof odho.timestamp=="number"
&& typeof response_object.higestTimestampList[`${mf}_TIME`] !=='undefined') { && typeof response_object.higestTimestampList[`${mf}_TIME`] !=='undefined') {
@ -20149,11 +20148,12 @@
try { try {
if(typeof Obj.vectorClock == "undefined") { if(typeof Obj.vectorClock == "undefined") {
Obj.vectorClock = 0; Obj.vectorClock = 0;
Obj.timestamp = + new Date();
} else if(increaseVectorClock === false) { } else if(increaseVectorClock === false) {
// leave the vector clock field unchanged // leave the vector clock field unchanged
} else { } else {
Obj.vectorClock += 1; Obj.vectorClock += 1;
}
if (typeof Obj.timestamp !== "number") {
Obj.timestamp = + new Date(); Obj.timestamp = + new Date();
} }
var request = db.transaction([tablename], "readwrite") var request = db.transaction([tablename], "readwrite")
@ -20498,11 +20498,12 @@
try { try {
if(typeof Obj.vectorClock == "undefined") { if(typeof Obj.vectorClock == "undefined") {
Obj.vectorClock = 0; Obj.vectorClock = 0;
Obj.timestamp = + new Date();
} else if(increaseVectorClock === false) { } else if(increaseVectorClock === false) {
// leave the vector clock field unchanged // leave the vector clock field unchanged
} else { } else {
Obj.vectorClock += 1; Obj.vectorClock += 1;
}
if (typeof Obj.timestamp !== "number") {
Obj.timestamp = + new Date(); Obj.timestamp = + new Date();
} }
let that = this; let that = this;
@ -20863,10 +20864,7 @@
reactor.dispatchEvent('sync_primary_and_backup_db'); reactor.dispatchEvent('sync_primary_and_backup_db');
showMessage(`INFO: You need to update serve to true to start serving as Primary Supernode.`); showMessage(`INFO: You need to update serve to true to start serving as Primary Supernode.`);
} else { } else {
for (let w = 0; w <= localbitcoinplusplus.master_configurations.MaxBackups; w++) { localbitcoinplusplus.services[`can_serve_${localbitcoinplusplus.wallets.my_local_flo_address}`] = true;
const element = closestSuList[w];
localbitcoinplusplus.services[`can_serve_${element.trader_flo_address}`] = true;
}
} }
} }