diff --git a/cli/cmd.go b/cli/cmd.go index c75e639b9..9eff3e541 100644 --- a/cli/cmd.go +++ b/cli/cmd.go @@ -200,7 +200,6 @@ var Commands = []*cli.Command{ authCmd, chainCmd, clientCmd, - createMinerCmd, fetchParamCmd, mpoolCmd, netCmd, diff --git a/cli/createminer.go b/cli/createminer.go deleted file mode 100644 index 4247fe48e..000000000 --- a/cli/createminer.go +++ /dev/null @@ -1,100 +0,0 @@ -package cli - -import ( - "fmt" - "strconv" - - "golang.org/x/xerrors" - "gopkg.in/urfave/cli.v2" - - actors "github.com/filecoin-project/lotus/chain/actors" - address "github.com/filecoin-project/lotus/chain/address" - types "github.com/filecoin-project/lotus/chain/types" - - "github.com/libp2p/go-libp2p-core/peer" -) - -var createMinerCmd = &cli.Command{ - Name: "createminer", - Usage: "Create a new storage market actor", - Action: func(cctx *cli.Context) error { - if cctx.Args().Len() != 4 { - return fmt.Errorf("must pass four arguments: worker address, owner address, sector size, peer ID") - } - - api, closer, err := GetFullNodeAPI(cctx) - if err != nil { - return err - } - defer closer() - - args := cctx.Args().Slice() - - worker, err := address.NewFromString(args[0]) - if err != nil { - return err - } - - owner, err := address.NewFromString(args[1]) - if err != nil { - return err - } - - ssize, err := strconv.ParseUint(args[2], 10, 64) - if err != nil { - return err - } - - pid, err := peer.IDB58Decode(args[3]) - if err != nil { - return err - } - - createMinerArgs := actors.CreateStorageMinerParams{ - Worker: worker, - Owner: owner, - SectorSize: ssize, - PeerID: pid, - } - - ctx := ReqContext(cctx) - addr, err := api.WalletDefaultAddress(ctx) - if err != nil { - return xerrors.Errorf("failed to get default address: %w", err) - } - - params, err := actors.SerializeParams(&createMinerArgs) - if err != nil { - return err - } - - msg := &types.Message{ - To: actors.StoragePowerAddress, - From: addr, - Method: actors.SPAMethods.CreateStorageMiner, - Params: params, - Value: types.NewInt(0), - GasPrice: types.NewInt(0), - GasLimit: types.NewInt(10000), - } - - smsg, err := api.MpoolPushMessage(ctx, msg) - if err != nil { - return xerrors.Errorf("failed to push signed message: %w", err) - } - - mwait, err := api.StateWaitMsg(ctx, smsg.Cid()) - if err != nil { - return xerrors.Errorf("failed waiting for message inclusion: %w", err) - } - - maddr, err := address.NewFromBytes(mwait.Receipt.Return) - if err != nil { - return err - } - - fmt.Printf("new miner address: %s\n", maddr) - - return nil - }, -}