refactor miner info command.
This commit is contained in:
parent
7d6eb250ea
commit
d9c6a32b8e
@ -128,7 +128,6 @@ var AuthApiInfoToken = &cli.Command{
|
|||||||
|
|
||||||
// TODO: Log in audit log when it is implemented
|
// TODO: Log in audit log when it is implemented
|
||||||
|
|
||||||
// WARN: this is unable to tell
|
|
||||||
currentEnv, _ := cliutil.EnvsForRepo(t)
|
currentEnv, _ := cliutil.EnvsForRepo(t)
|
||||||
fmt.Printf("%s=%s:%s\n", currentEnv, string(token), ainfo.Addr)
|
fmt.Printf("%s=%s:%s\n", currentEnv, string(token), ainfo.Addr)
|
||||||
return nil
|
return nil
|
||||||
|
@ -1,30 +0,0 @@
|
|||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"github.com/urfave/cli/v2"
|
|
||||||
)
|
|
||||||
|
|
||||||
var dagstoreCmd = &cli.Command{
|
|
||||||
Name: "dagstore",
|
|
||||||
Usage: "Manage the DAG store",
|
|
||||||
Subcommands: []*cli.Command{
|
|
||||||
dagstoreListShardsCmd,
|
|
||||||
dagstoreGarbageCollectCmd,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
var dagstoreListShardsCmd = &cli.Command{
|
|
||||||
Name: "list-shards",
|
|
||||||
Usage: "List shards known to the DAG store",
|
|
||||||
Action: func(cctx *cli.Context) error {
|
|
||||||
return nil
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
var dagstoreGarbageCollectCmd = &cli.Command{
|
|
||||||
Name: "gc",
|
|
||||||
Usage: "Garbage collect the DAG store",
|
|
||||||
Action: func(cctx *cli.Context) error {
|
|
||||||
return nil
|
|
||||||
},
|
|
||||||
}
|
|
@ -50,7 +50,13 @@ var infoCmd = &cli.Command{
|
|||||||
}
|
}
|
||||||
|
|
||||||
func infoCmdAct(cctx *cli.Context) error {
|
func infoCmdAct(cctx *cli.Context) error {
|
||||||
nodeApi, closer, err := lcli.GetStorageMinerAPI(cctx)
|
minerApi, closer, err := lcli.GetStorageMinerAPI(cctx)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer closer()
|
||||||
|
|
||||||
|
marketsApi, closer, err := lcli.GetMarketsAPI(cctx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@ -64,12 +70,19 @@ func infoCmdAct(cctx *cli.Context) error {
|
|||||||
|
|
||||||
ctx := lcli.ReqContext(cctx)
|
ctx := lcli.ReqContext(cctx)
|
||||||
|
|
||||||
subsystems, err := nodeApi.RuntimeSubsystems(ctx)
|
subsystems, err := minerApi.RuntimeSubsystems(ctx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Println("Enabled subsystems:", subsystems)
|
fmt.Println("Enabled subsystems (from miner API):", subsystems)
|
||||||
|
|
||||||
|
subsystems, err = marketsApi.RuntimeSubsystems(ctx)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Println("Enabled subsystems (from markets API):", subsystems)
|
||||||
|
|
||||||
fmt.Print("Chain: ")
|
fmt.Print("Chain: ")
|
||||||
|
|
||||||
@ -103,18 +116,14 @@ func infoCmdAct(cctx *cli.Context) error {
|
|||||||
|
|
||||||
fmt.Println()
|
fmt.Println()
|
||||||
|
|
||||||
if subsystems.Has(api.SubsystemSectorStorage) {
|
err = handleMiningInfo(ctx, cctx, fullapi, minerApi)
|
||||||
err := handleMiningInfo(ctx, cctx, fullapi, nodeApi)
|
if err != nil {
|
||||||
if err != nil {
|
return err
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if subsystems.Has(api.SubsystemMarkets) {
|
err = handleMarketsInfo(ctx, marketsApi)
|
||||||
err := handleMarketsInfo(ctx, nodeApi)
|
if err != nil {
|
||||||
if err != nil {
|
return err
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
Loading…
Reference in New Issue
Block a user