Merge pull request #1143 from eordano/feature/randomizeouts
Add functionality to randomize outputs
This commit is contained in:
commit
9ffe2def46
@ -63,6 +63,9 @@ module.exports = [{
|
|||||||
}, {
|
}, {
|
||||||
name: 'NeedMoreInfo',
|
name: 'NeedMoreInfo',
|
||||||
message: '{0}'
|
message: '{0}'
|
||||||
|
}, {
|
||||||
|
name: 'InvalidSorting',
|
||||||
|
message: 'The sorting function provided did not return the change output as one of the array elements'
|
||||||
}, {
|
}, {
|
||||||
name: 'InvalidOutputAmountSum',
|
name: 'InvalidOutputAmountSum',
|
||||||
message: '{0}'
|
message: '{0}'
|
||||||
|
|||||||
@ -805,6 +805,44 @@ Transaction.prototype.removeOutput = function(index) {
|
|||||||
this._updateChangeOutput();
|
this._updateChangeOutput();
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Randomize this transaction's outputs ordering. The shuffling algorithm is a
|
||||||
|
* version of the Fisher-Yates shuffle, provided by lodash's _.shuffle().
|
||||||
|
*
|
||||||
|
* @return {Transaction} this
|
||||||
|
*/
|
||||||
|
Transaction.prototype.shuffleOutputs = function() {
|
||||||
|
return this.sortOutputs(_.shuffle);
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sort this transaction's outputs, according to a given sorting function that
|
||||||
|
* takes an array as argument and returns a new array, with the same elements
|
||||||
|
* but with a different order. The argument function MUST NOT modify the order
|
||||||
|
* of the original array
|
||||||
|
*
|
||||||
|
* @param {Function} sortingFunction
|
||||||
|
* @return {Transaction} this
|
||||||
|
*/
|
||||||
|
Transaction.prototype.sortOutputs = function(sortingFunction) {
|
||||||
|
var outs = sortingFunction(this.outputs);
|
||||||
|
return this._newOutputOrder(outs);
|
||||||
|
};
|
||||||
|
|
||||||
|
Transaction.prototype._newOutputOrder = function(newOutputs) {
|
||||||
|
var changeIndex = 0;
|
||||||
|
var length = this.outputs.length;
|
||||||
|
while (changeIndex < length && this.outputs[this._changeIndex] !== newOutputs[changeIndex]) {
|
||||||
|
changeIndex++;
|
||||||
|
}
|
||||||
|
if (changeIndex === length) {
|
||||||
|
throw new errors.Transaction.InvalidSorting();
|
||||||
|
}
|
||||||
|
this.outputs = newOutputs;
|
||||||
|
this._changeIndex = changeIndex;
|
||||||
|
return this;
|
||||||
|
};
|
||||||
|
|
||||||
Transaction.prototype.removeInput = function(txId, outputIndex) {
|
Transaction.prototype.removeInput = function(txId, outputIndex) {
|
||||||
var index;
|
var index;
|
||||||
if (!outputIndex && _.isNumber(txId)) {
|
if (!outputIndex && _.isNumber(txId)) {
|
||||||
|
|||||||
@ -91,7 +91,8 @@
|
|||||||
"bitcore-build": "bitpay/bitcore-build",
|
"bitcore-build": "bitpay/bitcore-build",
|
||||||
"brfs": "^1.2.0",
|
"brfs": "^1.2.0",
|
||||||
"chai": "^1.10.0",
|
"chai": "^1.10.0",
|
||||||
"gulp": "^3.8.10"
|
"gulp": "^3.8.10",
|
||||||
|
"sinon": "^1.13.0"
|
||||||
},
|
},
|
||||||
"license": "MIT"
|
"license": "MIT"
|
||||||
}
|
}
|
||||||
|
|||||||
@ -5,6 +5,7 @@
|
|||||||
var should = require('chai').should();
|
var should = require('chai').should();
|
||||||
var expect = require('chai').expect;
|
var expect = require('chai').expect;
|
||||||
var _ = require('lodash');
|
var _ = require('lodash');
|
||||||
|
var sinon = require('sinon');
|
||||||
|
|
||||||
var bitcore = require('../..');
|
var bitcore = require('../..');
|
||||||
var Transaction = bitcore.Transaction;
|
var Transaction = bitcore.Transaction;
|
||||||
@ -619,6 +620,62 @@ describe('Transaction', function() {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
describe('output ordering', function() {
|
||||||
|
|
||||||
|
var tenth = 1e7;
|
||||||
|
var fourth = 25e6;
|
||||||
|
var half = 5e7;
|
||||||
|
var transaction, out1, out2, out3, out4;
|
||||||
|
|
||||||
|
beforeEach(function() {
|
||||||
|
transaction = new Transaction()
|
||||||
|
.from(simpleUtxoWith1BTC)
|
||||||
|
.to(toAddress, tenth)
|
||||||
|
.to(toAddress, fourth)
|
||||||
|
.to(toAddress, half)
|
||||||
|
.change(changeAddress);
|
||||||
|
out1 = transaction.outputs[0];
|
||||||
|
out2 = transaction.outputs[1];
|
||||||
|
out3 = transaction.outputs[2];
|
||||||
|
out4 = transaction.outputs[3];
|
||||||
|
});
|
||||||
|
|
||||||
|
it('allows the user to sort outputs according to a criteria', function() {
|
||||||
|
var sorting = function(array) {
|
||||||
|
return [array[3], array[2], array[1], array[0]];
|
||||||
|
};
|
||||||
|
transaction.sortOutputs(sorting);
|
||||||
|
transaction.outputs[0].should.equal(out4);
|
||||||
|
transaction.outputs[1].should.equal(out3);
|
||||||
|
transaction.outputs[2].should.equal(out2);
|
||||||
|
transaction.outputs[3].should.equal(out1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('allows the user to randomize the output order', function() {
|
||||||
|
var shuffle = sinon.stub(_, 'shuffle');
|
||||||
|
shuffle.onFirstCall().returns([out2, out1, out4, out3]);
|
||||||
|
|
||||||
|
transaction._changeIndex.should.equal(3);
|
||||||
|
transaction.shuffleOutputs();
|
||||||
|
transaction.outputs[0].should.equal(out2);
|
||||||
|
transaction.outputs[1].should.equal(out1);
|
||||||
|
transaction.outputs[2].should.equal(out4);
|
||||||
|
transaction.outputs[3].should.equal(out3);
|
||||||
|
transaction._changeIndex.should.equal(2);
|
||||||
|
|
||||||
|
_.shuffle.restore();
|
||||||
|
});
|
||||||
|
|
||||||
|
it('fails if the provided function does not work as expected', function() {
|
||||||
|
var sorting = function(array) {
|
||||||
|
return [];
|
||||||
|
};
|
||||||
|
expect(function() {
|
||||||
|
transaction.sortOutputs(sorting);
|
||||||
|
}).to.throw(errors.Transaction.InvalidSorting);
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
var tx_empty_hex = '01000000000000000000';
|
var tx_empty_hex = '01000000000000000000';
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user