348 lines
8.2 KiB
Go
348 lines
8.2 KiB
Go
|
package main
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"testing"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/Dreamacro/clash/adapters/outbound"
|
||
|
|
C "github.com/Dreamacro/clash/constant"
|
||
|
|
|
||
|
|
"github.com/docker/docker/api/types/container"
|
||
|
|
"github.com/stretchr/testify/assert"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestClash_Vmess(t *testing.T) {
|
||
|
|
configPath := C.Path.Resolve("vmess.json")
|
||
|
|
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{fmt.Sprintf("%s:/etc/v2ray/config.json", configPath)},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
t.Cleanup(func() {
|
||
|
|
cleanContainer(id)
|
||
|
|
})
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
UDP: true,
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessAEAD(t *testing.T) {
|
||
|
|
configPath := C.Path.Resolve("vmess-aead.json")
|
||
|
|
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{fmt.Sprintf("%s:/etc/v2ray/config.json", configPath)},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-aead")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
t.Cleanup(func() {
|
||
|
|
cleanContainer(id)
|
||
|
|
})
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 0,
|
||
|
|
UDP: true,
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessTLS(t *testing.T) {
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{
|
||
|
|
fmt.Sprintf("%s:/etc/v2ray/config.json", C.Path.Resolve("vmess-tls.json")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/fullchain.pem", C.Path.Resolve("example.org.pem")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/privkey.pem", C.Path.Resolve("example.org-key.pem")),
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-tls")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
defer cleanContainer(id)
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
TLS: true,
|
||
|
|
SkipCertVerify: true,
|
||
|
|
ServerName: "example.org",
|
||
|
|
UDP: true,
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessHTTP2(t *testing.T) {
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{
|
||
|
|
fmt.Sprintf("%s:/etc/v2ray/config.json", C.Path.Resolve("vmess-http2.json")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/fullchain.pem", C.Path.Resolve("example.org.pem")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/privkey.pem", C.Path.Resolve("example.org-key.pem")),
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-http2")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
defer cleanContainer(id)
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
Network: "h2",
|
||
|
|
TLS: true,
|
||
|
|
SkipCertVerify: true,
|
||
|
|
ServerName: "example.org",
|
||
|
|
UDP: true,
|
||
|
|
HTTP2Opts: outbound.HTTP2Options{
|
||
|
|
Host: []string{"example.org"},
|
||
|
|
Path: "/test",
|
||
|
|
},
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessHTTP(t *testing.T) {
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{
|
||
|
|
fmt.Sprintf("%s:/etc/v2ray/config.json", C.Path.Resolve("vmess-http.json")),
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-http")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
defer cleanContainer(id)
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
Network: "http",
|
||
|
|
UDP: true,
|
||
|
|
HTTPOpts: outbound.HTTPOptions{
|
||
|
|
Method: "GET",
|
||
|
|
Path: []string{"/"},
|
||
|
|
Headers: map[string][]string{
|
||
|
|
"Host": {"www.amazon.com"},
|
||
|
|
"User-Agent": {
|
||
|
|
"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/84.0.4147.105 Safari/537.36 Edg/84.0.522.49",
|
||
|
|
},
|
||
|
|
"Accept-Encoding": {
|
||
|
|
"gzip, deflate",
|
||
|
|
},
|
||
|
|
"Connection": {
|
||
|
|
"keep-alive",
|
||
|
|
},
|
||
|
|
"Pragma": {"no-cache"},
|
||
|
|
},
|
||
|
|
},
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessWebsocket(t *testing.T) {
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{
|
||
|
|
fmt.Sprintf("%s:/etc/v2ray/config.json", C.Path.Resolve("vmess-ws.json")),
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-ws")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
defer cleanContainer(id)
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
Network: "ws",
|
||
|
|
UDP: true,
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessWebsocketTLS(t *testing.T) {
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageVmess,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{
|
||
|
|
fmt.Sprintf("%s:/etc/v2ray/config.json", C.Path.Resolve("vmess-ws-tls.json")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/fullchain.pem", C.Path.Resolve("example.org.pem")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/privkey.pem", C.Path.Resolve("example.org-key.pem")),
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-ws")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
defer cleanContainer(id)
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
Network: "ws",
|
||
|
|
TLS: true,
|
||
|
|
SkipCertVerify: true,
|
||
|
|
UDP: true,
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestClash_VmessGrpc(t *testing.T) {
|
||
|
|
cfg := &container.Config{
|
||
|
|
Image: ImageXray,
|
||
|
|
ExposedPorts: defaultExposedPorts,
|
||
|
|
}
|
||
|
|
hostCfg := &container.HostConfig{
|
||
|
|
PortBindings: defaultPortBindings,
|
||
|
|
Binds: []string{
|
||
|
|
fmt.Sprintf("%s:/etc/xray/config.json", C.Path.Resolve("vmess-grpc.json")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/fullchain.pem", C.Path.Resolve("example.org.pem")),
|
||
|
|
fmt.Sprintf("%s:/etc/ssl/v2ray/privkey.pem", C.Path.Resolve("example.org-key.pem")),
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
id, err := startContainer(cfg, hostCfg, "vmess-grpc")
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
defer cleanContainer(id)
|
||
|
|
|
||
|
|
proxy, err := outbound.NewVmess(outbound.VmessOption{
|
||
|
|
Name: "vmess",
|
||
|
|
Server: localIP.String(),
|
||
|
|
Port: 10002,
|
||
|
|
UUID: "b831381d-6324-4d53-ad4f-8cda48b30811",
|
||
|
|
Cipher: "auto",
|
||
|
|
AlterID: 32,
|
||
|
|
Network: "grpc",
|
||
|
|
TLS: true,
|
||
|
|
SkipCertVerify: true,
|
||
|
|
UDP: true,
|
||
|
|
ServerName: "example.org",
|
||
|
|
GrpcOpts: outbound.GrpcOptions{
|
||
|
|
GrpcServiceName: "example",
|
||
|
|
},
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
assert.FailNow(t, err.Error())
|
||
|
|
}
|
||
|
|
|
||
|
|
time.Sleep(waitTime)
|
||
|
|
testSuit(t, proxy)
|
||
|
|
}
|