mirror of
https://github.com/ipfs/kubo.git
synced 2025-06-30 09:59:13 +08:00
cmd/ipfs: Load config and put in request context
This commit is contained in:

committed by
Juan Batiz-Benet

parent
7d53e736cf
commit
2419ffdb2d
@ -24,7 +24,7 @@ var Daemon = &cmds.Command{
|
||||
}
|
||||
|
||||
func daemonFunc(req cmds.Request, res cmds.Response) {
|
||||
configPath, err := getConfigPath(req)
|
||||
configPath, err := getConfigRoot(req)
|
||||
if err != nil {
|
||||
res.SetError(err, cmds.ErrNormal)
|
||||
return
|
||||
|
@ -67,6 +67,22 @@ func main() {
|
||||
}
|
||||
}
|
||||
|
||||
configPath, err := getConfigRoot(options)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
os.Exit(1)
|
||||
}
|
||||
|
||||
conf, err := getConfig(configPath)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
os.Exit(1)
|
||||
}
|
||||
|
||||
ctx := req.Context()
|
||||
ctx.ConfigRoot = configPath
|
||||
ctx.Config = conf
|
||||
|
||||
var res cmds.Response
|
||||
if root == Root {
|
||||
res = root.Call(req)
|
||||
@ -74,12 +90,6 @@ func main() {
|
||||
} else {
|
||||
local := true
|
||||
|
||||
configPath, err := getConfigPath(options)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
os.Exit(1)
|
||||
}
|
||||
|
||||
lockFilePath, err := config.Path(configPath, DaemonLockFile)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
@ -138,7 +148,7 @@ func getOptions(req cmds.Request, root *cmds.Command) (cmds.Request, error) {
|
||||
return tempReq, nil
|
||||
}
|
||||
|
||||
func getConfigPath(req cmds.Request) (string, error) {
|
||||
func getConfigRoot(req cmds.Request) (string, error) {
|
||||
if opt, found := req.Option("config"); found {
|
||||
return opt.(string), nil
|
||||
}
|
||||
|
Reference in New Issue
Block a user