op: 优化内存占用

Author: beck-8

proxy/get.go

@@ -17,6 +17,8 @@ import (
 	"gopkg.in/yaml.v3"
 )
 
+var proxyRegex = regexp.MustCompile("(ssr|ss|vmess|trojan|vless|hysteria|hy2|hysteria2)://")
+
 func GetProxies() ([]map[string]any, error) {
 	slog.Info(fmt.Sprintf("当前设置订阅链接数量: %d", len(config.GlobalConfig.SubUrls)))
 
@@ -53,11 +55,10 @@ func GetProxies() ([]map[string]any, error) {
 			var con map[string]any
 			err = yaml.Unmarshal(data, &con)
 			if err != nil {
-				reg, _ := regexp.Compile("(ssr|ss|vmess|trojan|vless|hysteria|hy2|hysteria2)://")
-				if !reg.Match(data) {
+				if !proxyRegex.Match(data) {
 					data = []byte(parser.DecodeBase64(string(data)))
 				}
-				if reg.Match(data) {
+				if proxyRegex.Match(data) {
 					scanner := bufio.NewScanner(strings.NewReader(string(data)))
 					for scanner.Scan() {
 						proxy := scanner.Text()

proxy/parser/vless.go

@@ -4,7 +4,6 @@ import (
 	"fmt"
 	"net/url"
 	"strconv"
-	"strings"
 )
 
 // 将vless格式的节点转换为clash的节点
@@ -18,20 +17,22 @@ func ParseVless(data string) (map[string]any, error) {
 		return nil, fmt.Errorf("不是vless格式")
 	}
 
-	hostPort := strings.Split(parsedURL.Host, ":")
-	if len(hostPort) != 2 {
-		return nil, nil
-	}
-
 	port, err := strconv.Atoi(parsedURL.Port())
 	if err != nil {
 		return nil, fmt.Errorf("格式错误: 端口格式不正确")
 	}
 
 	// 解析参数
 	query := parsedURL.Query()
+	sni := query.Get("sni")
+	path := query.Get("path")
+	host := query.Get("host")
+	pbk := query.Get("pbk")
+	sid := query.Get("sid")
+	fp := query.Get("fp")
+	serviceName := query.Get("serviceName")
 
-	// 构建 clash 格式的代理配置
+	// 构建 clash 格式的代理配置，这里边也加上了URI用到的参数，方便后边解析
 	proxy := map[string]any{
 		"name":               parsedURL.Fragment,
 		"type":               "vless",
@@ -41,33 +42,33 @@ func ParseVless(data string) (map[string]any, error) {
 		"network":            query.Get("type"),
 		"tls":                query.Get("security") != "none",
 		"udp":                query.Get("udp") == "true",
-		"servername":         query.Get("sni"),
+		"servername":         sni,
 		"flow":               query.Get("flow"),
-		"client-fingerprint": query.Get("fp"),
-		"ws-opts": map[string]any{
-			"path": query.Get("path"),
-			"headers": map[string]string{
-				"Host": query.Get("host"),
-			},
-		},
-		"reality-opts": map[string]string{
-			"public-key": query.Get("pbk"),
-			"short-id":   query.Get("sid"),
-		},
-		"grpc-opts": map[string]string{
-			"grpc-service-name": query.Get("serviceName"),
-		},
-		// 给 URI使用，Clash 的 参数不叫这个
-		"security":    query.Get("security"),
-		"sni":         query.Get("sni"),
-		"fp":          query.Get("fp"),
-		"pbk":         query.Get("pbk"),
-		"sid":         query.Get("sid"),
-		"path":        query.Get("path"),
-		"host":        query.Get("host"),
-		"serviceName": query.Get("serviceName"),
-		"mode":        query.Get("mode"),
+		"mode":               query.Get("mode"),
+		"client-fingerprint": fp,
+	}
+
+	if path != "" || host != "" {
+		wsOpts := make(map[string]any, 2)
+		wsOpts["path"] = path
+		if host != "" {
+			headers := map[string]string{"Host": host}
+			wsOpts["headers"] = headers
+		}
+		proxy["ws-opts"] = wsOpts
 	}
 
+	if pbk != "" || sid != "" {
+		proxy["reality-opts"] = map[string]string{
+			"public-key": pbk,
+			"short-id":   sid,
+		}
+	}
+
+	if serviceName != "" {
+		proxy["grpc-opts"] = map[string]string{
+			"grpc-service-name": serviceName,
+		}
+	}
 	return proxy, nil
 }

proxy/parser/vmess.go

@@ -36,6 +36,9 @@ func ParseVmess(data string) (map[string]any, error) {
 	// 移除 "vmess://" 前缀
 	data = data[8:]
 
+	// 移除 ` 符号，不知道为什么很多节点结尾有这个
+	data = strings.ReplaceAll(data, "`", "")
+
 	// base64解码
 	decoded, err := base64.StdEncoding.DecodeString(data)
 	if err != nil {

save/save.go

@@ -291,6 +291,8 @@ func genUrls(data []byte) (*bytes.Buffer, error) {
 					}
 				case "Host":
 					q.Set("host", v)
+				case "grpc-service-name":
+					q.Set("serviceName", v)
 				default:
 					q.Set(k, v)
 				}