From 5f6166435c5106cf4c3920c0636fa1bc3e02c1ca Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ra=C3=BAl=20Kripalani?= Date: Thu, 12 Aug 2021 11:15:00 +0100 Subject: [PATCH] make lotus-miner net commands hit markets subsystem. --- cli/cmd.go | 2 +- cmd/lotus-miner/main.go | 19 +++++++++++++++++-- 2 files changed, 18 insertions(+), 3 deletions(-) diff --git a/cli/cmd.go b/cli/cmd.go index 7e4a7636c..0731695a1 100644 --- a/cli/cmd.go +++ b/cli/cmd.go @@ -58,7 +58,7 @@ var GetMarketsAPI = cliutil.GetMarketsAPI var GetWorkerAPI = cliutil.GetWorkerAPI var CommonCommands = []*cli.Command{ - NetCmd, + // NetCmd: no longer a common command, since lotus-miner nodes without a markets subsystem no longer run a libp2p node AuthCmd, LogCmd, WaitApiCmd, diff --git a/cmd/lotus-miner/main.go b/cmd/lotus-miner/main.go index 2916fce1f..9cee61b03 100644 --- a/cmd/lotus-miner/main.go +++ b/cmd/lotus-miner/main.go @@ -5,16 +5,17 @@ import ( "fmt" "github.com/fatih/color" - cliutil "github.com/filecoin-project/lotus/cli/util" logging "github.com/ipfs/go-log/v2" "github.com/urfave/cli/v2" "go.opencensus.io/trace" "golang.org/x/xerrors" "github.com/filecoin-project/go-address" + "github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/build" lcli "github.com/filecoin-project/lotus/cli" + cliutil "github.com/filecoin-project/lotus/cli/util" "github.com/filecoin-project/lotus/lib/lotuslog" "github.com/filecoin-project/lotus/lib/tracing" "github.com/filecoin-project/lotus/node/repo" @@ -78,6 +79,20 @@ func main() { } } + // adapt the Net* commands to always hit the node running the markets + // subsystem, as that is the only one that runs a libp2p node. + netCmd := *lcli.NetCmd // make a copy. + prev := netCmd.Before + netCmd.Before = func(c *cli.Context) error { + if prev != nil { + if err := prev(c); err != nil { + return err + } + } + c.App.Metadata["repoType"] = repo.Markets + return nil + } + app := &cli.App{ Name: "lotus-miner", Usage: "Filecoin decentralized storage network miner", @@ -120,7 +135,7 @@ func main() { }, cliutil.FlagVeryVerbose, }, - Commands: append(local, lcli.CommonCommands...), + Commands: append(local, append(lcli.CommonCommands, &netCmd)...), Before: func(c *cli.Context) error { // this command is explicitly called on markets, inform // common commands by overriding the repoType.