lzhr/v2fly
1
0
Fork 0
mirror of https://github.com/v2fly/v2ray-core.git synced 2024-06-09 09:20:45 +00:00
Code Issues Releases Wiki Activity

Merge pull request #351 from v2fly/dev-fix-mutijson-dep

Browse Source 
Fix json parsing dependency introduced by mutijson config
This commit is contained in:
Xiaokang Wang 2020-10-26 15:44:58 +00:00 committed by GitHub
commit 3684dc15de
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
main/confloader/confloader.go
View File

@ -6,7 +6,7 @@ import (
) )
type configFileLoader func(string) (io.Reader, error) type configFileLoader func(string) (io.Reader, error)
type extconfigLoader func([]string) (io.Reader, error) type extconfigLoader func([]string, io.Reader) (io.Reader, error)
var ( var (
EffectiveConfigFileLoader configFileLoader EffectiveConfigFileLoader configFileLoader
@ -25,10 +25,10 @@ func LoadConfig(file string) (io.Reader, error) {
// LoadExtConfig calls v2ctl to handle multiple config // LoadExtConfig calls v2ctl to handle multiple config
// the actual work also in external module // the actual work also in external module
func LoadExtConfig(files []string) (io.Reader, error) { func LoadExtConfig(files []string, reader io.Reader) (io.Reader, error) {
if EffectiveExtConfigLoader == nil { if EffectiveExtConfigLoader == nil {
return nil, newError("external config module not loaded").AtError() return nil, newError("external config module not loaded").AtError()
} }
return EffectiveExtConfigLoader(files) return EffectiveExtConfigLoader(files, reader)
} }

4
main/confloader/external/external.go vendored
View File

@ -72,8 +72,8 @@ func FetchHTTPContent(target string) ([]byte, error) {
return content, nil return content, nil
} }
func ExtConfigLoader(files []string) (io.Reader, error) { func ExtConfigLoader(files []string, reader io.Reader) (io.Reader, error) {
buf, err := ctlcmd.Run(append([]string{"config"}, files...), os.Stdin) buf, err := ctlcmd.Run(append([]string{"config"}, files...), reader)
if err != nil { if err != nil {
return nil, err return nil, err
} }

12
main/json/config_json.go
View File

@ -4,11 +4,11 @@ package json
import ( import (
"io" "io"
"os"
"v2ray.com/core" "v2ray.com/core"
"v2ray.com/core/common" "v2ray.com/core/common"
"v2ray.com/core/common/cmdarg" "v2ray.com/core/common/cmdarg"
"v2ray.com/core/infra/conf/serial"
"v2ray.com/core/main/confloader" "v2ray.com/core/main/confloader"
) )
@ -19,15 +19,19 @@ func init() {
Loader: func(input interface{}) (*core.Config, error) { Loader: func(input interface{}) (*core.Config, error) {
switch v := input.(type) { switch v := input.(type) {
case cmdarg.Arg: case cmdarg.Arg:
r, err := confloader.LoadExtConfig(v) r, err := confloader.LoadExtConfig(v, os.Stdin)
if err != nil { if err != nil {
return nil, newError("failed to execute v2ctl to convert config file.").Base(err).AtWarning() return nil, newError("failed to execute v2ctl to convert config file.").Base(err).AtWarning()
} }
return core.LoadConfig("protobuf", "", r) return core.LoadConfig("protobuf", "", r)
case io.Reader: case io.Reader:
return serial.LoadJSONConfig(v) r, err := confloader.LoadExtConfig([]string{"stdin:"}, os.Stdin)
if err != nil {
return nil, newError("failed to execute v2ctl to convert config file.").Base(err).AtWarning()
}
return core.LoadConfig("protobuf", "", r)
default: default:
return nil, newError("unknow type") return nil, newError("unknown type")
} }
}, },
})) }))