mirror of
https://github.com/nitezs/sub2sing-box.git
synced 2024-12-25 01:54:42 -05:00
89 lines
2.6 KiB
Go
89 lines
2.6 KiB
Go
package parser
|
|
|
|
import (
|
|
"errors"
|
|
"net/url"
|
|
"strconv"
|
|
"strings"
|
|
"sub2sing-box/internal/model"
|
|
)
|
|
|
|
//hysteria://host:port?protocol=udp&auth=123456&peer=sni.domain&insecure=1&upmbps=100&downmbps=100&alpn=hysteria&obfs=xplus&obfsParam=123456#remarks
|
|
//
|
|
//- host: hostname or IP address of the server to connect to (required)
|
|
//- port: port of the server to connect to (required)
|
|
//- protocol: protocol to use ("udp", "wechat-video", "faketcp") (optional, default: "udp")
|
|
//- auth: authentication payload (string) (optional)
|
|
//- peer: SNI for TLS (optional)
|
|
//- insecure: ignore certificate errors (optional)
|
|
//- upmbps: upstream bandwidth in Mbps (required)
|
|
//- downmbps: downstream bandwidth in Mbps (required)
|
|
//- alpn: QUIC ALPN (optional)
|
|
//- obfs: Obfuscation mode (optional, empty or "xplus")
|
|
//- obfsParam: Obfuscation password (optional)
|
|
//- remarks: remarks (optional)
|
|
|
|
func ParseHysteria(proxy string) (model.Proxy, error) {
|
|
if !strings.HasPrefix(proxy, "hysteria://") {
|
|
return model.Proxy{}, errors.New("invalid hysteria Url")
|
|
}
|
|
parts := strings.SplitN(strings.TrimPrefix(proxy, "hysteria://"), "?", 2)
|
|
serverInfo := strings.SplitN(parts[0], ":", 2)
|
|
if len(serverInfo) != 2 {
|
|
return model.Proxy{}, errors.New("invalid hysteria Url")
|
|
}
|
|
params, err := url.ParseQuery(parts[1])
|
|
if err != nil {
|
|
return model.Proxy{}, errors.New("invalid hysteria Url")
|
|
}
|
|
host := serverInfo[0]
|
|
port, err := strconv.Atoi(serverInfo[1])
|
|
if err != nil {
|
|
return model.Proxy{}, errors.New("invalid hysteria Url")
|
|
}
|
|
protocol := params.Get("protocol")
|
|
auth := params.Get("auth")
|
|
// peer := params.Get("peer")
|
|
insecure := params.Get("insecure")
|
|
upmbps := params.Get("upmbps")
|
|
downmbps := params.Get("downmbps")
|
|
obfs := params.Get("obfs")
|
|
// obfsParam := params.Get("obfsParam")
|
|
var alpn []string
|
|
if params.Get("alpn") != "" {
|
|
alpn = strings.Split(params.Get("alpn"), ",")
|
|
} else {
|
|
alpn = nil
|
|
}
|
|
remarks := ""
|
|
if strings.Contains(parts[1], "#") {
|
|
r := strings.Split(parts[1], "#")
|
|
remarks = r[len(r)-1]
|
|
} else {
|
|
remarks = serverInfo[0] + ":" + serverInfo[1]
|
|
}
|
|
insecureBool, err := strconv.ParseBool(insecure)
|
|
if err != nil {
|
|
return model.Proxy{}, errors.New("invalid hysteria Url")
|
|
}
|
|
result := model.Proxy{
|
|
Type: "hysteria",
|
|
Tag: remarks,
|
|
Hysteria: model.Hysteria{
|
|
Server: host,
|
|
ServerPort: uint16(port),
|
|
Up: upmbps,
|
|
Down: downmbps,
|
|
Auth: []byte(auth),
|
|
Obfs: obfs,
|
|
Network: protocol,
|
|
TLS: &model.OutboundTLSOptions{
|
|
Enabled: true,
|
|
Insecure: insecureBool,
|
|
ALPN: alpn,
|
|
},
|
|
},
|
|
}
|
|
return result, nil
|
|
}
|