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

Fixed tests.

Browse Source
This commit is contained in:
Chris Kleeschulte 2017-11-05 07:57:27 -05:00
parent 00a5ea65b4
commit d55986be57
No known key found for this signature in database
GPG Key ID: 33195D27EF6BDB7F
3 changed files with 22 additions and 51 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/services/address/index.js
View File

@ -86,7 +86,7 @@ AddressService.prototype.getAddressHistory = function(addresses, options, callba
txList = utils.orderByConfirmations(txList); txList = utils.orderByConfirmations(txList);
var results = { var results = {
totalCount: options.txiIdList.length || 0, totalCount: options.txIdList.length || 0,
items: txList items: txList
}; };
@ -523,7 +523,7 @@ AddressService.prototype._getAddressTxidHistory = function(address, options, cal
}); });
txIdTransformStream.on('end', function() { txIdTransformStream.on('end', function() {
next(null, options.txIdList); next();
}); });
txIdTransformStream._transform = function(chunk, enc, callback) { txIdTransformStream._transform = function(chunk, enc, callback) {

6
lib/services/mempool/index.js
View File

@ -195,8 +195,7 @@ MempoolService.prototype._getAddressOperations = function(tx, reverse) {
ops.push({ ops.push({
type: action, type: action,
key: this._encoding.encodeMempoolAddressKey(address, tx.txid(), i, 0), key: this._encoding.encodeMempoolAddressKey(address, tx.txid(), i, 0)
value: this._encoding.encodeMempoolAddressValue(tx)
}); });
} }
@ -210,8 +209,7 @@ MempoolService.prototype._getAddressOperations = function(tx, reverse) {
ops.push({ ops.push({
type: action, type: action,
key: this._encoding.encodeMempoolAddressKey(address, tx.txid(), i, 1), key: this._encoding.encodeMempoolAddressKey(address, tx.txid(), i, 1)
value: this._encoding.encodeMempoolAddressValue(tx)
}); });
} }

63
test/services/address/index.unit.js
View File

@ -56,7 +56,9 @@ describe('Address Service', function() {
it('should get the address history', function(done) { it('should get the address history', function(done) {
sandbox.stub(addressService, '_getAddressHistory').callsArgWith(2, null, null); sandbox.stub(addressService, '_getAddressTxidHistory').callsArgWith(2, null, null);
sandbox.stub(addressService, '_getAddressTxHistory').callsArgWith(1, null, []);
addressService.getAddressHistory(['a', 'b', 'c'], { from: 12, to: 14 }, function(err, res) { addressService.getAddressHistory(['a', 'b', 'c'], { from: 12, to: 14 }, function(err, res) {
if (err) { if (err) {
@ -74,58 +76,29 @@ describe('Address Service', function() {
}); });
describe('#_getAddressHistory', function() { describe('#_getAddressTxidHistory', function() {
it('should get the address history', function(done) { it('should get the address txid history', function(done) {
var encoding = new Encoding(new Buffer('0001', 'hex'));
addressService._encoding = encoding;
var getHeaderHash = sandbox.stub().callsArgWith(1, null, 'aa');
var getBlockHeader = sandbox.stub().callsArgWith(1, null, 'aa');
var getTxsByAddress = sandbox.stub().callsArgWith(2, null, []);
var getTransaction = sandbox.stub().callsArgWith(2, null, { __height: 123, outputs: [ { value: 1 } ], __inputValues: [ 1 ] });
addressService._transaction = { getTransaction: getTransaction };
addressService._mempool = { getTxsByAddress: getTxsByAddress };
addressService._header = {
getHeaderHash: getHeaderHash,
getBlockHeader: getBlockHeader
};
var address = 'a';
var opts = { from: 0, to: 10 };
var txid = '1c6ea4a55a3edaac0a05e93b52908f607376a8fdc5387c492042f8baa6c05085';
var data = [ null, encoding.encodeAddressIndexKey(address, 123, txid, 1, 1) ];
addressService._mempool = { getTxidsByAddress: sinon.stub().callsArgWith(2, null, []) };
var txidStream = new Readable(); var txidStream = new Readable();
sandbox.stub(addressService, '_getTxidStream').returns(txidStream);
var addressInfoBuf = addressService._encoding.encodeAddressIndexKey('a', 10, tx.txid(), 1, 1, 1234567);
var options = {txIdList: []};
txidStream._read = function() { addressService._getAddressTxidHistory('a', options, function(err) {
txidStream.push(data.pop());
};
var createReadStream = sandbox.stub().returns(txidStream);
addressService._db = { createKeyStream: createReadStream };
addressService._getAddressHistory(address, opts, function(err, res) {
if (err) { if (err) {
return done(err); return done(err);
} }
expect(getTxsByAddress.calledOnce).to.be.true;
expect(getTransaction.calledOnce).to.be.true; expect(options.txIdList).to.deep.equal([{txid: tx.txid(), height: 10}]);
expect(res).to.deep.equal([
{
__height: 123,
__inputValues: [
1
],
outputs: [
{
value: 1
}
]
}
]);
done(); done();
}); });
txidStream.push(addressInfoBuf);
txidStream.push(null);
}); });
}); });
@ -181,7 +154,7 @@ describe('Address Service', function() {
var txidStream = new EventEmitter(); var txidStream = new EventEmitter();
addressService._mempool = { getTxsByAddress: sinon.stub().callsArgWith(2, null, []) }; addressService._mempool = { getTxidsByAddress: sinon.stub().callsArgWith(2, null, []) };
var createReadStream = sandbox.stub().returns(txidStream); var createReadStream = sandbox.stub().returns(txidStream);
addressService._db = { createReadStream: createReadStream }; addressService._db = { createReadStream: createReadStream };