From a486cbe2781e26d64a7025ffb68bbcdb41fb2703 Mon Sep 17 00:00:00 2001 From: benarc Date: Wed, 3 Nov 2021 16:07:04 +0000 Subject: [PATCH] broken cln sse rpc --- lnbits/wallets/clightning.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lnbits/wallets/clightning.py b/lnbits/wallets/clightning.py index 1dd5cc3cf..0eb961a6e 100644 --- a/lnbits/wallets/clightning.py +++ b/lnbits/wallets/clightning.py @@ -115,17 +115,17 @@ class CLightningWallet(Wallet): raise KeyError("supplied an invalid checking_id") async def paid_invoices_stream(self) -> AsyncGenerator[str, None]: - stream = await asyncio.open_unix_connection(self.rpc) + reader, writer = await asyncio.open_unix_connection(self.rpc) i = 0 while True: call = json.dumps( {"method": "waitanyinvoice", "id": 0, "params": [self.last_pay_index]} ) + writer.write(call.encode("utf-8")) + await writer.drain() - await stream.send_all(call.encode("utf-8")) - - data = await stream.receive_some() + data = await reader.read(100) paid = json.loads(data.decode("ascii")) paid = self.ln.waitanyinvoice(self.last_pay_index)