add cmd for message select (#4432)

* add cmd for message select

* fix lint

app/submodule/chain/actor_api.go

@@ -29,7 +29,7 @@ func (actorAPI *ActorAPI) StateGetActor(ctx context.Context, actor address.Addre
 		return nil, xerrors.Errorf("loading tipset %s: %v", tsk, err)
 	}
 
-	view, err := actorAPI.chain.ChainReader.StateView(ts)
+	view, err := actorAPI.chain.ChainReader.ParentStateView(ts)
 	if err != nil {
 		return nil, xerrors.Errorf("loading tipset %s: %v", tsk, err)
 	}

cmd/mpool.go

@@ -36,6 +36,7 @@ var mpoolCmd = &cmds.Command{
 		"gas-perf": mpoolGasPerfCmd,
 		"publish":  mpoolPublish,
 		"delete":   mpoolDeleteAddress,
+		"select":   mpoolSelect,
 	},
 }
 
@@ -69,6 +70,35 @@ var mpoolDeleteAddress = &cmds.Command{
 	},
 }
 
+var mpoolSelect = &cmds.Command{
+	Helptext: cmds.HelpText{
+		Tagline:          "select",
+		ShortDescription: "select message from mpool",
+	},
+	Options: []cmds.Option{
+		cmds.FloatOption("quality", "optionally specify the wallet for publish message").WithDefault(0.5),
+	},
+	Run: func(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment) error {
+		ctx := context.TODO()
+
+		quality, _ := req.Options["quality"].(float64)
+		head, err := env.(*node.Env).ChainAPI.ChainHead(ctx)
+		if err != nil {
+			return err
+		}
+		msgs, err := env.(*node.Env).MessagePoolAPI.MpoolSelect(ctx, head.Key(), quality)
+		if err != nil {
+			return err
+		}
+		selectMsg, err := json.MarshalIndent(msgs, " ", "\t")
+		if err != nil {
+			return err
+		}
+
+		return printOneString(re, string(selectMsg))
+	},
+}
+
 var mpoolPublish = &cmds.Command{
 	Helptext: cmds.HelpText{
 		Tagline:          "publish",