RanchiMall/flo-electrum
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

lightning: print invoice updates

Browse Source
This commit is contained in:
Janus 2018-03-01 12:26:34 +01:00
parent 559d12e3a3
commit a396df4f5d
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/lightning.py
View File

@ -736,7 +736,9 @@ class LightningWorker(ForeverCoroutineJob):
await asyncio.wait_for(writer.drain(), 5) await asyncio.wait_for(writer.drain(), 5)
while is_running(): while is_running():
obj = await readJson(reader, 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) await asyncio.wait_for(readReqAndReply(obj, writer), 10)
except: except:
traceback.print_exc() traceback.print_exc()
@ -746,10 +748,10 @@ class LightningWorker(ForeverCoroutineJob):
async def readJson(reader, is_running): async def readJson(reader, is_running):
data = b"" data = b""
while is_running(): while is_running():
if data != b"": print("parse failed, data has", data)
try: try:
return json.loads(data) return json.loads(data)
except ValueError: except ValueError:
if data != b"": print("parse failed, data has", data)
try: try:
data += await asyncio.wait_for(reader.read(2048), 1) data += await asyncio.wait_for(reader.read(2048), 1)
except TimeoutError: except TimeoutError:
@ -792,6 +794,7 @@ async def readReqAndReply(obj, writer):
await writer.drain() await writer.drain()
else: else:
if not found: if not found:
# TODO assumes obj has id
writer.write(json.dumps({"id":obj["id"],"error": {"code": -32601, "message": "invalid method"}}).encode("ascii")) writer.write(json.dumps({"id":obj["id"],"error": {"code": -32601, "message": "invalid method"}}).encode("ascii"))
else: else:
print("result was", result) print("result was", result)