Browse Source

cache address strings only

activeAddress
Ivan Socolsky 9 years ago
parent
commit
072aed5cc1
  1. 7
      lib/server.js
  2. 6
      lib/storage.js

7
lib/server.js

@ -1006,11 +1006,7 @@ WalletService.prototype.getBalance = function(opts, cb) {
if (err) return cb(err);
// Update cache
var addressIndex = _.indexBy(addresses, 'address');
var active = _.map(_.pluck(balance.byAddress, 'address'), function(addrStr) {
return addressIndex[addrStr];
});
var active = _.pluck(balance.byAddress, 'address')
self.storage.storeActiveAddresses(self.walletId, active, function(err) {
if (err) {
log.warn('Could not update wallet cache', err);
@ -1030,7 +1026,6 @@ WalletService.prototype._getActiveAddresses = function(cb) {
log.warn('Could not fetch active addresses from cache', err);
return cb(null, []);
}
active = _.pluck(active, 'address');
self.storage.fetchAddresses(self.walletId, function(err, allAddresses) {
if (err) return cb(err);

6
lib/storage.js

@ -520,8 +520,8 @@ Storage.prototype.storeActiveAddresses = function(walletId, addresses, cb) {
var record = {
walletId: walletId,
type: 'activeAddresses',
key: address.address,
value: address,
key: address,
value: null,
};
self.db.collection(collections.CACHE).update({
walletId: record.walletId,
@ -544,7 +544,7 @@ Storage.prototype.fetchActiveAddresses = function(walletId, cb) {
if (err) return cb(err);
if (!result || _.isEmpty(result)) return cb(null, []);
return cb(null, _.pluck(result, 'value'));
return cb(null, _.pluck(result, 'key'));
});
};

Loading…
Cancel
Save