aljaz/plugins
1
0
Fork 0
mirror of https://github.com/aljazceru/plugins.git synced 2026-01-27 17:04:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

feeadjuster: forcefeeadjust can run after a successful payment too

Browse Source
This commit is contained in:
Gálli Zoltán
2020-11-20 16:11:43 +01:00
committed by Christian Decker
parent a431fe0495
commit ca518fd291
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
feeadjuster/feeadjuster.py
View File

@@ -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