package main import ( "fmt" "sort" "github.com/filecoin-project/lotus/blockstore" "github.com/filecoin-project/lotus/chain/actors/builtin/miner" "github.com/filecoin-project/lotus/chain/types" lcli "github.com/filecoin-project/lotus/cli" "github.com/filecoin-project/specs-actors/v7/actors/util/adt" cbor "github.com/ipfs/go-ipld-cbor" "github.com/urfave/cli/v2" ) var sectorPreCommitsCmd = &cli.Command{ Name: "precommits-info", Usage: "Print precommits info", Action: func(cctx *cli.Context) error { ctx := lcli.ReqContext(cctx) mapi, closer, err := lcli.GetFullNodeAPI(cctx) if err != nil { return err } defer closer() maddr, err := getActorAddress(ctx, cctx) if err != nil { return err } mact, err := mapi.StateGetActor(ctx, maddr, types.EmptyTSK) if err != nil { return err } store := adt.WrapStore(ctx, cbor.NewCborStore(blockstore.NewAPIBlockstore(mapi))) mst, err := miner.Load(store, mact) if err != nil { return err } preCommitSector := make([]miner.SectorPreCommitOnChainInfo, 0) err = mst.ForEachPrecommittedSector(func(info miner.SectorPreCommitOnChainInfo) error { preCommitSector = append(preCommitSector, info) return err }) less := func(i, j int) bool { return preCommitSector[i].Info.SectorNumber <= preCommitSector[j].Info.SectorNumber } sort.Slice(preCommitSector, less) for _, info := range preCommitSector { fmt.Printf("%s: %s\n", info.Info.SectorNumber, info.PreCommitEpoch) } return nil }, }