tlightning channels list: add mock server for testing - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit d055507003eef1d910ceeba6deb9cadfa9f5bb71
DIR parent fc822ab9278c73cf3c1ec864baf29978fbadb3f8
HTML Author: Janus <ysangkok@gmail.com>
Date: Wed, 18 Apr 2018 17:20:30 +0200
lightning channels list: add mock server for testing
Diffstat:
M gui/qt/lightning_channels_list.py | 67 ++++++++++++++++++++++++++++---
1 file changed, 62 insertions(+), 5 deletions(-)
---
DIR diff --git a/gui/qt/lightning_channels_list.py b/gui/qt/lightning_channels_list.py
t@@ -13,7 +13,6 @@ datatable = OrderedDict([])
class MyTableRow(QtWidgets.QTreeWidgetItem):
def __init__(self, di):
strs = [str(di[mapping[key]]) for key in range(len(mapping))]
- print(strs)
super(MyTableRow, self).__init__(strs)
assert isinstance(di, dict)
self.di = di
t@@ -47,8 +46,8 @@ class LightningChannelsList(QtWidgets.QWidget):
cur = self._tv.currentItem()
channel_point = cur["channel_point"]
def close():
- params = [str(channel_point)] + (["--force"] if cur["active"] else [])
- lightningCall(lightningRpc, "closechannel")(*params)
+ params = [str(channel_point)] + (["--force"] if not cur["active"] else []) # TODO test if force is being used correctly
+ lightningCall(self.lightningRpc, "closechannel")(*params)
menu.addAction("Close channel", close)
menu.exec_(self._tv.viewport().mapToGlobal(position))
def lightningWorkerHandler(self, sourceClassName, obj):
t@@ -97,10 +96,11 @@ class LightningChannelsList(QtWidgets.QWidget):
timer = QtCore.QTimer(self)
timer.timeout.connect(tick)
- timer.start(20000)
+ timer.start(5000)
lightningWorker.subscribe(self.lightningWorkerHandler)
lightningRpc.subscribe(self.lightningRpcHandler)
+ self.lightningRpc = lightningRpc
self._tv=QtWidgets.QTreeWidget(self)
self._tv.setHeaderLabels([mapping[i] for i in range(len(mapping))])
t@@ -140,13 +140,70 @@ class LightningChannelsList(QtWidgets.QWidget):
self.resize(2500,1000)
+class MockLightningWorker:
+ def subscribe(self, handler):
+ pass
+
if __name__=="__main__":
+ import queue, threading, asyncio
from sys import argv, exit
+ import signal , traceback, os
+
+ loop = asyncio.new_event_loop()
+
+ async def loopstop():
+ loop.stop()
+
+ def signal_handler(signal, frame):
+ asyncio.run_coroutine_threadsafe(loopstop(), loop)
+
+ signal.signal(signal.SIGINT, signal_handler)
a=QtWidgets.QApplication(argv)
- w=LightningChannelsList()
+ gotReplyHandlerLock = threading.Lock()
+ gotReplyHandlerLock.acquire()
+ replyHandler = None
+
+ class MockLightningRPC:
+ def __init__(self, q):
+ self.queue = q
+ def subscribe(self, handler):
+ global replyHandler
+ replyHandler = handler
+ gotReplyHandlerLock.release()
+
+ q = queue.Queue()
+ w=LightningChannelsList(None, MockLightningWorker(), MockLightningRPC(q))
w.show()
w.raise_()
+ async def the_job():
+ try:
+ acquired_once = False
+ while loop.is_running():
+ try:
+ cmd = q.get_nowait()
+ except queue.Empty:
+ await asyncio.sleep(1)
+ continue
+ if not acquired_once:
+ gotReplyHandlerLock.acquire()
+ acquired_once = True
+ if cmd[0] == "listchannels":
+ #replyHandler("listchannels", Exception("Test exception"))
+ replyHandler("listchannels", {"channels": [{"channel_point": binascii.hexlify(os.urandom(32)).decode("ascii"), "active": True}]})
+ elif cmd[0] == "openchannel":
+ replyHandler("openchannel", {})
+ else:
+ print("mock rpc server ignoring", cmd[0])
+ except:
+ traceback.print_exc()
+
+ def asyncioThread():
+ loop.create_task(the_job())
+ loop.run_forever()
+
+ threading.Thread(target=asyncioThread).start()
+
exit(a.exec_())