mirror of
https://github.com/v2fly/v2ray-core.git
synced 2024-12-22 18:17:52 -05:00
199 lines
5.1 KiB
Go
199 lines
5.1 KiB
Go
package dokodemo
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"github.com/v2ray/v2ray-core/app"
|
|
"github.com/v2ray/v2ray-core/app/dispatcher"
|
|
"github.com/v2ray/v2ray-core/common/alloc"
|
|
v2io "github.com/v2ray/v2ray-core/common/io"
|
|
"github.com/v2ray/v2ray-core/common/log"
|
|
v2net "github.com/v2ray/v2ray-core/common/net"
|
|
"github.com/v2ray/v2ray-core/proxy"
|
|
"github.com/v2ray/v2ray-core/proxy/internal"
|
|
"github.com/v2ray/v2ray-core/transport/internet"
|
|
"github.com/v2ray/v2ray-core/transport/internet/udp"
|
|
)
|
|
|
|
type DokodemoDoor struct {
|
|
tcpMutex sync.RWMutex
|
|
udpMutex sync.RWMutex
|
|
config *Config
|
|
accepting bool
|
|
address v2net.Address
|
|
port v2net.Port
|
|
packetDispatcher dispatcher.PacketDispatcher
|
|
tcpListener *internet.TCPHub
|
|
udpHub *udp.UDPHub
|
|
udpServer *udp.UDPServer
|
|
meta *proxy.InboundHandlerMeta
|
|
}
|
|
|
|
func NewDokodemoDoor(config *Config, space app.Space, meta *proxy.InboundHandlerMeta) *DokodemoDoor {
|
|
d := &DokodemoDoor{
|
|
config: config,
|
|
address: config.Address,
|
|
port: config.Port,
|
|
meta: meta,
|
|
}
|
|
space.InitializeApplication(func() error {
|
|
if !space.HasApp(dispatcher.APP_ID) {
|
|
log.Error("Dokodemo: Dispatcher is not found in the space.")
|
|
return app.ErrMissingApplication
|
|
}
|
|
d.packetDispatcher = space.GetApp(dispatcher.APP_ID).(dispatcher.PacketDispatcher)
|
|
return nil
|
|
})
|
|
return d
|
|
}
|
|
|
|
func (this *DokodemoDoor) Port() v2net.Port {
|
|
return this.meta.Port
|
|
}
|
|
|
|
func (this *DokodemoDoor) Close() {
|
|
this.accepting = false
|
|
if this.tcpListener != nil {
|
|
this.tcpMutex.Lock()
|
|
this.tcpListener.Close()
|
|
this.tcpListener = nil
|
|
this.tcpMutex.Unlock()
|
|
}
|
|
if this.udpHub != nil {
|
|
this.udpMutex.Lock()
|
|
this.udpHub.Close()
|
|
this.udpHub = nil
|
|
this.udpMutex.Unlock()
|
|
}
|
|
}
|
|
|
|
func (this *DokodemoDoor) Start() error {
|
|
if this.accepting {
|
|
return nil
|
|
}
|
|
this.accepting = true
|
|
|
|
if this.config.Network.HasNetwork(v2net.TCPNetwork) {
|
|
err := this.ListenTCP()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
if this.config.Network.HasNetwork(v2net.UDPNetwork) {
|
|
err := this.ListenUDP()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (this *DokodemoDoor) ListenUDP() error {
|
|
this.udpServer = udp.NewUDPServer(this.meta, this.packetDispatcher)
|
|
udpHub, err := udp.ListenUDP(this.meta.Address, this.meta.Port, this.handleUDPPackets)
|
|
if err != nil {
|
|
log.Error("Dokodemo failed to listen on ", this.meta.Address, ":", this.meta.Port, ": ", err)
|
|
return err
|
|
}
|
|
this.udpMutex.Lock()
|
|
this.udpHub = udpHub
|
|
this.udpMutex.Unlock()
|
|
return nil
|
|
}
|
|
|
|
func (this *DokodemoDoor) handleUDPPackets(payload *alloc.Buffer, dest v2net.Destination) {
|
|
this.udpServer.Dispatch(
|
|
&proxy.SessionInfo{Source: dest, Destination: v2net.UDPDestination(this.address, this.port)}, payload, this.handleUDPResponse)
|
|
}
|
|
|
|
func (this *DokodemoDoor) handleUDPResponse(dest v2net.Destination, payload *alloc.Buffer) {
|
|
defer payload.Release()
|
|
this.udpMutex.RLock()
|
|
defer this.udpMutex.RUnlock()
|
|
if !this.accepting {
|
|
return
|
|
}
|
|
this.udpHub.WriteTo(payload.Value, dest)
|
|
}
|
|
|
|
func (this *DokodemoDoor) ListenTCP() error {
|
|
tcpListener, err := internet.ListenTCP(this.meta.Address, this.meta.Port, this.HandleTCPConnection, this.meta.StreamSettings)
|
|
if err != nil {
|
|
log.Error("Dokodemo: Failed to listen on ", this.meta.Address, ":", this.meta.Port, ": ", err)
|
|
return err
|
|
}
|
|
this.tcpMutex.Lock()
|
|
this.tcpListener = tcpListener
|
|
this.tcpMutex.Unlock()
|
|
return nil
|
|
}
|
|
|
|
func (this *DokodemoDoor) HandleTCPConnection(conn internet.Connection) {
|
|
defer conn.Close()
|
|
|
|
var dest v2net.Destination
|
|
if this.config.FollowRedirect {
|
|
originalDest := GetOriginalDestination(conn)
|
|
if originalDest != nil {
|
|
log.Info("Dokodemo: Following redirect to: ", originalDest)
|
|
dest = originalDest
|
|
}
|
|
}
|
|
if dest == nil && this.address != nil && this.port > v2net.Port(0) {
|
|
dest = v2net.TCPDestination(this.address, this.port)
|
|
}
|
|
|
|
if dest == nil {
|
|
log.Info("Dokodemo: Unknown destination, stop forwarding...")
|
|
return
|
|
}
|
|
log.Info("Dokodemo: Handling request to ", dest)
|
|
|
|
ray := this.packetDispatcher.DispatchToOutbound(this.meta, &proxy.SessionInfo{
|
|
Source: v2net.DestinationFromAddr(conn.RemoteAddr()),
|
|
Destination: dest,
|
|
})
|
|
defer ray.InboundOutput().Release()
|
|
|
|
var inputFinish, outputFinish sync.Mutex
|
|
inputFinish.Lock()
|
|
outputFinish.Lock()
|
|
|
|
reader := v2net.NewTimeOutReader(this.config.Timeout, conn)
|
|
defer reader.Release()
|
|
|
|
go func() {
|
|
v2reader := v2io.NewAdaptiveReader(reader)
|
|
defer v2reader.Release()
|
|
|
|
v2io.Pipe(v2reader, ray.InboundInput())
|
|
inputFinish.Unlock()
|
|
ray.InboundInput().Close()
|
|
}()
|
|
|
|
go func() {
|
|
v2writer := v2io.NewAdaptiveWriter(conn)
|
|
defer v2writer.Release()
|
|
|
|
v2io.Pipe(ray.InboundOutput(), v2writer)
|
|
outputFinish.Unlock()
|
|
}()
|
|
|
|
outputFinish.Lock()
|
|
inputFinish.Lock()
|
|
}
|
|
|
|
type Factory struct{}
|
|
|
|
func (this *Factory) StreamCapability() internet.StreamConnectionType {
|
|
return internet.StreamConnectionTypeRawTCP
|
|
}
|
|
|
|
func (this *Factory) Create(space app.Space, rawConfig interface{}, meta *proxy.InboundHandlerMeta) (proxy.InboundHandler, error) {
|
|
return NewDokodemoDoor(rawConfig.(*Config), space, meta), nil
|
|
}
|
|
|
|
func init() {
|
|
internal.MustRegisterInboundHandlerCreator("dokodemo-door", new(Factory))
|
|
}
|