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

Drop duplicated code on addressService

Browse Source
This commit is contained in:
eordano 2015-03-20 13:19:40 -03:00
parent a2a6f03c50
commit 61f99d94b5
1 changed files with 26 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
lib/services/address.js
View File

@ -53,41 +53,37 @@ AddressService.processOutput = function(data) {
return output;
};
AddressService.prototype.getAllOutputs = function(address) {
var results = [];
var self = this;
var retrieveOutputs = function(indexFunction, processElement) {
return function(address) {
var results = [];
var self = this;
return new Promise(function(resolve, reject) {
self.database.createReadStream({
gte: TransactionService.Index.getOutputsForAddress(address, NULLTXHASH, 0),
lte: TransactionService.Index.getOutputsForAddress(address, LASTTXHASH, MAXOUTPUT)
}).on('data', function(element) {
results.push(AddressService.processOutput(element));
}).on('error', function() {
return reject();
}).on('end', function() {
return resolve(results);
return new Promise(function(resolve, reject) {
self.database.createReadStream({
gte: indexFunction(address, NULLTXHASH, 0),
lte: indexFunction(address, LASTTXHASH, MAXOUTPUT)
}).on('data', function(element) {
results.push(processElement(element));
}).on('error', reject).on('end', function() {
return resolve(results);
});
});
});
};
};
AddressService.prototype.getSpent = function(address) {
var results = [];
var self = this;
AddressService.prototype.getAllOutputs = retrieveOutputs(
TransactionService.Index.getOutputsForAddress,
function(e) {
return AddressService.processOutput(e);
}
);
return new Promise(function(resolve, reject) {
self.database.createReadStream({
gte: TransactionService.Index.getSpentOutputsForAddress(address, NULLTXHASH, 0),
lte: TransactionService.Index.getSpentOutputsForAddress(address, LASTTXHASH, MAXOUTPUT)
}).on('data', function(element) {
results.push(JSON.parse(element.value));
}).on('error', function(err) {
return reject(err);
}).on('end', function() {
return resolve(results);
});
});
};
AddressService.prototype.getSpent = retrieveOutputs(
TransactionService.Index.getSpentOutputsForAddress,
function(element) {
return JSON.parse(element.value);
}
);
AddressService.prototype.buildAddressSummary = function(address, tip, allOutputs, spent, confirmations) {