|
1 | | -#!/usr/bin/env python3 |
| 1 | +#!/usr/bin/env -S uv run --script |
| 2 | + |
| 3 | +# /// script |
| 4 | +# requires-python = ">=3.9.2" |
| 5 | +# dependencies = [ |
| 6 | +# "pyln-client>=24.11", |
| 7 | +# ] |
| 8 | +# /// |
| 9 | + |
2 | 10 | from clnutils import cln_parse_rpcversion |
3 | 11 | from datetime import timedelta |
4 | 12 | from functools import reduce |
@@ -50,7 +58,12 @@ def setup_routing_fees(route, msat): |
50 | 58 | route_set_msat(r, msat) |
51 | 59 | r["delay"] = delay |
52 | 60 | channels = plugin.rpc.listpeerchannels(route[-2]["id"]).get("channels") |
53 | | - ch = next(c["updates"]["remote"] for c in channels if c["short_channel_id"] == r["channel"] or c["alias"].get("remote") == r["channel"]) |
| 61 | + ch = next( |
| 62 | + c["updates"]["remote"] |
| 63 | + for c in channels |
| 64 | + if c["short_channel_id"] == r["channel"] |
| 65 | + or c["alias"].get("remote") == r["channel"] |
| 66 | + ) |
54 | 67 | fee = Millisatoshi(ch["fee_base_msat"]) |
55 | 68 | # BOLT #7 requires fee >= fee_base_msat + ( amount_to_forward * fee_proportional_millionths / 1000000 ) |
56 | 69 | fee += ( |
@@ -355,10 +368,22 @@ def rebalance( |
355 | 368 | my_node_id = plugin.getinfo.get("id") |
356 | 369 | outgoing_node_id = peer_from_scid(outgoing_scid, my_node_id, payload) |
357 | 370 | incoming_node_id = peer_from_scid(incoming_scid, my_node_id, payload) |
358 | | - out_aliases = get_channel(payload, outgoing_node_id, outgoing_scid, True).get("alias") |
359 | | - out_alias = out_aliases.get("local") if (out_aliases and out_aliases.get("local")) else outgoing_scid |
360 | | - in_aliases = get_channel(payload, incoming_node_id, incoming_scid, True).get("alias") |
361 | | - in_alias = in_aliases.get("remote") if (in_aliases and in_aliases.get("remote")) else incoming_scid |
| 371 | + out_aliases = get_channel(payload, outgoing_node_id, outgoing_scid, True).get( |
| 372 | + "alias" |
| 373 | + ) |
| 374 | + out_alias = ( |
| 375 | + out_aliases.get("local") |
| 376 | + if (out_aliases and out_aliases.get("local")) |
| 377 | + else outgoing_scid |
| 378 | + ) |
| 379 | + in_aliases = get_channel(payload, incoming_node_id, incoming_scid, True).get( |
| 380 | + "alias" |
| 381 | + ) |
| 382 | + in_alias = ( |
| 383 | + in_aliases.get("remote") |
| 384 | + if (in_aliases and in_aliases.get("remote")) |
| 385 | + else incoming_scid |
| 386 | + ) |
362 | 387 | out_ours, out_total = amounts_from_scid(outgoing_scid) |
363 | 388 | in_ours, in_total = amounts_from_scid(incoming_scid) |
364 | 389 |
|
|
0 commit comments