mirror of
https://github.com/v2fly/v2ray-core.git
synced 2024-12-23 02:26:49 -05:00
395 lines
12 KiB
Go
395 lines
12 KiB
Go
package shadowsocks
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/rand"
|
|
"io"
|
|
|
|
"v2ray.com/core/common"
|
|
"v2ray.com/core/common/bitmask"
|
|
"v2ray.com/core/common/buf"
|
|
"v2ray.com/core/common/crypto"
|
|
"v2ray.com/core/common/net"
|
|
"v2ray.com/core/common/protocol"
|
|
"v2ray.com/core/common/serial"
|
|
)
|
|
|
|
const (
|
|
Version = 1
|
|
RequestOptionOneTimeAuth bitmask.Byte = 0x01
|
|
|
|
AddrTypeIPv4 = 1
|
|
AddrTypeIPv6 = 4
|
|
AddrTypeDomain = 3
|
|
)
|
|
|
|
func ReadTCPSession(user *protocol.User, reader io.Reader) (*protocol.RequestHeader, buf.Reader, error) {
|
|
rawAccount, err := user.GetTypedAccount()
|
|
if err != nil {
|
|
return nil, nil, newError("failed to parse account").Base(err).AtError()
|
|
}
|
|
account := rawAccount.(*ShadowsocksAccount)
|
|
|
|
buffer := buf.NewLocal(512)
|
|
defer buffer.Release()
|
|
|
|
ivLen := account.Cipher.IVSize()
|
|
if err := buffer.AppendSupplier(buf.ReadFullFrom(reader, ivLen)); err != nil {
|
|
return nil, nil, newError("failed to read IV").Base(err)
|
|
}
|
|
|
|
iv := append([]byte(nil), buffer.BytesTo(ivLen)...)
|
|
|
|
stream, err := account.Cipher.NewDecodingStream(account.Key, iv)
|
|
if err != nil {
|
|
return nil, nil, newError("failed to initialize decoding stream").Base(err).AtError()
|
|
}
|
|
reader = crypto.NewCryptionReader(stream, reader)
|
|
|
|
authenticator := NewAuthenticator(HeaderKeyGenerator(account.Key, iv))
|
|
request := &protocol.RequestHeader{
|
|
Version: Version,
|
|
User: user,
|
|
Command: protocol.RequestCommandTCP,
|
|
}
|
|
|
|
if err := buffer.Reset(buf.ReadFullFrom(reader, 1)); err != nil {
|
|
return nil, nil, newError("failed to read address type").Base(err)
|
|
}
|
|
|
|
addrType := (buffer.Byte(0) & 0x0F)
|
|
if (buffer.Byte(0) & 0x10) == 0x10 {
|
|
request.Option.Set(RequestOptionOneTimeAuth)
|
|
}
|
|
|
|
if request.Option.Has(RequestOptionOneTimeAuth) && account.OneTimeAuth == Account_Disabled {
|
|
return nil, nil, newError("rejecting connection with OTA enabled, while server disables OTA")
|
|
}
|
|
|
|
if !request.Option.Has(RequestOptionOneTimeAuth) && account.OneTimeAuth == Account_Enabled {
|
|
return nil, nil, newError("rejecting connection with OTA disabled, while server enables OTA")
|
|
}
|
|
|
|
switch addrType {
|
|
case AddrTypeIPv4:
|
|
if err := buffer.AppendSupplier(buf.ReadFullFrom(reader, 4)); err != nil {
|
|
return nil, nil, newError("failed to read IPv4 address").Base(err)
|
|
}
|
|
request.Address = net.IPAddress(buffer.BytesFrom(-4))
|
|
case AddrTypeIPv6:
|
|
if err := buffer.AppendSupplier(buf.ReadFullFrom(reader, 16)); err != nil {
|
|
return nil, nil, newError("failed to read IPv6 address").Base(err)
|
|
}
|
|
request.Address = net.IPAddress(buffer.BytesFrom(-16))
|
|
case AddrTypeDomain:
|
|
if err := buffer.AppendSupplier(buf.ReadFullFrom(reader, 1)); err != nil {
|
|
return nil, nil, newError("failed to read domain lenth.").Base(err)
|
|
}
|
|
domainLength := int(buffer.BytesFrom(-1)[0])
|
|
err = buffer.AppendSupplier(buf.ReadFullFrom(reader, domainLength))
|
|
if err != nil {
|
|
return nil, nil, newError("failed to read domain").Base(err)
|
|
}
|
|
request.Address = net.DomainAddress(string(buffer.BytesFrom(-domainLength)))
|
|
default:
|
|
// Check address validity after OTA verification.
|
|
}
|
|
|
|
err = buffer.AppendSupplier(buf.ReadFullFrom(reader, 2))
|
|
if err != nil {
|
|
return nil, nil, newError("failed to read port").Base(err)
|
|
}
|
|
request.Port = net.PortFromBytes(buffer.BytesFrom(-2))
|
|
|
|
if request.Option.Has(RequestOptionOneTimeAuth) {
|
|
actualAuth := make([]byte, AuthSize)
|
|
authenticator.Authenticate(buffer.Bytes())(actualAuth)
|
|
|
|
err := buffer.AppendSupplier(buf.ReadFullFrom(reader, AuthSize))
|
|
if err != nil {
|
|
return nil, nil, newError("Failed to read OTA").Base(err)
|
|
}
|
|
|
|
if !bytes.Equal(actualAuth, buffer.BytesFrom(-AuthSize)) {
|
|
return nil, nil, newError("invalid OTA")
|
|
}
|
|
}
|
|
|
|
if request.Address == nil {
|
|
return nil, nil, newError("invalid remote address.")
|
|
}
|
|
|
|
var chunkReader buf.Reader
|
|
if request.Option.Has(RequestOptionOneTimeAuth) {
|
|
chunkReader = NewChunkReader(reader, NewAuthenticator(ChunkKeyGenerator(iv)))
|
|
} else {
|
|
chunkReader = buf.NewReader(reader)
|
|
}
|
|
|
|
return request, chunkReader, nil
|
|
}
|
|
|
|
func WriteTCPRequest(request *protocol.RequestHeader, writer io.Writer) (buf.Writer, error) {
|
|
user := request.User
|
|
rawAccount, err := user.GetTypedAccount()
|
|
if err != nil {
|
|
return nil, newError("failed to parse account").Base(err).AtError()
|
|
}
|
|
account := rawAccount.(*ShadowsocksAccount)
|
|
|
|
iv := make([]byte, account.Cipher.IVSize())
|
|
rand.Read(iv)
|
|
_, err = writer.Write(iv)
|
|
if err != nil {
|
|
return nil, newError("failed to write IV")
|
|
}
|
|
|
|
stream, err := account.Cipher.NewEncodingStream(account.Key, iv)
|
|
if err != nil {
|
|
return nil, newError("failed to create encoding stream").Base(err).AtError()
|
|
}
|
|
|
|
writer = crypto.NewCryptionWriter(stream, writer)
|
|
|
|
header := buf.NewLocal(512)
|
|
|
|
switch request.Address.Family() {
|
|
case net.AddressFamilyIPv4:
|
|
header.AppendBytes(AddrTypeIPv4)
|
|
header.Append([]byte(request.Address.IP()))
|
|
case net.AddressFamilyIPv6:
|
|
header.AppendBytes(AddrTypeIPv6)
|
|
header.Append([]byte(request.Address.IP()))
|
|
case net.AddressFamilyDomain:
|
|
domain := request.Address.Domain()
|
|
if protocol.IsDomainTooLong(domain) {
|
|
return nil, newError("domain name too long: ", domain)
|
|
}
|
|
header.AppendBytes(AddrTypeDomain, byte(len(domain)))
|
|
common.Must(header.AppendSupplier(serial.WriteString(domain)))
|
|
default:
|
|
return nil, newError("unsupported address type: ", request.Address.Family())
|
|
}
|
|
|
|
common.Must(header.AppendSupplier(serial.WriteUint16(uint16(request.Port))))
|
|
|
|
if request.Option.Has(RequestOptionOneTimeAuth) {
|
|
header.SetByte(0, header.Byte(0)|0x10)
|
|
|
|
authenticator := NewAuthenticator(HeaderKeyGenerator(account.Key, iv))
|
|
common.Must(header.AppendSupplier(authenticator.Authenticate(header.Bytes())))
|
|
}
|
|
|
|
_, err = writer.Write(header.Bytes())
|
|
if err != nil {
|
|
return nil, newError("failed to write header").Base(err)
|
|
}
|
|
|
|
var chunkWriter buf.Writer
|
|
if request.Option.Has(RequestOptionOneTimeAuth) {
|
|
chunkWriter = NewChunkWriter(writer, NewAuthenticator(ChunkKeyGenerator(iv)))
|
|
} else {
|
|
chunkWriter = buf.NewWriter(writer)
|
|
}
|
|
|
|
return chunkWriter, nil
|
|
}
|
|
|
|
func ReadTCPResponse(user *protocol.User, reader io.Reader) (buf.Reader, error) {
|
|
rawAccount, err := user.GetTypedAccount()
|
|
if err != nil {
|
|
return nil, newError("failed to parse account").Base(err).AtError()
|
|
}
|
|
account := rawAccount.(*ShadowsocksAccount)
|
|
|
|
iv := make([]byte, account.Cipher.IVSize())
|
|
_, err = io.ReadFull(reader, iv)
|
|
if err != nil {
|
|
return nil, newError("failed to read IV").Base(err)
|
|
}
|
|
|
|
stream, err := account.Cipher.NewDecodingStream(account.Key, iv)
|
|
if err != nil {
|
|
return nil, newError("failed to initialize decoding stream").Base(err).AtError()
|
|
}
|
|
return buf.NewReader(crypto.NewCryptionReader(stream, reader)), nil
|
|
}
|
|
|
|
func WriteTCPResponse(request *protocol.RequestHeader, writer io.Writer) (buf.Writer, error) {
|
|
user := request.User
|
|
rawAccount, err := user.GetTypedAccount()
|
|
if err != nil {
|
|
return nil, newError("failed to parse account.").Base(err).AtError()
|
|
}
|
|
account := rawAccount.(*ShadowsocksAccount)
|
|
|
|
iv := make([]byte, account.Cipher.IVSize())
|
|
rand.Read(iv)
|
|
_, err = writer.Write(iv)
|
|
if err != nil {
|
|
return nil, newError("failed to write IV.").Base(err)
|
|
}
|
|
|
|
stream, err := account.Cipher.NewEncodingStream(account.Key, iv)
|
|
if err != nil {
|
|
return nil, newError("failed to create encoding stream.").Base(err).AtError()
|
|
}
|
|
|
|
return buf.NewWriter(crypto.NewCryptionWriter(stream, writer)), nil
|
|
}
|
|
|
|
func EncodeUDPPacket(request *protocol.RequestHeader, payload []byte) (*buf.Buffer, error) {
|
|
user := request.User
|
|
rawAccount, err := user.GetTypedAccount()
|
|
if err != nil {
|
|
return nil, newError("failed to parse account.").Base(err).AtError()
|
|
}
|
|
account := rawAccount.(*ShadowsocksAccount)
|
|
|
|
buffer := buf.New()
|
|
ivLen := account.Cipher.IVSize()
|
|
buffer.AppendSupplier(buf.ReadFullFrom(rand.Reader, ivLen))
|
|
iv := buffer.Bytes()
|
|
|
|
switch request.Address.Family() {
|
|
case net.AddressFamilyIPv4:
|
|
buffer.AppendBytes(AddrTypeIPv4)
|
|
buffer.Append([]byte(request.Address.IP()))
|
|
case net.AddressFamilyIPv6:
|
|
buffer.AppendBytes(AddrTypeIPv6)
|
|
buffer.Append([]byte(request.Address.IP()))
|
|
case net.AddressFamilyDomain:
|
|
buffer.AppendBytes(AddrTypeDomain, byte(len(request.Address.Domain())))
|
|
buffer.Append([]byte(request.Address.Domain()))
|
|
default:
|
|
return nil, newError("unsupported address type: ", request.Address.Family()).AtError()
|
|
}
|
|
|
|
buffer.AppendSupplier(serial.WriteUint16(uint16(request.Port)))
|
|
buffer.Append(payload)
|
|
|
|
if request.Option.Has(RequestOptionOneTimeAuth) {
|
|
authenticator := NewAuthenticator(HeaderKeyGenerator(account.Key, iv))
|
|
buffer.SetByte(ivLen, buffer.Byte(ivLen)|0x10)
|
|
|
|
buffer.AppendSupplier(authenticator.Authenticate(buffer.BytesFrom(ivLen)))
|
|
}
|
|
|
|
stream, err := account.Cipher.NewEncodingStream(account.Key, iv)
|
|
if err != nil {
|
|
return nil, newError("failed to create encoding stream").Base(err).AtError()
|
|
}
|
|
|
|
stream.XORKeyStream(buffer.BytesFrom(ivLen), buffer.BytesFrom(ivLen))
|
|
return buffer, nil
|
|
}
|
|
|
|
func DecodeUDPPacket(user *protocol.User, payload *buf.Buffer) (*protocol.RequestHeader, *buf.Buffer, error) {
|
|
rawAccount, err := user.GetTypedAccount()
|
|
if err != nil {
|
|
return nil, nil, newError("failed to parse account").Base(err).AtError()
|
|
}
|
|
account := rawAccount.(*ShadowsocksAccount)
|
|
|
|
ivLen := account.Cipher.IVSize()
|
|
iv := payload.BytesTo(ivLen)
|
|
payload.SliceFrom(ivLen)
|
|
|
|
stream, err := account.Cipher.NewDecodingStream(account.Key, iv)
|
|
if err != nil {
|
|
return nil, nil, newError("failed to initialize decoding stream").Base(err).AtError()
|
|
}
|
|
stream.XORKeyStream(payload.Bytes(), payload.Bytes())
|
|
|
|
authenticator := NewAuthenticator(HeaderKeyGenerator(account.Key, iv))
|
|
request := &protocol.RequestHeader{
|
|
Version: Version,
|
|
User: user,
|
|
Command: protocol.RequestCommandUDP,
|
|
}
|
|
|
|
addrType := (payload.Byte(0) & 0x0F)
|
|
if (payload.Byte(0) & 0x10) == 0x10 {
|
|
request.Option |= RequestOptionOneTimeAuth
|
|
}
|
|
|
|
if request.Option.Has(RequestOptionOneTimeAuth) && account.OneTimeAuth == Account_Disabled {
|
|
return nil, nil, newError("rejecting packet with OTA enabled, while server disables OTA").AtWarning()
|
|
}
|
|
|
|
if !request.Option.Has(RequestOptionOneTimeAuth) && account.OneTimeAuth == Account_Enabled {
|
|
return nil, nil, newError("rejecting packet with OTA disabled, while server enables OTA").AtWarning()
|
|
}
|
|
|
|
if request.Option.Has(RequestOptionOneTimeAuth) {
|
|
payloadLen := payload.Len() - AuthSize
|
|
authBytes := payload.BytesFrom(payloadLen)
|
|
|
|
actualAuth := make([]byte, AuthSize)
|
|
authenticator.Authenticate(payload.BytesTo(payloadLen))(actualAuth)
|
|
if !bytes.Equal(actualAuth, authBytes) {
|
|
return nil, nil, newError("invalid OTA")
|
|
}
|
|
|
|
payload.Slice(0, payloadLen)
|
|
}
|
|
|
|
payload.SliceFrom(1)
|
|
|
|
switch addrType {
|
|
case AddrTypeIPv4:
|
|
request.Address = net.IPAddress(payload.BytesTo(4))
|
|
payload.SliceFrom(4)
|
|
case AddrTypeIPv6:
|
|
request.Address = net.IPAddress(payload.BytesTo(16))
|
|
payload.SliceFrom(16)
|
|
case AddrTypeDomain:
|
|
domainLength := int(payload.Byte(0))
|
|
request.Address = net.DomainAddress(string(payload.BytesRange(1, 1+domainLength)))
|
|
payload.SliceFrom(1 + domainLength)
|
|
default:
|
|
return nil, nil, newError("unknown address type: ", addrType).AtError()
|
|
}
|
|
|
|
request.Port = net.PortFromBytes(payload.BytesTo(2))
|
|
payload.SliceFrom(2)
|
|
|
|
return request, payload, nil
|
|
}
|
|
|
|
type UDPReader struct {
|
|
Reader io.Reader
|
|
User *protocol.User
|
|
}
|
|
|
|
func (v *UDPReader) ReadMultiBuffer() (buf.MultiBuffer, error) {
|
|
buffer := buf.New()
|
|
err := buffer.AppendSupplier(buf.ReadFrom(v.Reader))
|
|
if err != nil {
|
|
buffer.Release()
|
|
return nil, err
|
|
}
|
|
_, payload, err := DecodeUDPPacket(v.User, buffer)
|
|
if err != nil {
|
|
buffer.Release()
|
|
return nil, err
|
|
}
|
|
return buf.NewMultiBufferValue(payload), nil
|
|
}
|
|
|
|
type UDPWriter struct {
|
|
Writer io.Writer
|
|
Request *protocol.RequestHeader
|
|
}
|
|
|
|
// Write implements io.Writer.
|
|
func (w *UDPWriter) Write(payload []byte) (int, error) {
|
|
packet, err := EncodeUDPPacket(w.Request, payload)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
_, err = w.Writer.Write(packet.Bytes())
|
|
packet.Release()
|
|
return len(payload), err
|
|
}
|