mirror of
https://github.com/v2fly/v2ray-core.git
synced 2026-04-18 11:39:11 -04:00
move json config into a separate package
This commit is contained in:
81
main/json/config_json.go
Normal file
81
main/json/config_json.go
Normal file
@@ -0,0 +1,81 @@
|
||||
package json
|
||||
|
||||
//go:generate go run $GOPATH/src/v2ray.com/core/common/errors/errorgen/main.go -pkg json -path Main,Json
|
||||
|
||||
import (
|
||||
"context"
|
||||
"io"
|
||||
"os"
|
||||
"os/exec"
|
||||
|
||||
"v2ray.com/core"
|
||||
"v2ray.com/core/common"
|
||||
"v2ray.com/core/common/platform"
|
||||
"v2ray.com/core/common/signal"
|
||||
)
|
||||
|
||||
type logWriter struct{}
|
||||
|
||||
func (*logWriter) Write(b []byte) (int, error) {
|
||||
n, err := os.Stderr.Write(b)
|
||||
if err == nil {
|
||||
os.Stderr.WriteString(platform.LineSeparator())
|
||||
}
|
||||
return n, err
|
||||
}
|
||||
|
||||
func jsonToProto(input io.Reader) (*core.Config, error) {
|
||||
v2ctl := platform.GetToolLocation("v2ctl")
|
||||
if _, err := os.Stat(v2ctl); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
cmd := exec.Command(v2ctl, "config")
|
||||
cmd.Stdin = input
|
||||
cmd.Stderr = &logWriter{}
|
||||
cmd.SysProcAttr = getSysProcAttr()
|
||||
|
||||
stdoutReader, err := cmd.StdoutPipe()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer stdoutReader.Close()
|
||||
|
||||
if err := cmd.Start(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
var config *core.Config
|
||||
|
||||
loadTask := signal.ExecuteAsync(func() error {
|
||||
c, err := core.LoadConfig("protobuf", "", stdoutReader)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
config = c
|
||||
return nil
|
||||
})
|
||||
|
||||
waitTask := signal.ExecuteAsync(func() error {
|
||||
return cmd.Wait()
|
||||
})
|
||||
|
||||
if err := signal.ErrorOrFinish2(context.Background(), loadTask, waitTask); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return config, nil
|
||||
}
|
||||
|
||||
func init() {
|
||||
common.Must(core.RegisterConfigLoader(&core.ConfigFormat{
|
||||
Name: "JSON",
|
||||
Extension: []string{"json"},
|
||||
Loader: func(input io.Reader) (*core.Config, error) {
|
||||
config, err := jsonToProto(input)
|
||||
if err != nil {
|
||||
return nil, newError("failed to execute v2ctl to convert config file.").Base(err).AtWarning()
|
||||
}
|
||||
return config, nil
|
||||
},
|
||||
}))
|
||||
}
|
||||
9
main/json/config_json_other.go
Normal file
9
main/json/config_json_other.go
Normal file
@@ -0,0 +1,9 @@
|
||||
// +build !windows
|
||||
|
||||
package json
|
||||
|
||||
import "syscall"
|
||||
|
||||
func getSysProcAttr() *syscall.SysProcAttr {
|
||||
return nil
|
||||
}
|
||||
11
main/json/config_json_windows.go
Normal file
11
main/json/config_json_windows.go
Normal file
@@ -0,0 +1,11 @@
|
||||
// +build windows
|
||||
|
||||
package json
|
||||
|
||||
import "syscall"
|
||||
|
||||
func getSysProcAttr() *syscall.SysProcAttr {
|
||||
return &syscall.SysProcAttr{
|
||||
HideWindow: true,
|
||||
}
|
||||
}
|
||||
5
main/json/errors.generated.go
Normal file
5
main/json/errors.generated.go
Normal file
@@ -0,0 +1,5 @@
|
||||
package json
|
||||
|
||||
import "v2ray.com/core/common/errors"
|
||||
|
||||
func newError(values ...interface{}) *errors.Error { return errors.New(values...).Path("Main", "Json") }
|
||||
Reference in New Issue
Block a user