first prototype architecture

config/default.yml

@@ -1,6 +1,6 @@
 BitcoreNode:
+  network: testnet
   NetworkMonitor:
-    network: livenet
     host: localhost
     port: 8333
 Reporter: simple # none, simple, matrix

index.js

@@ -2,9 +2,11 @@
 
 var BitcoreNode = require('./lib/node');
 var reporters = require('./lib/reporters');
+var bitcore = require('bitcore');
 
 if (require.main === module) {
   var config = require('config');
+  bitcore.Networks.defaultNetwork = bitcore.Networks.get(config.network);
   var node = BitcoreNode.create(config.get('BitcoreNode'));
   node.start();
   node.on('error', function(err) {

lib/networkmonitor.js

@@ -21,10 +21,9 @@ util.inherits(NetworkMonitor, EventEmitter);
 
 NetworkMonitor.create = function(eventBus, opts) {
   opts = opts || {};
-  var network = Networks.get(opts.network) || Networks.defaultNetwork;
   var host = opts.host || 'localhost';
   var port = opts.port || Networks.defaultNetwork.port;
-  var peer = new Peer(host, port, network);
+  var peer = new Peer(host, port, Networks.defaultNetwork);
   return new NetworkMonitor(eventBus, peer);
 };
 
@@ -47,12 +46,21 @@ NetworkMonitor.prototype.setupPeer = function(peer) {
   peer.on('error', function(err) {
     self.emit('error', err);
   });
+  peer.on('disconnect', function() {
+    self.emit('disconnect');
+  });
 
 };
 
 NetworkMonitor.prototype.start = function() {
   this.peer.connect();
 };
+NetworkMonitor.prototype.stop = function() {
+  this.peer.disconnect();
+};
 
+NetworkMonitor.prototype.syncFrom = function(start) {
+  this.peer.sendMessage(messages.GetBlocks([start]));
+};
 
 module.exports = NetworkMonitor;

lib/node.js

@@ -4,10 +4,13 @@ var util = require('util');
 var EventEmitter = require('eventemitter2').EventEmitter2;
 
 var bitcore = require('bitcore');
+var p2p = require('bitcore-p2p');
+var messages = new p2p.Messages();
 var $ = bitcore.util.preconditions;
 
 var NetworkMonitor = require('./networkmonitor');
 var EventBus = require('./eventbus');
+var BlockService = require('./services/block.js');
 
 var BitcoreNode = function(bus, nm) {
   $.checkArgument(bus);
@@ -16,12 +19,20 @@ var BitcoreNode = function(bus, nm) {
   this.bus = bus;
   this.nm = nm;
 
+  this.bs = new BlockService();
+
+  this.bus.register(bitcore.Block, this.bs.onBlock.bind(this.bs));
+
   this.bus.onAny(function(value) {
     self.emit(this.event, value);
   });
   this.nm.on('error', function(err) {
     self.emit('error', err);
   });
+  this.nm.on('disconnect', function() {
+    console.log('network monitor disconnected');
+  });
+
 };
 util.inherits(BitcoreNode, EventEmitter);
 
@@ -33,7 +44,31 @@ BitcoreNode.create = function(opts) {
 };
 
 BitcoreNode.prototype.start = function() {
+  this.sync();
   this.nm.start();
 };
 
+BitcoreNode.prototype.sync = function() {
+  var genesis = bitcore.Networks.defaultNetwork.genesis;
+  console.log(bitcore.Networks.defaultNetwork.name);
+  console.log(genesis);
+  var self = this;
+  this.nm.on('ready', function() {
+    console.log('ready');
+    self.bs.getLatest().then(function(latest) {
+        var start = genesis;
+        if (latest) {
+          start = latest.rawHash;
+        }
+        console.log('Starting sync from', start);
+        self.nm.syncFrom(start);
+      })
+      .catch(function(err) {
+        self.nm.disconnect();
+        throw err;
+      });
+  });
+};
+
+
 module.exports = BitcoreNode;

lib/services/block.js

@@ -214,6 +214,15 @@ BlockService.prototype.getLatest = function() {
   });
 };
 
+/**
+ * Handle a block from the network
+ *
+ * @param {bitcore.Block} block
+ * @return a list of events back to the event bus
+ */
+BlockService.prototype.onBlock = function(block) {
+  console.log('block', block);
+};
 
 /**
  * Save a new block