tlnbase: call save_channel in revoke and receive_revoke - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit d9facabc8ca1ea9491da62da860118b7959b06e2
DIR parent 0dfc9e512b6ca711395f22426993486c4899d2d1
HTML Author: ThomasV <thomasv@electrum.org>
Date: Tue, 23 Oct 2018 15:05:11 +0200
lnbase: call save_channel in revoke and receive_revoke
Diffstat:
M electrum/lnbase.py | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
---
DIR diff --git a/electrum/lnbase.py b/electrum/lnbase.py
t@@ -876,7 +876,6 @@ class Peer(PrintError):
self.revoke(chan)
self.send_commitment(chan) # htlc will be removed
await self.receive_revoke(chan)
- self.lnworker.save_channel(chan)
self.network.trigger_callback('ln_message', self.lnworker, 'Payment failed')
async def _handle_error_code_from_failed_htlc(self, error_reason, route: List[RouteEdge], channel_id, htlc_id):
t@@ -954,6 +953,7 @@ class Peer(PrintError):
async def receive_revoke(self, m):
revoke_and_ack_msg = await self.revoke_and_ack[m.channel_id].get()
m.receive_revocation(RevokeAndAck(revoke_and_ack_msg["per_commitment_secret"], revoke_and_ack_msg["next_per_commitment_point"]))
+ self.lnworker.save_channel(chan)
def revoke(self, m):
rev, _ = m.revoke_current_commitment()
t@@ -987,7 +987,6 @@ class Peer(PrintError):
self.revoke(chan)
self.send_commitment(chan) # htlc will be removed
await self.receive_revoke(chan)
- self.lnworker.save_channel(chan)
self.network.trigger_callback('ln_message', self.lnworker, 'Payment sent')
# used in lightning-integration
t@@ -1064,7 +1063,6 @@ class Peer(PrintError):
channel_id=chan.channel_id,
id=htlc_id,
payment_preimage=preimage)
- self.lnworker.save_channel(chan)
self.network.trigger_callback('ln_message', self.lnworker, 'Payment received')
async def fail_htlc(self, chan: Channel, htlc_id: int, onion_packet: OnionPacket,
t@@ -1077,7 +1075,6 @@ class Peer(PrintError):
id=htlc_id,
len=len(error_packet),
reason=error_packet)
- self.lnworker.save_channel(chan)
def on_revoke_and_ack(self, payload):
self.print_error("got revoke_and_ack")