From a396df4f5d3a0a501013b752b5d94d2e33118f0d Mon Sep 17 00:00:00 2001 From: Janus Date: Thu, 1 Mar 2018 12:26:34 +0100 Subject: [PATCH] lightning: print invoice updates --- lib/lightning.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/lib/lightning.py b/lib/lightning.py index 0c711102..850a4904 100644 --- a/lib/lightning.py +++ b/lib/lightning.py @@ -736,7 +736,9 @@ class LightningWorker(ForeverCoroutineJob): await asyncio.wait_for(writer.drain(), 5) while is_running(): obj = await readJson(reader, is_running) - if not obj: continue + if "id" not in obj: + print("Invoice update?", obj) + continue await asyncio.wait_for(readReqAndReply(obj, writer), 10) except: traceback.print_exc() @@ -746,10 +748,10 @@ class LightningWorker(ForeverCoroutineJob): async def readJson(reader, is_running): data = b"" while is_running(): - if data != b"": print("parse failed, data has", data) try: return json.loads(data) except ValueError: + if data != b"": print("parse failed, data has", data) try: data += await asyncio.wait_for(reader.read(2048), 1) except TimeoutError: @@ -792,6 +794,7 @@ async def readReqAndReply(obj, writer): await writer.drain() else: if not found: + # TODO assumes obj has id writer.write(json.dumps({"id":obj["id"],"error": {"code": -32601, "message": "invalid method"}}).encode("ascii")) else: print("result was", result)