From ca518fd291062517257b4eae7cac7bb405e73fac Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?G=C3=A1lli=20Zolt=C3=A1n?= Date: Fri, 20 Nov 2020 16:11:43 +0100 Subject: [PATCH] feeadjuster: forcefeeadjust can run after a successful payment too --- feeadjuster/feeadjuster.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/feeadjuster/feeadjuster.py b/feeadjuster/feeadjuster.py index b4f7707..d539e4f 100755 --- a/feeadjuster/feeadjuster.py +++ b/feeadjuster/feeadjuster.py @@ -112,15 +112,19 @@ def forward_event(plugin: Plugin, forward_event: dict, **kwargs): def forcefeeadjust(plugin: Plugin): """Adjust fees for all existing channels. - Can run effectively only once as an initial setup. After that, the plugin keeps the fees up-to-date. + Can run effectively once as an initial setup, or after a successful payment. Otherwise, the plugin keeps the fees up-to-date. """ peers = plugin.rpc.listpeers()["peers"] channels_adjusted = 0 for peer in peers: for chan in peer["channels"]: if chan["state"] == "CHANNELD_NORMAL": - maybe_add_new_balances(plugin, [chan['short_channel_id']]) - channels_adjusted += maybe_adjust_fees(plugin, [chan['short_channel_id']]) + scid = chan['short_channel_id']; + if scid not in plugin.adj_balances: + plugin.adj_balances[scid] = {} + plugin.adj_balances[scid]["our"] = int(chan["to_us_msat"]) + plugin.adj_balances[scid]["total"] = int(chan["total_msat"]) + channels_adjusted += maybe_adjust_fees(plugin, [scid]) return "%s channels adjusted" % channels_adjusted