139 lines
3.9 KiB
JavaScript
Executable File
139 lines
3.9 KiB
JavaScript
Executable File
// In renderer process (web page).
|
|
const {
|
|
ipcRenderer
|
|
} = require("electron");
|
|
var web3;
|
|
|
|
// Set the provider you want from Web3.providers
|
|
SyncProgress = new ProgressBar.Line("#syncProgress", {
|
|
strokeWidth: 6,
|
|
easing: "easeInOut",
|
|
duration: 1400,
|
|
color: "#7A1336",
|
|
trailColor: "#eee",
|
|
trailWidth: 1,
|
|
text: {
|
|
style: {
|
|
color: "#bbb",
|
|
position: "absolute",
|
|
left: "50%",
|
|
top: "-1px",
|
|
transform: "translateX(-50%)",
|
|
fontSize: "0.9em",
|
|
LineHeight: "24px",
|
|
padding: 0
|
|
},
|
|
autoStyleContainer: false
|
|
},
|
|
from: {
|
|
color: "#FFEA82"
|
|
},
|
|
to: {
|
|
color: "#ED6A5A"
|
|
}
|
|
});
|
|
|
|
// set initial value for the progress text
|
|
SyncProgress.setText("Waiting for blockchain, please wait...");
|
|
isFullySynced = false;
|
|
|
|
var peerCountInterval = setInterval(function() {
|
|
web3Local.eth.net.getPeerCount(function(error, count) {
|
|
$("#peerCount").html(vsprintf("Peer Count: %d", [count]));
|
|
});
|
|
}, 5000);
|
|
|
|
function StartSyncProcess() {
|
|
var alreadyCatchedUp = false;
|
|
var nodeSyncInterval = null;
|
|
|
|
var subscription = web3Local.eth.subscribe("syncing", function(error, sync) {
|
|
if (!error) {
|
|
if (!sync) {
|
|
if (nodeSyncInterval) {
|
|
clearInterval(nodeSyncInterval);
|
|
}
|
|
|
|
nodeSyncInterval = setInterval(function() {
|
|
web3Local.eth.getBlock("latest", function(error, localBlock) {
|
|
if (!error) {
|
|
if (localBlock.number > 0) {
|
|
if (!EthoTransactions.getIsSyncing()) {
|
|
SyncProgress.animate(1);
|
|
SyncProgress.setText(vsprintf("%d/%d (100%%)", [localBlock.number, localBlock.number]));
|
|
}
|
|
|
|
if (alreadyCatchedUp == false) {
|
|
// clear the repeat interval and render wallets
|
|
$(document).trigger("onNewAccountTransaction");
|
|
alreadyCatchedUp = true;
|
|
isFullySynced = true;
|
|
|
|
// enable the keep in sync feature
|
|
EthoTransactions.enableKeepInSync();
|
|
// sync all the transactions to the current block
|
|
EthoTransactions.syncTransactionsForAllAddresses(localBlock.number);
|
|
|
|
// signal that the sync is complete
|
|
$(document).trigger("onSyncComplete");
|
|
}
|
|
}
|
|
} else {
|
|
EthoMainGUI.showGeneralError(error);
|
|
}
|
|
});
|
|
}, 10000);
|
|
}
|
|
} else {
|
|
EthoMainGUI.showGeneralError(error);
|
|
}
|
|
}).on("data", function(sync) {
|
|
if (sync && sync.HighestBlock > 0) {
|
|
SyncProgress.animate(sync.CurrentBlock / sync.HighestBlock);
|
|
SyncProgress.setText(vsprintf("%d/%d (%d%%)", [
|
|
sync.CurrentBlock,
|
|
sync.HighestBlock,
|
|
Math.floor(sync.CurrentBlock / sync.HighestBlock * 100)
|
|
]));
|
|
}
|
|
}).on("changed", function(isSyncing) {
|
|
if (isSyncing) {
|
|
|
|
nodeSyncInterval = setInterval(function() {
|
|
web3Local.eth.isSyncing(function(error, sync) {
|
|
if (!error && sync) {
|
|
SyncProgress.animate(sync.currentBlock / sync.highestBlock);
|
|
SyncProgress.setText(vsprintf("%d/%d (%d%%)", [
|
|
sync.currentBlock,
|
|
sync.highestBlock,
|
|
Math.floor(sync.currentBlock / sync.highestBlock * 100)
|
|
]));
|
|
} else if (error) {
|
|
EthoMainGUI.showGeneralError(error);
|
|
}
|
|
});
|
|
}, 2000);
|
|
} else {
|
|
if (nodeSyncInterval) {
|
|
clearInterval(nodeSyncInterval);
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
var InitWeb3 = setInterval(function() {
|
|
try {
|
|
web3Local = new Web3(new Web3.providers.WebsocketProvider("ws://localhost:8546"));
|
|
|
|
web3Local.eth.net.isListening(function(error, success) {
|
|
if (!error) {
|
|
$(document).trigger("onGethReady");
|
|
clearInterval(InitWeb3);
|
|
StartSyncProcess();
|
|
}
|
|
});
|
|
} catch (err) {
|
|
EthoMainGUI.showGeneralError(err);
|
|
}
|
|
}, 2000);
|