test BitcoreNode

index.js

@@ -1,49 +1,8 @@
 'use strict';
 
-
 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;
-
-  this.bus.register(bitcore.Transaction, function(tx) {
-    var tout = Unit.fromSatoshis(tx.outputAmount).toBTC();
-    console.log('Transaction:', tx.id, 'total_out:', tout, 'BTC');
-  });
-
-  this.bus.register(bitcore.Block, function(block) {
-    console.log('Block:', block.id);
-  });
-
-  this.bus.onAny(function(value) {
-    self.emit(this.event, value);
-  });
-  this.nm.on('error', function(err) {
-    self.emit('error', err);
-  });
-};
-util.inherits(BitcoreNode, EventEmitter);
-
-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();
-};
 
+var BitcoreNode = require('./lib/node.js');
 
 if (require.main === module) {
   var node = BitcoreNode.create(config.get('BitcoreNode'));

lib/node.js

@@ -0,0 +1,50 @@
+'use strict';
+
+var util = require('util');
+var EventEmitter = require('eventemitter2').EventEmitter2;
+
+var bitcore = require('bitcore');
+var Unit = bitcore.Unit;
+var $ = bitcore.util.preconditions;
+
+var NetworkMonitor = require('./networkmonitor');
+var EventBus = require('./eventbus');
+
+var BitcoreNode = function(bus, nm) {
+  $.checkArgument(bus);
+  $.checkArgument(nm);
+  var self = this;
+  this.bus = bus;
+  this.nm = nm;
+
+  this.bus.register(bitcore.Transaction, function(tx) {
+    var tout = Unit.fromSatoshis(tx.outputAmount).toBTC();
+    console.log('Transaction:', tx.id);
+    console.log('\ttotal_out:', tout, 'BTC');
+  });
+
+  this.bus.register(bitcore.Block, function(block) {
+    console.log('Block:', block.id);
+  });
+
+  this.bus.onAny(function(value) {
+    self.emit(this.event, value);
+  });
+  this.nm.on('error', function(err) {
+    self.emit('error', err);
+  });
+};
+util.inherits(BitcoreNode, EventEmitter);
+
+BitcoreNode.create = function(opts) {
+  opts = opts || {};
+  var bus = new EventBus();
+  var nm = NetworkMonitor.create(bus, opts.NetworkMonitor);
+  return new BitcoreNode(bus, nm);
+};
+
+BitcoreNode.prototype.start = function() {
+  this.nm.start();
+};
+
+module.exports = BitcoreNode;

test/networkmonitor.js

@@ -65,6 +65,13 @@ describe('NetworkMonitor', function() {
     nm.start.bind(nm).should.not.throw();
   });
 
+  it('broadcasts errors in underlying peer', function(cb) {
+    var nm = new NetworkMonitor(busMock, peerMock);
+    nm.on('error', cb);
+    nm.start();
+    peerMock.emit('error');
+  });
+
   it('broadcasts ready after start', function(cb) {
     var nm = new NetworkMonitor(busMock, peerMock);
     nm.on('ready', cb);

test/node.js

@@ -0,0 +1,49 @@
+'use strict';
+
+var chai = require('chai');
+var should = chai.should();
+var sinon = require('sinon');
+
+var Promise = require('bluebird');
+var EventEmitter = require('eventemitter2').EventEmitter2;
+var BitcoreNode = require('../lib/node');
+var EventBus = require('../lib/eventbus');
+Promise.longStackTraces();
+
+describe('BitcoreNode', function() {
+
+  // mocks
+  var busMock, nmMock;
+  beforeEach(function() {
+    busMock = new EventBus();
+    nmMock = new EventEmitter();
+    nmMock.start = function() {};
+  });
+  describe('instantiates', function() {
+    it('from constructor', function() {
+      var node = new BitcoreNode(busMock, nmMock);
+      should.exist(node);
+    });
+
+    it('from create', function() {
+      var node = BitcoreNode.create();
+      should.exist(node);
+    });
+  });
+
+  it('starts', function() {
+    var node = new BitcoreNode(busMock, nmMock);
+    node.start.bind(node).should.not.throw();
+  });
+
+  it('broadcasts errors from network monitor', function(cb) {
+    var node = new BitcoreNode(busMock, nmMock);
+    node.on('error', cb);
+    nmMock.emit('error');
+  });
+  it('exposes all events from the event bus', function(cb) {
+    var node = new BitcoreNode(busMock, nmMock);
+    node.on('foo', cb);
+    busMock.emit('foo');
+  });
+});