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

fix(LND_GRPC): two potential async bugs

Browse source 
* gRPC channel not created in all cases
* possible infinite loop while waiting for lnd to boot up

refs #126
This commit is contained in:
fusion44 2022-06-26 10:59:56 +02:00
parent 1cfab33a5c
commit d573217bd7
No known key found for this signature in database
GPG key ID: 645FA807E935D9D5
1 changed files with 12 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

13
app/repositories/ln_impl/lnd_grpc.py
View file

@ -129,7 +129,12 @@ async def _check_lnd_status(
channel = grpc.aio.secure_channel(_lnd_grpc_url, _combined_creds)
lnd_stub = lnrpc.LightningStub(channel)
await lnd_stub.GetInfo(ln.GetInfoRequest())
if _channel is None:
_create_stubs()
await init_queue.put(InitLnRepoUpdate(state=LnInitState.DONE))
break
except grpc.aio._call.AioRpcError as error:
details = error.details()
logging.debug(f"Waiting for LND daemon... Details {details}")
@ -551,7 +556,13 @@ async def _wait_wallet_fully_ready():
while True:
try:
await _lnd_stub.GetInfo(ln.GetInfoRequest())
info = await _lnd_stub.GetInfo(ln.GetInfoRequest())
if info != None:
logging.debug(
f"LND_GRPC: _wait_wallet_fully_ready() breaking out of loop"
)
break
except grpc.aio._call.AioRpcError as error:
details = error.details()
if (