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

Merge pull request #3095 from lbryio/fix-transaction-getbatch-order

Browse source 
ensure transactions are returned in the order they're requested
This commit is contained in:
Jack Robison 2020-11-24 17:21:12 -05:00 committed by GitHub
commit 23bb5598d5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -518,15 +518,15 @@ class LevelDB:
txs = await asyncio.get_event_loop().run_in_executor( txs = await asyncio.get_event_loop().run_in_executor(
self.executor, self._fs_transactions, txids self.executor, self._fs_transactions, txids
) )
unsorted_result = {}
async def add_result(item): async def add_result(item):
_txid, _tx, _tx_num, _tx_height = item _txid, _tx, _tx_num, _tx_height = item
result[_txid] = (_tx, await self.tx_merkle(_tx_num, _tx_height)) unsorted_result[_txid] = (_tx, await self.tx_merkle(_tx_num, _tx_height))
result = {}
if txs: if txs:
await asyncio.gather(*map(add_result, txs)) await asyncio.gather(*map(add_result, txs))
return result return {txid: unsorted_result[txid] for txid, _, _, _ in txs}
async def fs_block_hashes(self, height, count): async def fs_block_hashes(self, height, count):
if height + count > len(self.headers): if height + count > len(self.headers):