mirror of https://github.com/guggero/chantools
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.
100 lines
2.8 KiB
Go
100 lines
2.8 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/hex"
|
|
"fmt"
|
|
"path"
|
|
|
|
"github.com/davecgh/go-spew/spew"
|
|
"github.com/guggero/chantools/dump"
|
|
"github.com/lightningnetwork/lnd/channeldb"
|
|
"github.com/lightningnetwork/lnd/input"
|
|
)
|
|
|
|
type dumpChannelsCommand struct {
|
|
ChannelDB string `long:"channeldb" description:"The lnd channel.db file to dump the channels from."`
|
|
}
|
|
|
|
func (c *dumpChannelsCommand) Execute(_ []string) error {
|
|
setupChainParams(cfg)
|
|
|
|
// Check that we have a channel DB.
|
|
if c.ChannelDB == "" {
|
|
return fmt.Errorf("channel DB is required")
|
|
}
|
|
db, err := channeldb.Open(
|
|
path.Dir(c.ChannelDB), channeldb.OptionSetSyncFreelist(true),
|
|
channeldb.OptionReadOnly(true),
|
|
)
|
|
if err != nil {
|
|
return fmt.Errorf("error opening rescue DB: %v", err)
|
|
}
|
|
return dumpChannelInfo(db)
|
|
}
|
|
|
|
func dumpChannelInfo(chanDb *channeldb.DB) error {
|
|
channels, err := chanDb.FetchAllChannels()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
dumpChannels := make([]dump.OpenChannel, len(channels))
|
|
for idx, channel := range channels {
|
|
var buf bytes.Buffer
|
|
if channel.FundingTxn != nil {
|
|
err = channel.FundingTxn.Serialize(&buf)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
revPreimage, err := channel.RevocationProducer.AtIndex(
|
|
channel.LocalCommitment.CommitHeight,
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
perCommitPoint := input.ComputeCommitmentPoint(revPreimage[:])
|
|
|
|
dumpChannels[idx] = dump.OpenChannel{
|
|
ChanType: channel.ChanType,
|
|
ChainHash: channel.ChainHash,
|
|
FundingOutpoint: channel.FundingOutpoint.String(),
|
|
ShortChannelID: channel.ShortChannelID,
|
|
IsPending: channel.IsPending,
|
|
IsInitiator: channel.IsInitiator,
|
|
ChanStatus: channel.ChanStatus(),
|
|
FundingBroadcastHeight: channel.FundingBroadcastHeight,
|
|
NumConfsRequired: channel.NumConfsRequired,
|
|
ChannelFlags: channel.ChannelFlags,
|
|
IdentityPub: dump.PubKeyToString(
|
|
channel.IdentityPub,
|
|
),
|
|
Capacity: channel.Capacity,
|
|
TotalMSatSent: channel.TotalMSatSent,
|
|
TotalMSatReceived: channel.TotalMSatReceived,
|
|
PerCommitPoint: dump.PubKeyToString(perCommitPoint),
|
|
LocalChanCfg: dump.ToChannelConfig(
|
|
chainParams, channel.LocalChanCfg,
|
|
),
|
|
RemoteChanCfg: dump.ToChannelConfig(
|
|
chainParams, channel.RemoteChanCfg,
|
|
),
|
|
LocalCommitment: channel.LocalCommitment,
|
|
RemoteCommitment: channel.RemoteCommitment,
|
|
RemoteCurrentRevocation: dump.PubKeyToString(
|
|
channel.RemoteCurrentRevocation,
|
|
),
|
|
RemoteNextRevocation: dump.PubKeyToString(
|
|
channel.RemoteNextRevocation,
|
|
),
|
|
FundingTxn: hex.EncodeToString(buf.Bytes()),
|
|
LocalShutdownScript: channel.LocalShutdownScript,
|
|
RemoteShutdownScript: channel.RemoteShutdownScript,
|
|
}
|
|
}
|
|
|
|
spew.Dump(dumpChannels)
|
|
return nil
|
|
}
|