mirror of
https://github.com/v2fly/v2ray-core.git
synced 2024-06-29 10:45:22 +00:00
119 lines
3.0 KiB
Go
119 lines
3.0 KiB
Go
package shadowsocks_test
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"v2ray.com/core/common/alloc"
|
|
"v2ray.com/core/common/loader"
|
|
v2net "v2ray.com/core/common/net"
|
|
"v2ray.com/core/common/protocol"
|
|
. "v2ray.com/core/proxy/shadowsocks"
|
|
"v2ray.com/core/testing/assert"
|
|
)
|
|
|
|
func TestUDPEncoding(t *testing.T) {
|
|
assert := assert.On(t)
|
|
|
|
request := &protocol.RequestHeader{
|
|
Version: Version,
|
|
Command: protocol.RequestCommandUDP,
|
|
Address: v2net.LocalHostIP,
|
|
Port: 1234,
|
|
User: &protocol.User{
|
|
Email: "love@v2ray.com",
|
|
Account: loader.NewTypedSettings(&Account{
|
|
Password: "shadowsocks-password",
|
|
CipherType: CipherType_AES_128_CFB,
|
|
Ota: Account_Disabled,
|
|
}),
|
|
},
|
|
}
|
|
|
|
data := alloc.NewLocalBuffer(256).Clear().AppendString("test string")
|
|
encodedData, err := EncodeUDPPacket(request, data)
|
|
assert.Error(err).IsNil()
|
|
|
|
decodedRequest, decodedData, err := DecodeUDPPacket(request.User, encodedData)
|
|
assert.Error(err).IsNil()
|
|
assert.Bytes(decodedData.Value).Equals(data.Value)
|
|
assert.Address(decodedRequest.Address).Equals(request.Address)
|
|
assert.Port(decodedRequest.Port).Equals(request.Port)
|
|
}
|
|
|
|
func TestTCPRequest(t *testing.T) {
|
|
assert := assert.On(t)
|
|
|
|
request := &protocol.RequestHeader{
|
|
Version: Version,
|
|
Command: protocol.RequestCommandTCP,
|
|
Address: v2net.LocalHostIP,
|
|
Option: RequestOptionOneTimeAuth,
|
|
Port: 1234,
|
|
User: &protocol.User{
|
|
Email: "love@v2ray.com",
|
|
Account: loader.NewTypedSettings(&Account{
|
|
Password: "tcp-password",
|
|
CipherType: CipherType_CHACHA20,
|
|
}),
|
|
},
|
|
}
|
|
|
|
data := alloc.NewLocalBuffer(256).Clear().AppendString("test string")
|
|
cache := alloc.NewLargeBuffer().Clear()
|
|
|
|
writer, err := WriteTCPRequest(request, cache)
|
|
assert.Error(err).IsNil()
|
|
|
|
writer.Write(data)
|
|
|
|
decodedRequest, reader, err := ReadTCPSession(request.User, cache)
|
|
assert.Error(err).IsNil()
|
|
assert.Address(decodedRequest.Address).Equals(request.Address)
|
|
assert.Port(decodedRequest.Port).Equals(request.Port)
|
|
|
|
decodedData, err := reader.Read()
|
|
assert.Error(err).IsNil()
|
|
assert.Bytes(decodedData.Value).Equals([]byte("test string"))
|
|
}
|
|
|
|
func TestUDPReaderWriter(t *testing.T) {
|
|
assert := assert.On(t)
|
|
|
|
user := &protocol.User{
|
|
Account: loader.NewTypedSettings(&Account{
|
|
Password: "test-password",
|
|
CipherType: CipherType_CHACHA20_IEFT,
|
|
}),
|
|
}
|
|
cache := alloc.NewBuffer().Clear()
|
|
writer := &UDPWriter{
|
|
Writer: cache,
|
|
Request: &protocol.RequestHeader{
|
|
Version: Version,
|
|
Address: v2net.DomainAddress("v2ray.com"),
|
|
Port: 123,
|
|
User: user,
|
|
Option: RequestOptionOneTimeAuth,
|
|
},
|
|
}
|
|
|
|
reader := &UDPReader{
|
|
Reader: cache,
|
|
User: user,
|
|
}
|
|
|
|
err := writer.Write(alloc.NewBuffer().Clear().AppendString("test payload"))
|
|
assert.Error(err).IsNil()
|
|
|
|
payload, err := reader.Read()
|
|
assert.Error(err).IsNil()
|
|
assert.String(payload.String()).Equals("test payload")
|
|
|
|
err = writer.Write(alloc.NewBuffer().Clear().AppendString("test payload 2"))
|
|
assert.Error(err).IsNil()
|
|
|
|
payload, err = reader.Read()
|
|
assert.Error(err).IsNil()
|
|
assert.String(payload.String()).Equals("test payload 2")
|
|
}
|