colin/nix-files
1
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

servo: clightning-sane: factor "loop" action into own subroutine

Browse Source
This commit is contained in:
Colin 2024-01-12 21:28:20 +00:00
parent 5c649ff216
commit 91847a9a8e
1 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
hosts/by-name/servo/services/cryptocurrencies/clightning-sane/clightning-sane
View File

@ -404,6 +404,24 @@ def show_status(rpc: RpcHelper, full: bool=False):
else:
print(ch.to_str(with_scid=True, with_bal_ratio=True, with_cost=True, with_ppm_theirs=True, with_ppm_mine=full, with_peer_id=full))
def balance_loop(rpc: RpcHelper, out: str, in_: str, min_msat: int, max_msat: int, max_tx: int):
balancer = Balancer(rpc)
bounds = TxBounds(min_msat=min_msat, max_msat=max_msat)
asked_to_route = bounds.max_msat
total_routed = 0
for i in range(max_tx):
bounds.max_msat = min(bounds.max_msat, asked_to_route - total_routed)
if not bounds.is_satisfiable(): break
amt_balanced = balancer.balance_once_with_retries(out, in_, bounds)
total_routed += amt_balanced
if amt_balanced == 0: break
logger.info(f"rebalanced {amt_balanced} (total: {total_routed} of {asked_to_route})")
bounds.max_msat = min(bounds.max_msat, amt_balanced)
logger.info(f"rebalanced {total_routed} of {asked_to_route}")
def main():
logging.basicConfig()
logger.setLevel(logging.INFO)
@ -435,25 +453,7 @@ def main():
show_status(rpc, full=args.full)
if args.action == "loop":
balancer = Balancer(rpc)
bounds = TxBounds(
min_msat = int(args.min_msat),
max_msat = int(args.max_msat),
)
asked_to_route = bounds.max_msat
total_routed = 0
for i in range(int(args.max_tx)):
bounds.max_msat = min(bounds.max_msat, asked_to_route - total_routed)
if not bounds.is_satisfiable(): break
amt_balanced = balancer.balance_once_with_retries(args.out, args.in_, bounds)
total_routed += amt_balanced
if amt_balanced == 0: break
logger.info(f"rebalanced {amt_balanced} (total: {total_routed} of {asked_to_route})")
bounds.max_msat = min(bounds.max_msat, amt_balanced)
logger.info(f"rebalanced {total_routed} of {asked_to_route}")
balance_loop(rpc, out=args.out, in_=args.in_, min_msat=int(args.min_msat), max_msat=int(args.max_msat), max_tx=int(args.max_tx))
if __name__ == '__main__':
main()