Remove obsolete createminer command
Signed-off-by: Jakub Sztandera <kubuxu@protocol.ai>
This commit is contained in:
parent
cf9edae000
commit
0a78be0935
@ -200,7 +200,6 @@ var Commands = []*cli.Command{
|
|||||||
authCmd,
|
authCmd,
|
||||||
chainCmd,
|
chainCmd,
|
||||||
clientCmd,
|
clientCmd,
|
||||||
createMinerCmd,
|
|
||||||
fetchParamCmd,
|
fetchParamCmd,
|
||||||
mpoolCmd,
|
mpoolCmd,
|
||||||
netCmd,
|
netCmd,
|
||||||
|
@ -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
|
|
||||||
},
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user