aljaz/plugins
1
0
Fork 0
mirror of https://github.com/aljazceru/plugins.git synced 2025-12-24 08:34:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

feeadjuster: update forward_event _msat values

Browse Source
This commit is contained in:
Michael Schmoock
2022-09-19 23:26:13 +02:00
parent 3514460ae8
commit 2810f4d032
2 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
feeadjuster/feeadjuster.py
View File

@@ -1,5 +1,6 @@
#!/usr/bin/env python3
import random
import semver
import statistics
import time
import math
@@ -212,8 +213,13 @@ def forward_event(plugin: Plugin, forward_event: dict, **kwargs):
out_scid = forward_event["out_channel"]
maybe_add_new_balances(plugin, [in_scid, out_scid])
plugin.adj_balances[in_scid]["our"] += forward_event["in_msatoshi"]
plugin.adj_balances[out_scid]["our"] -= forward_event["out_msatoshi"]
if plugin.rpcversion.major == 0 and plugin.rpcversion.minor < 12:
plugin.adj_balances[in_scid]["our"] += int(forward_event["in_msatoshi"])
plugin.adj_balances[out_scid]["our"] -= int(forward_event["out_msatoshi"])
else:
plugin.adj_balances[in_scid]["our"] += int(forward_event["in_msat"])
plugin.adj_balances[out_scid]["our"] -= int(forward_event["out_msat"])
try:
# Pseudo-randomly add some hysterisis to the update
if not plugin.deactivate_fuzz and random.randint(0, 9) == 9:
@@ -281,7 +287,15 @@ def feeadjuster_toggle(plugin: Plugin, value: bool = None):
@plugin.init()
def init(options: dict, configuration: dict, plugin: Plugin, **kwargs):
plugin.our_node_id = plugin.rpc.getinfo()["id"]
# parse semver string to determine RPC version
# strip leading 'v' although semver should ignore it, but it doesn't.
plugin.getinfo = plugin.rpc.getinfo()
rpcversion = plugin.getinfo.get('version')
if rpcversion.startswith('v'):
rpcversion = rpcversion[1:]
plugin.rpcversion = semver.VersionInfo.parse(rpcversion)
plugin.our_node_id = plugin.getinfo["id"]
plugin.deactivate_fuzz = options.get("feeadjuster-deactivate-fuzz")
plugin.forward_event_subscription = not options.get("feeadjuster-deactivate-fee-update")
plugin.update_threshold = float(options.get("feeadjuster-threshold"))

1
feeadjuster/requirements.txt
View File

@@ -1 +1,2 @@
pyln-client>=0.8.2
semver==2.*