zcash-hackworks
/
bitcore-node-zcash
mirror of https://github.com/zcash-hackworks/bitcore-node-zcash.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix unit tests for node.

This commit is contained in:
Braydon Fuller 2015-08-24 14:46:48 -04:00
parent d03d452981
commit f1642388af
2 changed files with 138 additions and 69 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
lib/node.js
View File

@ -92,7 +92,7 @@ Node.prototype._loadBitcoinConf = function(config) {
}
}
$.checkState((this.bitcoinConfiguration.txindex && this.bitcoinConfiguration.txindex == 1),
$.checkState((this.bitcoinConfiguration.txindex && this.bitcoinConfiguration.txindex == 1),
'Txindex option is required in order to use most of the features of bitcore-node. \
Please add "txindex=1" to your configuration and reindex an existing database if necessary with reindex=1');
};
@ -265,7 +265,7 @@ Node.prototype._syncBitcoind = function() {
log.debug('Chain added block to main chain');
self.chain.emit('addblock', block);
setImmediate(done);
});
});
});
} else {
@ -396,6 +396,22 @@ Node.prototype._initialize = function() {
// Chain References
this.chain.db = this.db;
// Initialize the event listeners
this._initializeBitcoind();
this._initializeChain();
this._initializeDatabase();
this.start(function(err) {
if(err) {
return self.emit('error', err);
}
self.emit('ready');
});
};
Node.prototype._initializeBitcoind = function() {
var self = this;
// Bitcoind
this.bitcoind.on('ready', function(status) {
log.info('Bitcoin Daemon Ready');
@ -406,7 +422,6 @@ Node.prototype._initialize = function() {
// Get the genesis block
self.bitcoind.getBlock(0, function(err, block) {
self.chain.genesis = self.Block.fromBuffer(block);
self.db.initialize();
});
});
@ -430,18 +445,10 @@ Node.prototype._initialize = function() {
self.emit('error', err);
});
// Chain
this.chain.on('ready', function() {
log.info('Bitcoin Chain Ready');
self._syncBitcoind();
});
};
this.chain.on('error', function(err) {
Error.captureStackTrace(err);
self.emit('error', err);
});
// Database
Node.prototype._initializeDatabase = function() {
var self = this;
this.db.on('ready', function() {
log.info('Bitcoin Database Ready');
});
@ -450,13 +457,18 @@ Node.prototype._initialize = function() {
Error.captureStackTrace(err);
self.emit('error', err);
});
};
this.start(function(err) {
if(err) {
return self.emit('error', err);
}
Node.prototype._initializeChain = function() {
var self = this;
this.chain.on('ready', function() {
log.info('Bitcoin Chain Ready');
self._syncBitcoind();
});
self.emit('ready');
this.chain.on('error', function(err) {
Error.captureStackTrace(err);
self.emit('error', err);
});
};

157
test/node.unit.js
View File

@ -459,22 +459,65 @@ describe('Bitcoind Node', function() {
});
describe('#_initialize', function() {
var node = new Node({});
node.chain = {
on: sinon.spy()
};
node.Block = 'Block';
node.bitcoind = {
on: sinon.spy()
};
node.db = {
on: sinon.spy()
};
it('will call db.initialize() on ready event', function(done) {
var node;
before(function() {
node = new Node({});
node.chain = {
on: sinon.spy()
};
node.Block = 'Block';
node.bitcoind = {
on: sinon.spy()
};
node._initializeBitcoind = sinon.spy();
node._initializeDatabase = sinon.spy();
node._initializeChain = sinon.spy();
node.db = {
on: sinon.spy()
};
});
it('should initialize', function(done) {
node.once('ready', function() {
done();
});
node.start = sinon.stub().callsArg(0);
node._initialize();
// references
node.db.chain.should.equal(node.chain);
node.db.Block.should.equal(node.Block);
node.db.bitcoind.should.equal(node.bitcoind);
node.chain.db.should.equal(node.db);
node.chain.db.should.equal(node.db);
// event handlers
node._initializeBitcoind.callCount.should.equal(1);
node._initializeDatabase.callCount.should.equal(1);
node._initializeChain.callCount.should.equal(1);
});
it('should emit an error if an error occurred starting services', function(done) {
node.once('error', function(err) {
should.exist(err);
err.message.should.equal('error');
done();
});
node.start = sinon.stub().callsArgWith(0, new Error('error'));
node._initialize();
});
});
describe('#_initalizeBitcoind', function() {
it('set the genesis block when ready and set height', function(done) {
var genesisBuffer = new Buffer('0100000043497fd7f826957108f4a30fd9cec3aeba79972084e90ead01ea330900000000bac8b0fa927c0ac8234287e33c5f74d38d354820e24756ad709d7038fc5f31f020e7494dffff001d03e4b6720101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0e0420e7494d017f062f503253482fffffffff0100f2052a010000002321021aeaf2f8638a129a3156fbe7e5ef635226b0bafd495ff03afe2c843d7e3a4b51ac00000000', 'hex');
var node = new Node({});
node.Block = Block;
node.chain = {};
@ -489,7 +532,6 @@ describe('Bitcoind Node', function() {
setImmediate(function() {
chainlib.log.info.callCount.should.equal(1);
chainlib.log.info.restore();
node.db.initialize.callCount.should.equal(1);
node.bitcoindHeight.should.equal(10);
done();
});
@ -508,22 +550,45 @@ describe('Bitcoind Node', function() {
node._initializeBitcoind();
node.bitcoind.emit('error', new Error('test error'));
});
it('will call sync when there is a new tip', function(done) {
var node = new Node({});
node.bitcoind = new EventEmitter();
node.bitcoind.syncPercentage = sinon.spy();
node._syncBitcoind = function() {
node.bitcoind.syncPercentage.callCount.should.equal(1);
node.bitcoindHeight.should.equal(10);
done();
};
node._initializeBitcoind();
node.bitcoind.emit('tip', 10);
});
it('will not call sync when there is a new tip and shutting down', function(done) {
var node = new Node({});
node.bitcoind = new EventEmitter();
node._syncBitcoind = sinon.spy();
node.bitcoind.syncPercentage = sinon.spy();
node.stopping = true;
node.bitcoind.on('tip', function() {
setImmediate(function() {
node.bitcoind.syncPercentage.callCount.should.equal(0);
node._syncBitcoind.callCount.should.equal(0);
done();
});
});
node._initializeBitcoind();
node.bitcoind.emit('tip', 10);
});
});
it('will call chain.initialize() on ready event', function(done) {
describe('#_initializeDatabase', function() {
it('will log on ready event', function(done) {
var node = new Node({});
node.db = new EventEmitter();
node.db.addModule = sinon.spy();
var module = {};
node.db._modules = [module];
node.chain = {
initialize: sinon.spy()
};
sinon.stub(chainlib.log, 'info');
node.db.on('ready', function() {
setImmediate(function() {
chainlib.log.info.callCount.should.equal(1);
chainlib.log.info.restore();
node.chain.initialize.callCount.should.equal(1);
done();
});
});
@ -541,41 +606,33 @@ describe('Bitcoind Node', function() {
node._initializeDatabase();
node.db.emit('error', new Error('test error'));
});
});
it('should initialize', function(done) {
node.once('ready', function() {
done();
describe('#_initializeChain', function() {
it('will call _syncBitcoind on ready', function(done) {
var node = new Node({});
node._syncBitcoind = sinon.spy();
node.chain = new EventEmitter();
node.chain.on('ready', function(err) {
setImmediate(function() {
node._syncBitcoind.callCount.should.equal(1);
done();
});
});
node.start = sinon.stub().callsArg(0);
node._initialize();
// references
node.db.chain.should.equal(node.chain);
node.db.Block.should.equal(node.Block);
node.db.bitcoind.should.equal(node.bitcoind);
node.chain.db.should.equal(node.db);
node.chain.db.should.equal(node.db);
// start syncing
node.setSyncStrategy = sinon.spy();
node._initializeChain();
node.chain.emit('ready');
});
it('should emit an error if an error occurred starting services', function(done) {
node.once('error', function(err) {
it('will emit an error from the chain', function(done) {
var node = new Node({});
node.chain = new EventEmitter();
node.on('error', function(err) {
should.exist(err);
err.message.should.equal('error');
err.message.should.equal('test error');
done();
});
node.start = sinon.stub().callsArgWith(0, new Error('error'));
node._initialize();
node._initializeChain();
node.chain.emit('error', new Error('test error'));
});
});
describe('#getServiceOrder', function() {