LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-09-04 04:45:16 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

minor fix

Browse source
This commit is contained in:
ThomasV 2018-10-13 14:35:56 +02:00
parent 9362130fba
commit 87fb0da5e1
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
electrum/lnchan.py
View file

@ -343,7 +343,8 @@ class Channel(PrintError):
else: else:
their_cur_pcp = self.config[REMOTE].next_per_commitment_point their_cur_pcp = self.config[REMOTE].next_per_commitment_point
encumbered_sweeptx = maybe_create_sweeptx_for_their_ctx_to_remote(self, ctx, their_cur_pcp, self.sweep_address) encumbered_sweeptx = maybe_create_sweeptx_for_their_ctx_to_remote(self, ctx, their_cur_pcp, self.sweep_address)
self.lnwatcher.add_sweep_tx(outpoint, ctx.txid(), encumbered_sweeptx.to_json()) if encumbered_sweeptx:
self.lnwatcher.add_sweep_tx(outpoint, ctx.txid(), encumbered_sweeptx.to_json())
def process_new_revocation_secret(self, per_commitment_secret: bytes): def process_new_revocation_secret(self, per_commitment_secret: bytes):
if not self.lnwatcher: if not self.lnwatcher:
@ -351,7 +352,8 @@ class Channel(PrintError):
outpoint = self.funding_outpoint.to_str() outpoint = self.funding_outpoint.to_str()
ctx = self.remote_commitment_to_be_revoked ctx = self.remote_commitment_to_be_revoked
encumbered_sweeptx = maybe_create_sweeptx_for_their_ctx_to_local(self, ctx, per_commitment_secret, self.sweep_address) encumbered_sweeptx = maybe_create_sweeptx_for_their_ctx_to_local(self, ctx, per_commitment_secret, self.sweep_address)
self.lnwatcher.add_sweep_tx(outpoint, ctx.txid(), encumbered_sweeptx.to_json()) if encumbered_sweeptx:
self.lnwatcher.add_sweep_tx(outpoint, ctx.txid(), encumbered_sweeptx.to_json())
def receive_revocation(self, revocation): def receive_revocation(self, revocation):
""" """

2
electrum/lnwatcher.py
View file

@ -185,8 +185,6 @@ class LNWatcher(PrintError):
@with_watchtower @with_watchtower
def add_sweep_tx(self, funding_outpoint: str, ctx_txid: str, sweeptx): def add_sweep_tx(self, funding_outpoint: str, ctx_txid: str, sweeptx):
encumbered_sweeptx = EncumberedTransaction.from_json(sweeptx) encumbered_sweeptx = EncumberedTransaction.from_json(sweeptx)
if encumbered_sweeptx is None:
return
with self.lock: with self.lock:
self.sweepstore[funding_outpoint][ctx_txid].add(encumbered_sweeptx) self.sweepstore[funding_outpoint][ctx_txid].add(encumbered_sweeptx)
self.write_to_disk() self.write_to_disk()