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

fix scriptPubKey cache

Browse Source
This commit is contained in:
Matias Alejo Garcia 2016-02-22 15:15:20 -03:00
parent d1fb951aef
commit fe7c499d09
1 changed files with 51 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

97
lib/TransactionDb.js
View File

@ -1,6 +1,7 @@
'use strict';
var imports = require('soop').imports();
var _ = require('lodash');
@ -115,9 +116,9 @@ TransactionDb.prototype.fromTxId = function(txid, cb) {
// outs.
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var k = data.key.split('-');
var v = data.value.split(':');
@ -135,9 +136,9 @@ TransactionDb.prototype.fromTxId = function(txid, cb) {
var k = SPENT_PREFIX + txid + '-';
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var k = data.key.split('-');
var j = idx[parseInt(k[2])];
@ -164,9 +165,9 @@ TransactionDb.prototype._fillSpent = function(info, cb) {
var k = SPENT_PREFIX + info.txid + '-';
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var k = data.key.split('-');
self._addSpentInfo(info.vout[k[2]], k[3], k[4], data.value);
@ -247,8 +248,8 @@ TransactionDb.prototype._getInfo = function(txid, next, opts) {
self._fillOutpoints(txInfo, function() {
if (opts.noExtraInfo)
return next(null,txInfo);
if (opts.noExtraInfo)
return next(null, txInfo);
self._fillSpent(txInfo, function() {
return next(null, txInfo);
@ -301,15 +302,15 @@ TransactionDb.prototype.fromTxIdN = function(txid, n, cb, opts) {
};
}
if (opts.noExtraInfo)
if (opts.noExtraInfo)
return cb(null, ret);
// spent?
var k = SPENT_PREFIX + txid + '-' + n + '-';
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var k = data.key.split('-');
self._addSpentInfo(ret, k[3], k[4], data.value);
@ -328,9 +329,9 @@ TransactionDb.prototype.deleteCacheForAddress = function(addr, cb) {
var k = ADDR_PREFIX + addr + '-';
var dbScript = [];
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var v = data.value.split(':');
dbScript.push({
@ -391,25 +392,28 @@ TransactionDb.prototype.cacheConfirmations = function(txouts, cb) {
TransactionDb.prototype.cacheScriptPubKey = function(txouts, cb) {
console.log('[TransactionDb.js.381:cacheScriptPubKey:]'); //TODO
// console.log('[TransactionDb.js.381:cacheScriptPubKey:]'); //TODO
var self = this;
var dbScript = [];
for (var ii in txouts) {
var txout = txouts[ii];
_.each(txouts, function(txout) {
//everything already cached?
if (txout.scriptPubKeyCached || txout.spentTxId) {
continue;
}
if (txout.scriptPubKeyCached || txout.spentTxId)
return;
// not hard confirmed ?
if (!txout.isConfirmedCached && !txout.confirmedWillBeCached)
return;
if (txout.scriptPubKey) {
var infoToCache = [txout.value_sat, (txout.isConfirmedCached || txout.confirmedWillBeCached) ? 1 : 0, txout.scriptPubKey];
var infoToCache = [txout.value_sat, 1, txout.scriptPubKey];
dbScript.push({
type: 'put',
key: txout.key,
value: infoToCache.join(':'),
});
}
}
});
db.batch(dbScript, cb);
};
@ -466,10 +470,10 @@ TransactionDb.prototype.fromAddr = function(addr, opts, cb) {
var unique = {};
db.createReadStream({
start: k,
end: k + '~',
limit: opts.txLimit > 0 ? opts.txLimit : -1, // -1 means not limit
})
start: k,
end: k + '~',
limit: opts.txLimit > 0 ? opts.txLimit : -1, // -1 means not limit
})
.on('data', function(data) {
var k = data.key.split('-');
var index = k[3] + k[4];
@ -495,9 +499,9 @@ TransactionDb.prototype.fromAddr = function(addr, opts, cb) {
}), CONCURRENCY, function(o, e_c) {
var k = SPENT_PREFIX + o.txid + '-' + o.index + '-';
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var k = data.key.split('-');
self._addSpentInfo(o, k[3], k[4], data.value);
@ -573,8 +577,9 @@ TransactionDb.prototype.fillScriptPubKey = function(txouts, cb) {
return a_c();
});
}, function() {
if (!allCached)
self.cacheScriptPubKey(txouts, cb);
if (allCached)
return cb();
self.cacheScriptPubKey(txouts, cb);
});
};
@ -593,14 +598,14 @@ TransactionDb.prototype.removeFromTxId = function(txid, cb) {
},
function(c) {
db.createReadStream({
start: SPENT_PREFIX + txid + '-',
end: SPENT_PREFIX + txid + '~'
})
start: SPENT_PREFIX + txid + '-',
end: SPENT_PREFIX + txid + '~'
})
.pipe(
db.createWriteStream({
type: 'del'
})
).on('close', c);
).on('close', c);
}
],
function(err) {
@ -722,10 +727,10 @@ TransactionDb.prototype.checkVersion02 = function(cb) {
var k = 'txa-';
var isV2 = 1;
db.createReadStream({
start: k,
end: k + '~',
limit: 1,
})
start: k,
end: k + '~',
limit: 1,
})
.on('data', function(data) {
isV2 = 0;
})
@ -741,9 +746,9 @@ TransactionDb.prototype.migrateV02 = function(cb) {
var c2 = 0;
var N = 50000;
db.createReadStream({
start: k,
end: k + '~'
})
start: k,
end: k + '~'
})
.on('data', function(data) {
var k = data.key.split('-');
var v = data.value.split(':');