AaronFiore/electrum
1
0
Fork 0
Code Activity

follow-up c7dcfab

Browse Source
This commit is contained in:
ThomasV
2025-03-11 18:16:41 +01:00
parent 3f327eea07
commit 9d0cc6c4a3
1 changed files with 0 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
electrum/plugins/watchtower/watchtower.py
View File

@@ -70,9 +70,6 @@ class WatchTower(LNWatcher):
LNWatcher.__init__(self, adb, network) LNWatcher.__init__(self, adb, network)
self.network = network self.network = network
self.sweepstore = SweepStore(os.path.join(self.network.config.path, "watchtower_db"), network) self.sweepstore = SweepStore(os.path.join(self.network.config.path, "watchtower_db"), network)
# 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]
async def stop(self): async def stop(self):
await super().stop() await super().stop()
@@ -163,8 +160,6 @@ class WatchTower(LNWatcher):
self.logger.info(f'broadcast failure: txid={tx.txid()}, funding_outpoint={funding_outpoint}: {repr(e)}') self.logger.info(f'broadcast failure: txid={tx.txid()}, funding_outpoint={funding_outpoint}: {repr(e)}')
else: else:
self.logger.info(f'broadcast success: txid={tx.txid()}, funding_outpoint={funding_outpoint}') self.logger.info(f'broadcast success: txid={tx.txid()}, funding_outpoint={funding_outpoint}')
if funding_outpoint in self.tx_progress:
await self.tx_progress[funding_outpoint].tx_queue.put(tx)
return txid return txid
async def get_ctn(self, outpoint, addr): async def get_ctn(self, outpoint, addr):
@@ -192,8 +187,6 @@ class WatchTower(LNWatcher):
await super().unwatch_channel(address, funding_outpoint) await super().unwatch_channel(address, funding_outpoint)
await self.sweepstore.remove_sweep_tx(funding_outpoint) await self.sweepstore.remove_sweep_tx(funding_outpoint)
await self.sweepstore.remove_channel(funding_outpoint) await self.sweepstore.remove_channel(funding_outpoint)
if funding_outpoint in self.tx_progress:
self.tx_progress[funding_outpoint].all_done.set()
async def update_channel_state(self, *args, **kwargs): async def update_channel_state(self, *args, **kwargs):
pass pass