120 lines
1.9 KiB
Go
120 lines
1.9 KiB
Go
package cli
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"gopkg.in/urfave/cli.v2"
|
|
|
|
"github.com/filecoin-project/go-lotus/lib/addrutil"
|
|
)
|
|
|
|
var netCmd = &cli.Command{
|
|
Name: "net",
|
|
Usage: "Manage P2P Network",
|
|
Subcommands: []*cli.Command{
|
|
netPeers,
|
|
netConnect,
|
|
netListen,
|
|
netId,
|
|
},
|
|
}
|
|
|
|
var netPeers = &cli.Command{
|
|
Name: "peers",
|
|
Usage: "Print peers",
|
|
Action: func(cctx *cli.Context) error {
|
|
api, closer, err := GetAPI(cctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer closer()
|
|
ctx := ReqContext(cctx)
|
|
peers, err := api.NetPeers(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, peer := range peers {
|
|
fmt.Println(peer)
|
|
}
|
|
|
|
return nil
|
|
},
|
|
}
|
|
|
|
var netListen = &cli.Command{
|
|
Name: "listen",
|
|
Usage: "List listen addresses",
|
|
Action: func(cctx *cli.Context) error {
|
|
api, closer, err := GetAPI(cctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer closer()
|
|
ctx := ReqContext(cctx)
|
|
|
|
addrs, err := api.NetAddrsListen(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, peer := range addrs.Addrs {
|
|
fmt.Printf("%s/p2p/%s\n", peer, addrs.ID)
|
|
}
|
|
return nil
|
|
},
|
|
}
|
|
|
|
var netConnect = &cli.Command{
|
|
Name: "connect",
|
|
Usage: "Connect to a peer",
|
|
ArgsUsage: "<peer multiaddr>",
|
|
Action: func(cctx *cli.Context) error {
|
|
api, closer, err := GetAPI(cctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer closer()
|
|
ctx := ReqContext(cctx)
|
|
|
|
pis, err := addrutil.ParseAddresses(ctx, cctx.Args().Slice())
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, pi := range pis {
|
|
fmt.Printf("connect %s: ", pi.ID.Pretty())
|
|
err := api.NetConnect(ctx, pi)
|
|
if err != nil {
|
|
fmt.Println("failure")
|
|
return err
|
|
}
|
|
fmt.Println("success")
|
|
}
|
|
|
|
return nil
|
|
},
|
|
}
|
|
|
|
var netId = &cli.Command{
|
|
Name: "id",
|
|
Usage: "Get node identity",
|
|
Action: func(cctx *cli.Context) error {
|
|
api, closer, err := GetAPI(cctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer closer()
|
|
|
|
ctx := ReqContext(cctx)
|
|
|
|
pid, err := api.ID(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
fmt.Println(pid)
|
|
return nil
|
|
},
|
|
}
|