mirror of
https://github.com/v2fly/v2ray-core.git
synced 2024-11-20 03:16:24 -05:00
49 lines
1.4 KiB
Go
49 lines
1.4 KiB
Go
package outbound
|
|
|
|
import (
|
|
"hash/fnv"
|
|
|
|
"github.com/v2ray/v2ray-core/common/log"
|
|
v2net "github.com/v2ray/v2ray-core/common/net"
|
|
proto "github.com/v2ray/v2ray-core/common/protocol"
|
|
"github.com/v2ray/v2ray-core/common/serial"
|
|
"github.com/v2ray/v2ray-core/proxy/vmess/command"
|
|
)
|
|
|
|
func (this *VMessOutboundHandler) handleSwitchAccount(cmd *command.SwitchAccount) {
|
|
user := proto.NewUser(proto.NewID(cmd.ID), cmd.Level, cmd.AlterIds.Value())
|
|
dest := v2net.TCPDestination(cmd.Host, cmd.Port)
|
|
this.receiverManager.AddDetour(NewReceiver(dest, user), cmd.ValidMin)
|
|
}
|
|
|
|
func (this *VMessOutboundHandler) handleCommand(dest v2net.Destination, cmdId byte, data []byte) {
|
|
if len(data) < 4 {
|
|
return
|
|
}
|
|
fnv1hash := fnv.New32a()
|
|
fnv1hash.Write(data[4:])
|
|
actualHashValue := fnv1hash.Sum32()
|
|
expectedHashValue := serial.BytesLiteral(data[:4]).Uint32Value()
|
|
if actualHashValue != expectedHashValue {
|
|
return
|
|
}
|
|
data = data[4:]
|
|
cmd, err := command.CreateResponseCommand(cmdId)
|
|
if err != nil {
|
|
log.Warning("VMessOut: Unknown response command (", cmdId, "): ", err)
|
|
return
|
|
}
|
|
if err := cmd.Unmarshal(data); err != nil {
|
|
log.Warning("VMessOut: Failed to parse response command: ", err)
|
|
return
|
|
}
|
|
switch typedCommand := cmd.(type) {
|
|
case *command.SwitchAccount:
|
|
if typedCommand.Host == nil {
|
|
typedCommand.Host = dest.Address()
|
|
}
|
|
this.handleSwitchAccount(typedCommand)
|
|
default:
|
|
}
|
|
}
|