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

Get addr status after subscribing to fix race.

Browse source
This commit is contained in:
Jonathan Moody 2022-09-20 22:31:33 -05:00 committed by Jack Robison
parent e60bb35ebd
commit bc4e3aa7fb
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
hub/herald/session.py
View file

@ -1483,12 +1483,11 @@ class LBRYElectrumX(asyncio.Protocol):
if len(addresses) > 1000: if len(addresses) > 1000:
raise RPCError(BAD_REQUEST, f'too many addresses in subscription request: {len(addresses)}') raise RPCError(BAD_REQUEST, f'too many addresses in subscription request: {len(addresses)}')
hashXes = [item async for item in asyncify_for_loop((self.address_to_hashX(address) for address in addresses), 100)] hashXes = [item async for item in asyncify_for_loop((self.address_to_hashX(address) for address in addresses), 100)]
statuses = await self.get_hashX_statuses(hashXes)
for hashX, alias in zip(hashXes, addresses): for hashX, alias in zip(hashXes, addresses):
self.hashX_subs[hashX] = alias self.hashX_subs[hashX] = alias
self.session_manager.hashx_subscriptions_by_session[hashX].add(id(self)) self.session_manager.hashx_subscriptions_by_session[hashX].add(id(self))
self.session_manager.address_subscription_metric.inc(len(addresses)) self.session_manager.address_subscription_metric.inc(len(addresses))
return statuses return await self.get_hashX_statuses(hashXes)
async def address_unsubscribe(self, address): async def address_unsubscribe(self, address):
"""Unsubscribe an address. """Unsubscribe an address.