add BitcoreNode model

config/default.yml

@@ -1,4 +1,5 @@
-NetworkMonitor:
+BitcoreNode:
-  network: livenet
+  NetworkMonitor:
-  host: localhost
+    network: livenet
-  port: 8333
+    host: localhost
+    port: 8333

index.js

@@ -2,25 +2,58 @@
 
 
 var config = require('config');
+var util = require('util');
+var EventEmitter = require('eventemitter2').EventEmitter2;
 
 var bitcore = require('bitcore');
+var Unit = bitcore.Unit;
 
 var NetworkMonitor = require('./lib/networkmonitor');
 var EventBus = require('./lib/eventbus');
 
+var BitcoreNode = function(bus, nm) {
+  var self = this;
+  this.bus = bus;
+  this.nm = nm;
 
-var bus = new EventBus();
+  this.bus.register(bitcore.Transaction, function(tx) {
-var nm = NetworkMonitor.create(bus, config.get('NetworkMonitor'));
+    console.log('Transaction:', tx.id, 'total_out:', Unit.fromSatoshis(tx.outputAmount).toBTC());
+  });
 
-bus.register(bitcore.Transaction, function(tx) {
+  this.bus.register(bitcore.Block, function(block) {
-  console.log('Transaction:', tx.id);
+    console.log('Block:', block.id);
-});
+  });
 
-bus.register(bitcore.Block, function(block) {
+  this.bus.onAny(function(value) {
-  console.log('Block:', block.id);
+    self.emit(this.event, value);
-});
+  });
+  this.nm.on('error', function(err) {
+    self.emit('error', err);
+  });
+};
+util.inherits(BitcoreNode, EventEmitter);
 
-nm.start();
+BitcoreNode.create = function(opts) {
+  var bus = new EventBus();
+  var nm = NetworkMonitor.create(bus, opts.NetworkMonitor);
+  return new BitcoreNode(bus, nm);
+};
+
+BitcoreNode.prototype.start = function() {
+  this.nm.start();
+};
 
 
+if (require.main === module) {
+  var node = BitcoreNode.create(config.get('BitcoreNode'));
+  node.start();
+  node.on('error', function(err) {
+    if (err.code === 'ECONNREFUSED') {
+      console.log('Connection to bitcoind failed');
+    } else {
+      console.log('Unrecognized error: ', err);
+    }
+  });
+}
 
+module.exports = BitcoreNode;

lib/eventbus.js

@@ -5,7 +5,7 @@ var bitcore = require('bitcore');
 var Promise = require('bluebird');
 var $ = bitcore.util.preconditions;
 var _ = bitcore.deps._;
-var EventEmitter = require('events').EventEmitter;
+var EventEmitter = require('eventemitter2').EventEmitter2;
 var util = require('util');
 
 function EventBus() {

lib/networkmonitor.js

@@ -1,7 +1,7 @@
 'use strict';
 
 var util = require('util');
-var EventEmitter = require('events').EventEmitter;
+var EventEmitter = require('eventemitter2').EventEmitter2;
 
 var bitcore = require('bitcore');
 var Networks = bitcore.Networks;
@@ -44,6 +44,10 @@ NetworkMonitor.prototype.setupPeer = function(peer) {
   peer.on('block', function(m) {
     self.bus.process(m.block);
   });
+  peer.on('error', function(err) {
+    self.emit('error', err);
+  });
+
 };
 
 NetworkMonitor.prototype.start = function() {

package.json

@@ -55,7 +55,8 @@
     "compression": "^1.4.1",
     "cors": "^2.5.3",
     "cron": "^1.0.4",
-    "express": "4.11.1",
+    "eventemitter2": "^0.4.14",
+    "express": "~3.4.7",
     "glob": "*",
     "js-yaml": "^3.2.7",
     "leveldown": "~0.10.0",

test/networkmonitor.js

@@ -8,7 +8,7 @@ var sinon = require('sinon');
 var util = require('util');
 var Transaction = bitcore.Transaction;
 var Block = bitcore.Block;
-var EventEmitter = require('events').EventEmitter;
+var EventEmitter = require('eventemitter2').EventEmitter2;
 
 var NetworkMonitor = require('../lib/networkmonitor');
 var EventBus = require('../lib/eventbus');
@@ -67,7 +67,7 @@ describe('NetworkMonitor', function() {
 
   it('broadcasts ready after start', function(cb) {
     var nm = new NetworkMonitor(busMock, peerMock);
-    nm.on('ready', cb)
+    nm.on('ready', cb);
     nm.start();
   });