cerc-io/lotus
15
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Wire in request context

Browse Source 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
This commit is contained in:
Jakub Sztandera 2019-07-09 14:19:10 +02:00
parent 40d9fbd952
commit 66a67b0633
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
cli/net.go
View File

@ -25,9 +25,9 @@ var netCmd = &cli.Command{
var netPeers = &cli.Command{
Name: "peers",
Usage: "Print peers",
Action: func(ctx *cli.Context) error {
api := getApi(ctx)
fmt.Println(api.NetPeers(context.Background()))
Action: func(cctx *cli.Context) error {
api := getApi(cctx)
fmt.Println(api.NetPeers(reqContext(cctx)))
return nil
},
@ -36,9 +36,9 @@ var netPeers = &cli.Command{
var netListen = &cli.Command{
Name: "listen",
Usage: "List listen addresses",
Action: func(ctx *cli.Context) error {
api := getApi(ctx)
fmt.Println(api.NetAddrsListen(context.Background()))
Action: func(cctx *cli.Context) error {
api := getApi(cctx)
fmt.Println(api.NetAddrsListen(reqContext(cctx)))
return nil
},
@ -47,15 +47,17 @@ var netListen = &cli.Command{
var netConnect = &cli.Command{
Name: "connect",
Usage: "Connect to a peer",
Action: func(ctx *cli.Context) error {
pis, err := parseAddresses(context.Background(), ctx.Args().Slice())
Action: func(cctx *cli.Context) error {
ctx := reqContext(cctx)
api := getApi(cctx)
pis, err := parseAddresses(ctx, cctx.Args().Slice())
if err != nil {
return err
}
api := getApi(ctx)
for _, pi := range pis {
fmt.Printf("connect %s", pi.ID.Pretty())
fmt.Printf("connect %s: ", pi.ID.Pretty())
err := api.NetConnect(context.Background(), pi)
if err != nil {
fmt.Println("failure")