mirror of
https://gitclone.com/github.com/MetaCubeX/Clash.Meta
synced 2024-11-15 05:31:18 +08:00
122 lines
2.8 KiB
Go
122 lines
2.8 KiB
Go
package adapters
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"net"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/Dreamacro/clash/component/vmess"
|
|
C "github.com/Dreamacro/clash/constant"
|
|
)
|
|
|
|
// VmessAdapter is a vmess adapter
|
|
type VmessAdapter struct {
|
|
conn net.Conn
|
|
}
|
|
|
|
// Close is used to close connection
|
|
func (v *VmessAdapter) Close() {
|
|
v.conn.Close()
|
|
}
|
|
|
|
func (v *VmessAdapter) Conn() net.Conn {
|
|
return v.conn
|
|
}
|
|
|
|
type Vmess struct {
|
|
name string
|
|
server string
|
|
client *vmess.Client
|
|
}
|
|
|
|
type VmessOption struct {
|
|
Name string `proxy:"name"`
|
|
Server string `proxy:"server"`
|
|
Port int `proxy:"port"`
|
|
UUID string `proxy:"uuid"`
|
|
AlterID int `proxy:"alterId"`
|
|
Cipher string `proxy:"cipher"`
|
|
TLS bool `proxy:"tls,omitempty"`
|
|
Network string `proxy:"network,omitempty"`
|
|
WSPath string `proxy:"ws-path,omitempty"`
|
|
SkipCertVerify bool `proxy:"skip-cert-verify,omitempty"`
|
|
}
|
|
|
|
func (v *Vmess) Name() string {
|
|
return v.name
|
|
}
|
|
|
|
func (v *Vmess) Type() C.AdapterType {
|
|
return C.Vmess
|
|
}
|
|
|
|
func (v *Vmess) Generator(metadata *C.Metadata) (adapter C.ProxyAdapter, err error) {
|
|
c, err := net.DialTimeout("tcp", v.server, tcpTimeout)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("%s connect error", v.server)
|
|
}
|
|
tcpKeepAlive(c)
|
|
c, err = v.client.New(c, parseVmessAddr(metadata))
|
|
return &VmessAdapter{conn: c}, err
|
|
}
|
|
|
|
func (v *Vmess) MarshalJSON() ([]byte, error) {
|
|
return json.Marshal(map[string]interface{}{
|
|
"type": v.Type().String(),
|
|
})
|
|
}
|
|
|
|
func NewVmess(option VmessOption) (*Vmess, error) {
|
|
security := strings.ToLower(option.Cipher)
|
|
client, err := vmess.NewClient(vmess.Config{
|
|
UUID: option.UUID,
|
|
AlterID: uint16(option.AlterID),
|
|
Security: security,
|
|
TLS: option.TLS,
|
|
HostName: option.Server,
|
|
Port: strconv.Itoa(option.Port),
|
|
NetWork: option.Network,
|
|
WebSocketPath: option.WSPath,
|
|
SkipCertVerify: option.SkipCertVerify,
|
|
SessionCacahe: getClientSessionCache(),
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &Vmess{
|
|
name: option.Name,
|
|
server: net.JoinHostPort(option.Server, strconv.Itoa(option.Port)),
|
|
client: client,
|
|
}, nil
|
|
}
|
|
|
|
func parseVmessAddr(metadata *C.Metadata) *vmess.DstAddr {
|
|
var addrType byte
|
|
var addr []byte
|
|
switch metadata.AddrType {
|
|
case C.AtypIPv4:
|
|
addrType = byte(vmess.AtypIPv4)
|
|
addr = make([]byte, net.IPv4len)
|
|
copy(addr[:], metadata.IP.To4())
|
|
case C.AtypIPv6:
|
|
addrType = byte(vmess.AtypIPv6)
|
|
addr = make([]byte, net.IPv6len)
|
|
copy(addr[:], metadata.IP.To16())
|
|
case C.AtypDomainName:
|
|
addrType = byte(vmess.AtypDomainName)
|
|
addr = make([]byte, len(metadata.Host)+1)
|
|
addr[0] = byte(len(metadata.Host))
|
|
copy(addr[1:], []byte(metadata.Host))
|
|
}
|
|
|
|
port, _ := strconv.Atoi(metadata.Port)
|
|
return &vmess.DstAddr{
|
|
AddrType: addrType,
|
|
Addr: addr,
|
|
Port: uint(port),
|
|
}
|
|
}
|