LBRYCommunity/hub
1
0
Fork 0
Code Issues 35 Pull requests 6 Projects Releases Packages Wiki Activity

Precomputed hashx status #17

Merged
jackrobison merged 7 commits from precomputed-hashx-status into master 2022-04-07 18:06:18 +02:00
Conversation 0 Commits 7 Files changed 10 +9 -6
2 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 8a2517aa36 - Show all commits

8
scribe/db/db.py
View file

@ -850,6 +850,14 @@ class HubDB:
self.prefix_db.close() self.prefix_db.close()
self.prefix_db = None self.prefix_db = None
def get_hashX_status(self, hashX: bytes):
mempool_status = self.prefix_db.hashX_mempool_status.get(hashX)
if mempool_status:
return mempool_status.status.hex()
status = self.prefix_db.hashX_status.get(hashX)
if status:
return status.status.hex()
def get_tx_hash(self, tx_num: int) -> bytes: def get_tx_hash(self, tx_num: int) -> bytes:
if self._cache_all_tx_hashes: if self._cache_all_tx_hashes:
return self.total_transactions[tx_num] return self.total_transactions[tx_num]

7
scribe/hub/session.py
View file

@ -1101,12 +1101,7 @@ class LBRYElectrumX(asyncio.Protocol):
return len(self.hashX_subs) return len(self.hashX_subs)
async def get_hashX_status(self, hashX: bytes): async def get_hashX_status(self, hashX: bytes):
mempool_status = self.db.prefix_db.hashX_mempool_status.get(hashX) return await self.loop.run_in_executor(self.db._executor, self.db.get_hashX_status, hashX)
if mempool_status:
return mempool_status.status.hex()
status = self.db.prefix_db.hashX_status.get(hashX)
if status:
return status.status.hex()
async def send_history_notifications(self, *hashXes: typing.Iterable[bytes]): async def send_history_notifications(self, *hashXes: typing.Iterable[bytes]):
notifications = [] notifications = []