mirror of https://github.com/rkfg/regolancer
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
99 lines
3.4 KiB
Go
99 lines
3.4 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/lightningnetwork/lnd/lnrpc"
|
|
"github.com/mattn/go-runewidth"
|
|
)
|
|
|
|
func printBooleanOption(name string, value bool) {
|
|
v := "disabled"
|
|
if value {
|
|
v = "enabled"
|
|
}
|
|
fmt.Printf("%s: %s\n", name, hiWhiteColor(v))
|
|
}
|
|
|
|
func (r *regolancer) printChannelInfo(ctx context.Context, channel *lnrpc.Channel) error {
|
|
nodeInfo, err := r.getNodeInfo(ctx, channel.RemotePubkey)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
alias := runewidth.FillRight(runewidth.Truncate(nodeInfo.Node.Alias, 25, ""), 25)
|
|
balance := runewidth.FillRight(strings.Repeat("|", int(channel.LocalBalance*15/channel.Capacity)), 15)
|
|
balancePct := channel.LocalBalance * 100 / channel.Capacity
|
|
fmt.Printf("%s [%s] %d%% ", alias, cyanColor(balance), balancePct)
|
|
return nil
|
|
}
|
|
|
|
func (r *regolancer) info(ctx context.Context) error {
|
|
fromIdx := 0
|
|
toIdx := 0
|
|
sep := strings.Repeat("—", 98)
|
|
fmt.Printf("%s\nFrom %s channels %33s To %s channels\n%s\n", sep, hiWhiteColor(len(r.fromChannels)), "", hiWhiteColor(len(r.toChannels)), sep)
|
|
for {
|
|
if fromIdx < len(r.fromChannels) {
|
|
channel := r.fromChannels[fromIdx]
|
|
err := r.printChannelInfo(ctx, channel)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
fromIdx++
|
|
} else {
|
|
fmt.Print(strings.Repeat(" ", 51))
|
|
}
|
|
if toIdx < len(r.toChannels) {
|
|
channel := r.toChannels[toIdx]
|
|
err := r.printChannelInfo(ctx, channel)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
toIdx++
|
|
}
|
|
fmt.Println()
|
|
if fromIdx >= len(r.fromChannels) && toIdx >= len(r.toChannels) {
|
|
break
|
|
}
|
|
}
|
|
fmt.Println(sep)
|
|
fmt.Printf("Min amount: %s sat\n", formatAmt(params.MinAmount))
|
|
if params.Amount > 0 {
|
|
fmt.Printf("Amount: %s sat\n", formatAmt(params.Amount))
|
|
} else {
|
|
if params.RelAmountFrom > 0 {
|
|
fmt.Printf("Relative amount from: %s%%\n", formatAmt(int64(params.RelAmountFrom*100)))
|
|
}
|
|
if params.RelAmountTo > 0 {
|
|
fmt.Printf("Relative amount to: %s%%\n", formatAmt(int64(params.RelAmountTo*100)))
|
|
}
|
|
}
|
|
if params.FeeLimitPPM > 0 {
|
|
fmt.Printf("Max fee: %s ppm", formatAmt(int64(params.FeeLimitPPM)))
|
|
} else if params.EconRatio > 0 {
|
|
fmt.Printf("Max fee: %s%% of target channel ppm", formatAmt(int64(params.EconRatio*100)))
|
|
if params.EconRatioMaxPPM > 0 {
|
|
fmt.Printf(" (but <= %s ppm)", formatAmt(int64(params.EconRatioMaxPPM)))
|
|
}
|
|
}
|
|
fmt.Println()
|
|
if params.ExcludeChannelAge != 0 {
|
|
fmt.Printf("Channel age needs to be >= %s blocks\n", hiWhiteColor(params.ExcludeChannelAge))
|
|
}
|
|
fmt.Printf("Fail tolerance: %s ppm\n", formatAmt(int64(params.FailTolerance)))
|
|
printBooleanOption("Rapid rebalance", params.AllowRapidRebalance)
|
|
printBooleanOption("Lost profit accounting", params.LostProfit)
|
|
if params.ProbeSteps > 0 {
|
|
fmt.Printf("Probing steps: %s\n", hiWhiteColor(params.ProbeSteps))
|
|
}
|
|
fmt.Printf("Node cache size: %s records, life time: %s days %s hours %s minutes\n", hiWhiteColor(len(r.nodeCache)), hiWhiteColor(params.NodeCacheLifetime/1440), hiWhiteColor(params.NodeCacheLifetime%1440/60), hiWhiteColor(params.NodeCacheLifetime%60))
|
|
printBooleanOption("Show node cache hits", params.NodeCacheInfo)
|
|
fmt.Printf("Total rebalance timeout: %s hours %s minutes\n", hiWhiteColor(params.TimeoutRebalance/60), hiWhiteColor(params.TimeoutRebalance%60))
|
|
fmt.Printf("Single attempt timeout: %s minutes\n", hiWhiteColor(params.TimeoutAttempt))
|
|
fmt.Printf("Info query timeout: %s seconds\n", hiWhiteColor(params.TimeoutInfo))
|
|
fmt.Printf("Route query timeout: %s seconds\n", hiWhiteColor(params.TimeoutRoute))
|
|
return nil
|
|
}
|