LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

initialize TX_COUNTS_STATE from existing TX_COUNT_PREFIX

Browse source
This commit is contained in:
Jack Robison 2020-12-01 17:01:46 -05:00
parent c03b1b5a93
commit ede167bb56
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
2 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbry/wallet/ledger.py
View file

@ -131,7 +131,7 @@ class Ledger(metaclass=LedgerRegistry):
self._on_transaction_controller = StreamController() self._on_transaction_controller = StreamController()
self.on_transaction = self._on_transaction_controller.stream self.on_transaction = self._on_transaction_controller.stream
self.on_transaction.listen( self.on_transaction.listen(
lambda e: log.info( lambda e: log.debug(
'(%s) on_transaction: address=%s, height=%s, is_verified=%s, tx.id=%s', '(%s) on_transaction: address=%s, height=%s, is_verified=%s, tx.id=%s',
self.get_id(), e.address, e.tx.height, e.tx.is_verified, e.tx.id self.get_id(), e.address, e.tx.height, e.tx.is_verified, e.tx.id
) )

4
lbry/wallet/server/leveldb.py
View file

@ -74,7 +74,9 @@ class RocksReaderContext:
def update_state(self): def update_state(self):
tx_counts = array.array("L") tx_counts = array.array("L")
counts = self.db.get(TX_COUNTS_STATE) counts = self.db.get(TX_COUNTS_STATE)
if counts: if not counts:
self.tx_counts = list(map(unpack_be_uint64, self.db.iterator(prefix=TX_COUNT_PREFIX, include_key=False)))
else:
tx_counts.frombytes(counts) tx_counts.frombytes(counts)
self.tx_counts = tx_counts.tolist() self.tx_counts = tx_counts.tolist()