mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-09-02 18:25:21 +00:00
ln: commit fee updates as soon as possible
This commit is contained in:
parent
308eacbdc3
commit
634c39b6b0
2 changed files with 7 additions and 2 deletions
|
@ -1040,7 +1040,7 @@ class Peer(PrintError):
|
|||
channel_id = payload["channel_id"]
|
||||
self.channels[channel_id].receive_update_fee(int.from_bytes(payload["feerate_per_kw"], "big"))
|
||||
|
||||
def on_bitcoin_fee_update(self, chan):
|
||||
async def bitcoin_fee_update(self, chan):
|
||||
"""
|
||||
called when our fee estimates change
|
||||
"""
|
||||
|
@ -1062,6 +1062,11 @@ class Peer(PrintError):
|
|||
return
|
||||
|
||||
self.send_message(gen_msg("update_fee", channel_id=chan.channel_id, feerate_per_kw=feerate_per_kw))
|
||||
sig_64, htlc_sigs = chan.sign_next_commitment()
|
||||
self.send_message(gen_msg("commitment_signed", channel_id=chan.channel_id, signature=sig_64, num_htlcs=len(htlc_sigs), htlc_signature=b"".join(htlc_sigs)))
|
||||
await self.receive_revoke(chan)
|
||||
await self.receive_commitment(chan)
|
||||
self.revoke(chan)
|
||||
self.lnworker.save_channel(chan)
|
||||
|
||||
def current_feerate_per_kw(self):
|
||||
|
|
|
@ -150,7 +150,7 @@ class LNWorker(PrintError):
|
|||
self.print_error("peer not found for {}".format(bh2u(chan.node_id)))
|
||||
return
|
||||
if event == 'fee':
|
||||
peer.on_bitcoin_fee_update(chan)
|
||||
await peer.bitcoin_fee_update(chan)
|
||||
conf = self.wallet.get_tx_height(chan.funding_outpoint.txid).conf
|
||||
peer.on_network_update(chan, conf)
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue