Shed: Add a util to list terminated deals
This commit is contained in:
parent
dc26f3bd74
commit
d7528557df
@ -65,6 +65,7 @@ func main() {
|
||||
fr32Cmd,
|
||||
chainCmd,
|
||||
balancerCmd,
|
||||
terminationsCmd,
|
||||
}
|
||||
|
||||
app := &cli.App{
|
||||
|
173
cmd/lotus-shed/terminations.go
Normal file
173
cmd/lotus-shed/terminations.go
Normal file
@ -0,0 +1,173 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"context"
|
||||
"fmt"
|
||||
"io"
|
||||
|
||||
"github.com/filecoin-project/lotus/chain/types"
|
||||
|
||||
"github.com/filecoin-project/lotus/chain/actors/builtin/market"
|
||||
|
||||
"github.com/filecoin-project/lotus/chain/actors"
|
||||
"github.com/filecoin-project/lotus/chain/actors/adt"
|
||||
"github.com/filecoin-project/lotus/chain/actors/builtin/miner"
|
||||
"github.com/filecoin-project/lotus/chain/consensus/filcns"
|
||||
"github.com/filecoin-project/lotus/chain/state"
|
||||
"github.com/filecoin-project/lotus/chain/store"
|
||||
"github.com/filecoin-project/lotus/node/repo"
|
||||
miner2 "github.com/filecoin-project/specs-actors/actors/builtin/miner"
|
||||
"github.com/ipfs/go-cid"
|
||||
cbor "github.com/ipfs/go-ipld-cbor"
|
||||
"github.com/urfave/cli/v2"
|
||||
)
|
||||
|
||||
var terminationsCmd = &cli.Command{
|
||||
Name: "terminations",
|
||||
Description: "Lists terminated deals from the past 2 days",
|
||||
Flags: []cli.Flag{
|
||||
&cli.StringFlag{
|
||||
Name: "repo",
|
||||
Value: "~/.lotus",
|
||||
},
|
||||
},
|
||||
Action: func(cctx *cli.Context) error {
|
||||
ctx := context.TODO()
|
||||
|
||||
if !cctx.Args().Present() {
|
||||
return fmt.Errorf("must pass block cid")
|
||||
}
|
||||
|
||||
blkCid, err := cid.Decode(cctx.Args().First())
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to parse input: %w", err)
|
||||
}
|
||||
|
||||
fsrepo, err := repo.NewFS(cctx.String("repo"))
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
lkrepo, err := fsrepo.Lock(repo.FullNode)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
defer lkrepo.Close() //nolint:errcheck
|
||||
|
||||
bs, err := lkrepo.Blockstore(ctx, repo.UniversalBlockstore)
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to open blockstore: %w", err)
|
||||
}
|
||||
|
||||
defer func() {
|
||||
if c, ok := bs.(io.Closer); ok {
|
||||
if err := c.Close(); err != nil {
|
||||
log.Warnf("failed to close blockstore: %s", err)
|
||||
}
|
||||
}
|
||||
}()
|
||||
|
||||
mds, err := lkrepo.Datastore(context.Background(), "/metadata")
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
cs := store.NewChainStore(bs, bs, mds, filcns.Weight, nil)
|
||||
defer cs.Close() //nolint:errcheck
|
||||
|
||||
cst := cbor.NewCborStore(bs)
|
||||
store := adt.WrapStore(ctx, cst)
|
||||
|
||||
blk, err := cs.GetBlock(blkCid)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
minerCode, err := miner.GetActorCodeID(actors.Version6)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for i := 0; i < 2880*2; i++ {
|
||||
pts, err := cs.LoadTipSet(types.NewTipSetKey(blk.Parents...))
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
blk = pts.Blocks()[0]
|
||||
|
||||
msgs, err := cs.MessagesForTipset(pts)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for _, v := range msgs {
|
||||
msg := v.VMMessage()
|
||||
if msg.Method != miner.Methods.TerminateSectors {
|
||||
continue
|
||||
}
|
||||
|
||||
tree, err := state.LoadStateTree(cst, blk.ParentStateRoot)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
minerAct, err := tree.GetActor(msg.To)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if minerAct.Code != minerCode {
|
||||
continue
|
||||
}
|
||||
|
||||
minerSt, err := miner.Load(store, minerAct)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
marketAct, err := tree.GetActor(market.Address)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
marketSt, err := market.Load(store, marketAct)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
proposals, err := marketSt.Proposals()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
var termParams miner2.TerminateSectorsParams
|
||||
err = termParams.UnmarshalCBOR(bytes.NewBuffer(msg.Params))
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for _, t := range termParams.Terminations {
|
||||
sectors, err := minerSt.LoadSectors(&t.Sectors)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
for _, sector := range sectors {
|
||||
for _, deal := range sector.DealIDs {
|
||||
prop, find, err := proposals.Get(deal)
|
||||
if err != nil || !find {
|
||||
return err
|
||||
}
|
||||
fmt.Printf("%s, %d, %d, %s, %s\n", msg.To, sector.SectorNumber, deal, prop.PieceCID, prop.Label)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
},
|
||||
}
|
Loading…
Reference in New Issue
Block a user