GlcoinCore/blitz_api
1
0
Fork 0
mirror of https://github.com/fusion44/blitz_api.git synced 2026-08-15 12:10:12 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: don't update wallet if update is pending

Browse source
This commit is contained in:
Stefan Stammberger 2022-01-15 14:03:44 +01:00
parent 78db9f3d71
commit 18822e68cc
No known key found for this signature in database
GPG key ID: 645FA807E935D9D5
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

14
app/repositories/lightning.py
View file

@ -191,16 +191,26 @@ async def _handle_invoice_listener():
_update_wallet_balance()
_wallet_balance_update_scheduled = False
def _update_wallet_balance():
async def _perform_update():
global _wallet_balance_update_scheduled
_wallet_balance_update_scheduled = True
await asyncio.sleep(1.1)
wb = await get_wallet_balance_impl()
if _CACHE["wallet_balance"] != wb:
await send_sse_message(SSE.WALLET_BALANCE, wb.dict())
_CACHE["wallet_balance"] = wb
loop = asyncio.get_event_loop()
loop.create_task(_perform_update())
_wallet_balance_update_scheduled = False
global _wallet_balance_update_scheduled
if not _wallet_balance_update_scheduled:
loop = asyncio.get_event_loop()
loop.create_task(_perform_update())
def register_wallet_unlock_listener(q: asyncio.Queue):