AaronFiore/electrum
1
0
Fork 0
Code Activity

add watchtower_window

Browse Source
This commit is contained in:
ThomasV
2019-01-30 17:24:43 +01:00
parent 7bb4ea150f
commit 19e60f00bb
5 changed files with 121 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
electrum/lnwatcher.py
View File

@@ -58,14 +58,16 @@ class LNWatcher(AddressSynchronizer):
self.network.register_callback(self.on_network_update,
['network_updated', 'blockchain_updated', 'verified', 'wallet_updated'])
# remote watchtower
watchtower_url = self.config.get('watchtower_url')
self.watchtower = jsonrpclib.Server(watchtower_url) if watchtower_url else None
self.watchtower_queue = asyncio.Queue()
self.set_remote_watchtower()
# this maps funding_outpoints to ListenerItems, which have an event for when the watcher is done,
# and a queue for seeing which txs are being published
self.tx_progress = {} # type: Dict[str, ListenerItem]
def set_remote_watchtower(self):
watchtower_url = self.config.get('watchtower_url')
self.watchtower = jsonrpclib.Server(watchtower_url) if watchtower_url else None
self.watchtower_queue = asyncio.Queue()
def with_watchtower(func):
def wrapper(self, *args, **kwargs):
if self.watchtower: