mirror of
https://github.com/ipfs/kubo.git
synced 2025-06-23 05:35:58 +08:00
commands: Made PostRun signature match Run
This commit is contained in:
@ -356,7 +356,7 @@ func callCommand(ctx context.Context, req cmds.Request, root *cmds.Command, cmd
|
|||||||
}
|
}
|
||||||
|
|
||||||
if cmd.PostRun != nil {
|
if cmd.PostRun != nil {
|
||||||
cmd.PostRun(res)
|
cmd.PostRun(req, res)
|
||||||
}
|
}
|
||||||
|
|
||||||
return res, nil
|
return res, nil
|
||||||
|
@ -47,7 +47,7 @@ type Command struct {
|
|||||||
Arguments []Argument
|
Arguments []Argument
|
||||||
PreRun func(req Request) error
|
PreRun func(req Request) error
|
||||||
Run Function
|
Run Function
|
||||||
PostRun func(res Response)
|
PostRun Function
|
||||||
Marshalers map[EncodingType]Marshaler
|
Marshalers map[EncodingType]Marshaler
|
||||||
Helptext HelpText
|
Helptext HelpText
|
||||||
|
|
||||||
|
@ -104,7 +104,7 @@ remains to be implemented.
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
},
|
},
|
||||||
PostRun: func(res cmds.Response) {
|
PostRun: func(req cmds.Request, res cmds.Response) {
|
||||||
outChan, ok := res.Output().(<-chan interface{})
|
outChan, ok := res.Output().(<-chan interface{})
|
||||||
if !ok {
|
if !ok {
|
||||||
res.SetError(u.ErrCast(), cmds.ErrNormal)
|
res.SetError(u.ErrCast(), cmds.ErrNormal)
|
||||||
@ -112,14 +112,14 @@ remains to be implemented.
|
|||||||
}
|
}
|
||||||
res.SetOutput(nil)
|
res.SetOutput(nil)
|
||||||
|
|
||||||
quiet, _, err := res.Request().Option("quiet").Bool()
|
quiet, _, err := req.Option("quiet").Bool()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
res.SetError(u.ErrCast(), cmds.ErrNormal)
|
res.SetError(u.ErrCast(), cmds.ErrNormal)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
size := int64(0)
|
size := int64(0)
|
||||||
s, found := res.Request().Values()["size"]
|
s, found := req.Values()["size"]
|
||||||
if found {
|
if found {
|
||||||
size = s.(int64)
|
size = s.(int64)
|
||||||
}
|
}
|
||||||
|
@ -44,7 +44,7 @@ it contains.
|
|||||||
reader := io.MultiReader(readers...)
|
reader := io.MultiReader(readers...)
|
||||||
res.SetOutput(reader)
|
res.SetOutput(reader)
|
||||||
},
|
},
|
||||||
PostRun: func(res cmds.Response) {
|
PostRun: func(req cmds.Request, res cmds.Response) {
|
||||||
if res.Length() < progressBarMinSize {
|
if res.Length() < progressBarMinSize {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user