feat: proxies: add config load

Author: NullpointerW

go.mod

@@ -7,6 +7,7 @@ require (
 	github.com/ethereum/go-ethereum v1.13.5
 	github.com/spf13/cobra v1.5.0
 	golang.org/x/exp v0.0.0-20230905200255-921286631fa9
+	gopkg.in/yaml.v3 v3.0.1
 )
 
 require (

go.sum

@@ -200,6 +200,8 @@ golang.org/x/tools v0.13.0/go.mod h1:HvlwmtVNQAhOuCjW7xxvovg8wbNq7LwfXh/k7wXUl58
 google.golang.org/protobuf v1.27.1 h1:SnqbnDw1V7RiZcXPx5MEeqPv2s79L9i7BJUlG/+RurQ=
 google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/natefinch/lumberjack.v2 v2.0.0 h1:1Lc07Kr7qY4U2YPouBjpCLxpiyxIVoxqXgkXLknAOE8=
 gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k=
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=

pkg/proxies/shadowsocks/config.go

@@ -0,0 +1,52 @@
+package shadowsocks
+
+import (
+	"github.com/Dreamacro/clash/adapter/outbound"
+	"gopkg.in/yaml.v3"
+	"os"
+	"strconv"
+)
+
+type ProxiesYaml struct {
+	Proxies []Config `yaml:"proxies"`
+}
+
+type Config struct {
+	Server     string         `yaml:"server"`
+	Port       any            `yaml:"port"`
+	Password   string         `yaml:"password"`
+	Cipher     string         `yaml:"cipher"`
+	UDP        bool           `yaml:"udp"`
+	Plugin     string         `yaml:"plugin"`
+	PluginOpts map[string]any `yaml:"plugin-opts"`
+}
+
+func (yamlCfg *ProxiesYaml) Load(fp string) error {
+	b, err := os.ReadFile(fp)
+	if err != nil {
+		return err
+	}
+	err = yaml.Unmarshal(b, yamlCfg)
+	return err
+}
+func (yamlCfg *ProxiesYaml) CovertOption() []outbound.ShadowSocksOption {
+	var ssOps []outbound.ShadowSocksOption
+	for _, p := range yamlCfg.Proxies {
+		var ssOp = outbound.ShadowSocksOption{
+			Name:       "ss",
+			Server:     p.Server,
+			Password:   p.Password,
+			Cipher:     p.Cipher,
+			UDP:        p.UDP,
+			Plugin:     p.Plugin,
+			PluginOpts: p.PluginOpts,
+		}
+		if portStr, ok := p.Port.(string); ok {
+			ssOp.Port, _ = strconv.Atoi(portStr)
+		} else {
+			ssOp.Port = p.Port.(int)
+		}
+		ssOps = append(ssOps, ssOp)
+	}
+	return ssOps
+}

pkg/proxies/shadowsocks/dialer.go

@@ -43,3 +43,17 @@ func (dialer *Dialer) NewConn(_ context.Context, network, addr string) (net.Conn
 	})
 	return conn, err
 }
+
+func NewDialerWithCfg(addrResolver proxies.AddrResolver, config string) (*Dialer, error) {
+	cfg := new(ProxiesYaml)
+	err := cfg.Load(config)
+	if err != nil {
+		return nil, err
+	}
+	nodes := cfg.CovertOption()
+	dl := new(Dialer)
+	dl.nodes = nodes
+	dl.nl = len(nodes)
+	dl.addrResolver = addrResolver
+	return dl, nil
+}

pkg/proxies/shadowsocks/ss_test.go

@@ -78,3 +78,14 @@ func TestSS(t *testing.T) {
 	}
 	fmt.Println(string(b))
 }
+
+func TestProxiesYaml_Load(t *testing.T) {
+	cfg := new(ProxiesYaml)
+	err := cfg.Load("ss.yaml")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	outbounds := cfg.CovertOption()
+	fmt.Println(outbounds)
+}

pkg/proxies/vmess/config.go

@@ -0,0 +1,48 @@
+package vmess
+
+import (
+	"github.com/Dreamacro/clash/adapter/outbound"
+	"gopkg.in/yaml.v3"
+	"os"
+	"strconv"
+)
+
+type ProxiesYaml struct {
+	Proxies []Config `yaml:"proxies"`
+}
+
+type Config struct {
+	Server string `yaml:"server"`
+	Port   any    `yaml:"port"`
+	UUID   string `yaml:"uuid"`
+	Cipher string `yaml:"cipher"`
+	UDP    bool   `yaml:"udp"`
+}
+
+func (yamlCfg *ProxiesYaml) Load(fp string) error {
+	b, err := os.ReadFile(fp)
+	if err != nil {
+		return err
+	}
+	err = yaml.Unmarshal(b, yamlCfg)
+	return err
+}
+func (yamlCfg *ProxiesYaml) CovertOption() []outbound.VmessOption {
+	var vmOps []outbound.VmessOption
+	for _, p := range yamlCfg.Proxies {
+		var vmOp = outbound.VmessOption{
+			Name:   "vmess",
+			Server: p.Server,
+			UUID:   p.UUID,
+			Cipher: p.Cipher,
+			UDP:    p.UDP,
+		}
+		if portStr, ok := p.Port.(string); ok {
+			vmOp.Port, _ = strconv.Atoi(portStr)
+		} else {
+			vmOp.Port = p.Port.(int)
+		}
+		vmOps = append(vmOps, vmOp)
+	}
+	return vmOps
+}

pkg/proxies/vmess/dialer.go

@@ -24,6 +24,19 @@ func NewDialer(addrResolver proxies.AddrResolver, nodes ...outbound.VmessOption)
 	dl.addrResolver = addrResolver
 	return dl
 }
+func NewDialerWithCfg(addrResolver proxies.AddrResolver, config string) (*Dialer, error) {
+	cfg := new(ProxiesYaml)
+	err := cfg.Load(config)
+	if err != nil {
+		return nil, err
+	}
+	nodes := cfg.CovertOption()
+	dl := new(Dialer)
+	dl.nodes = nodes
+	dl.nl = len(nodes)
+	dl.addrResolver = addrResolver
+	return dl, nil
+}
 
 func (dialer *Dialer) NewConn(_ context.Context, network, addr string) (net.Conn, error) {
 	rand.Seed(uint64(time.Now().UnixNano()))

pkg/proxies/vmess/vmess_test.go

@@ -9,7 +9,7 @@ import (
 	"testing"
 )
 
-func TestSS(t *testing.T) {
+func TestVmess(t *testing.T) {
 	dialer := NewDialer(proxies.StringResolver, []outbound.VmessOption{{
 		Name:   "vmess",
 		Server: "sever_host",