trojan-go/proxy/proxy.go

package proxy

import (
	"io"
	"os"

	"github.com/p4gefau1t/trojan-go/common"
	"github.com/p4gefau1t/trojan-go/conf"
	"github.com/p4gefau1t/trojan-go/log"
	"github.com/p4gefau1t/trojan-go/protocol"
)

var logger = log.New(os.Stdout)

func copyConn(dst io.Writer, src io.Reader, errChan chan error) {
	_, err := io.Copy(dst, src)
	errChan <- err
}

func copyPacket(dst protocol.PacketWriter, src protocol.PacketReader, errChan chan error) {
	for {
		req, packet, err := src.ReadPacket()
		if err != nil {
			errChan <- err
			return
		}
		_, err = dst.WritePacket(req, packet)
		if err != nil {
			errChan <- err
			return
		}
	}
}

func proxyConn(a io.ReadWriteCloser, b io.ReadWriteCloser) {
	errChan := make(chan error, 2)
	go copyConn(a, b, errChan)
	go copyConn(b, a, errChan)
	err := <-errChan
	if err != nil {
		if err.Error() != "EOF" {
			logger.Error(common.NewError("conn proxy ends").Base(err))
		}
	} else {
		logger.Debug("conn proxy ends")
	}
}

func proxyPacket(a protocol.PacketReadWriter, b protocol.PacketReadWriter) {
	errChan := make(chan error, 2)
	go copyPacket(a, b, errChan)
	go copyPacket(b, a, errChan)
	err := <-errChan
	if err != nil {
		if err.Error() != "EOF" {
			logger.Error(common.NewError("packet proxy ends").Base(err))
		}
	} else {
		logger.Debug("packet proxy ends")
	}
}

func NewProxy(config *conf.GlobalConfig) common.Runnable {
	switch config.RunType {
	case conf.Client:
		client := &Client{
			config:  config,
			muxPool: make(map[muxID]*muxClientInfo),
		}
		return client
	case conf.Server:
		server := &Server{
			config: config,
		}
		return server
	case conf.Forward:
		forward := &Forward{
			config: config,
		}
		return forward
	case conf.NAT:
		nat := &NAT{
			config: config,
		}
		return nat
	default:
		panic("invalid run type")
	}
}