58 lines
1.3 KiB
Go
58 lines
1.3 KiB
Go
|
package proxy
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"context"
|
|||
|
|
"fmt"
|
|||
|
|
"github.com/bytedance/sonic"
|
|||
|
|
"github.com/metacubex/mihomo/adapter"
|
|||
|
|
"github.com/metacubex/mihomo/constant"
|
|||
|
|
"github.com/timerzz/proxypool/pkg/proxy"
|
|||
|
|
"net"
|
|||
|
|
"net/url"
|
|||
|
|
"strconv"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
func ConnFromProxy(ctx context.Context, p proxy.Proxy, addr constant.Metadata) (conn net.Conn, err error) {
|
|||
|
|
pmap := make(map[string]interface{})
|
|||
|
|
err = sonic.UnmarshalString(p.String(), &pmap)
|
|||
|
|
if err != nil {
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
pmap["port"] = int(pmap["port"].(float64))
|
|||
|
|
if p.TypeName() == "vmess" {
|
|||
|
|
pmap["alterId"] = int(pmap["alterId"].(float64))
|
|||
|
|
}
|
|||
|
|
clashProxy, err := adapter.ParseProxy(pmap)
|
|||
|
|
if err != nil {
|
|||
|
|
return nil, err
|
|||
|
|
}
|
|||
|
|
return clashProxy.DialContext(ctx, &addr) // 建立到proxy server的connection，对Proxy的类别做了自适应相当于泛型
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// UrlToMetadata DO NOT EDIT. Copied from clash because it's an unexported function
|
|||
|
|
func UrlToMetadata(rawURL string) (addr constant.Metadata, err error) {
|
|||
|
|
u, err := url.Parse(rawURL)
|
|||
|
|
if err != nil {
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
port := u.Port()
|
|||
|
|
if port == "" {
|
|||
|
|
switch u.Scheme {
|
|||
|
|
case "https":
|
|||
|
|
port = "443"
|
|||
|
|
case "http":
|
|||
|
|
port = "80"
|
|||
|
|
default:
|
|||
|
|
err = fmt.Errorf("%s scheme not Support", rawURL)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
pi, _ := strconv.Atoi(port)
|
|||
|
|
addr = constant.Metadata{
|
|||
|
|
Host: u.Hostname(),
|
|||
|
|
DstPort: uint16(pi),
|
|||
|
|
}
|
|||
|
|
return
|
|||
|
|
}
|