RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change name to sync on networkmonitor

Browse Source
This commit is contained in:
eordano 2015-04-06 15:14:12 -03:00
parent abac6a9ed3
commit 13b4f41f80
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/networkmonitor.js
View File

@ -64,6 +64,11 @@ NetworkMonitor.prototype.setupPeer = function(peer) {
}; };
NetworkMonitor.prototype.requestBlocks = function(start) {
$.checkArgument(_.isString(start), 'start must be a block hash string');
this.peer.sendMessage(messages.GetBlocks([start]));
};
NetworkMonitor.prototype.start = function() { NetworkMonitor.prototype.start = function() {
this.peer.connect(); this.peer.connect();
}; };
@ -76,9 +81,4 @@ NetworkMonitor.prototype.abort = function(reason) {
throw reason; throw reason;
}; };
NetworkMonitor.prototype.syncFrom = function(start) {
$.checkArgument(_.isString(start), 'start must be a block hash string');
this.peer.sendMessage(messages.GetBlocks([start]));
};
module.exports = NetworkMonitor; module.exports = NetworkMonitor;

5
lib/node.js
View File

@ -28,6 +28,8 @@ var BitcoreNode = function(bus, networkMonitor, blockService, transactionService
this.bus = bus; this.bus = bus;
this.networkMonitor = networkMonitor; this.networkMonitor = networkMonitor;
this.tip = null;
this.addressService = addressService; this.addressService = addressService;
this.transactionService = transactionService; this.transactionService = transactionService;
this.blockService = blockService; this.blockService = blockService;
@ -95,7 +97,8 @@ BitcoreNode.prototype.sync = function() {
start = latest.hash; start = latest.hash;
} }
console.log('Starting sync from', start); console.log('Starting sync from', start);
self.networkMonitor.syncFrom(start); self.tip = latest;
self.networkMonitor.requestBlocks(start);
}) })
.catch(function(err) { .catch(function(err) {
self.networkMonitor.stop(); self.networkMonitor.stop();