package redirect import ( "bufio" "bytes" "context" "crypto/tls" "fmt" "net" "strings" "time" "github.com/go-gost/core/handler" md "github.com/go-gost/core/metadata" "github.com/go-gost/core/observer/stats" "github.com/go-gost/core/recorder" xbypass "github.com/go-gost/x/bypass" ctxvalue "github.com/go-gost/x/ctx" xnet "github.com/go-gost/x/internal/net" "github.com/go-gost/x/internal/util/sniffing" tls_util "github.com/go-gost/x/internal/util/tls" rate_limiter "github.com/go-gost/x/limiter/rate" stats_wrapper "github.com/go-gost/x/observer/stats/wrapper" xrecorder "github.com/go-gost/x/recorder" "github.com/go-gost/x/registry" ) func init() { registry.HandlerRegistry().Register("red", NewHandler) registry.HandlerRegistry().Register("redir", NewHandler) registry.HandlerRegistry().Register("redirect", NewHandler) } type redirectHandler struct { md metadata options handler.Options recorder recorder.RecorderObject certPool tls_util.CertPool } func NewHandler(opts ...handler.Option) handler.Handler { options := handler.Options{} for _, opt := range opts { opt(&options) } return &redirectHandler{ options: options, } } func (h *redirectHandler) Init(md md.Metadata) (err error) { if err = h.parseMetadata(md); err != nil { return } for _, ro := range h.options.Recorders { if ro.Record == xrecorder.RecorderServiceHandler { h.recorder = ro break } } if h.md.certificate != nil && h.md.privateKey != nil { h.certPool = tls_util.NewMemoryCertPool() } return } func (h *redirectHandler) Handle(ctx context.Context, conn net.Conn, opts ...handler.HandleOption) (err error) { defer conn.Close() start := time.Now() ro := &xrecorder.HandlerRecorderObject{ Service: h.options.Service, Network: "tcp", RemoteAddr: conn.RemoteAddr().String(), LocalAddr: conn.LocalAddr().String(), Time: start, SID: string(ctxvalue.SidFromContext(ctx)), } ro.ClientIP, _, _ = net.SplitHostPort(conn.RemoteAddr().String()) log := h.options.Logger.WithFields(map[string]any{ "remote": conn.RemoteAddr().String(), "local": conn.LocalAddr().String(), "sid": ctxvalue.SidFromContext(ctx), }) log.Infof("%s <> %s", conn.RemoteAddr(), conn.LocalAddr()) pStats := stats.Stats{} conn = stats_wrapper.WrapConn(conn, &pStats) defer func() { if err != nil { ro.Err = err.Error() } ro.InputBytes = pStats.Get(stats.KindInputBytes) ro.OutputBytes = pStats.Get(stats.KindOutputBytes) ro.Duration = time.Since(start) if err := ro.Record(ctx, h.recorder.Recorder); err != nil { log.Errorf("record: %v", err) } log.WithFields(map[string]any{ "duration": time.Since(start), "inputBytes": ro.InputBytes, "outputBytes": ro.OutputBytes, }).Infof("%s >< %s", conn.RemoteAddr(), conn.LocalAddr()) }() if !h.checkRateLimit(conn.RemoteAddr()) { return rate_limiter.ErrRateLimit } var dstAddr net.Addr if h.md.tproxy { dstAddr = conn.LocalAddr() } else { dstAddr, err = h.getOriginalDstAddr(conn) if err != nil { log.Error(err) return } } ro.Host = dstAddr.String() log = log.WithFields(map[string]any{ "dst": fmt.Sprintf("%s/%s", dstAddr, dstAddr.Network()), }) if h.md.sniffing { if h.md.sniffingTimeout > 0 { conn.SetReadDeadline(time.Now().Add(h.md.sniffingTimeout)) } br := bufio.NewReader(conn) proto, _ := sniffing.Sniff(ctx, br) ro.Proto = proto if h.md.sniffingTimeout > 0 { conn.SetReadDeadline(time.Time{}) } dial := func(ctx context.Context, network, address string) (net.Conn, error) { var cc net.Conn var err error if address != "" { host, _, _ := net.SplitHostPort(address) if host == "" { host = address } _, port, _ := net.SplitHostPort(dstAddr.String()) address = net.JoinHostPort(strings.Trim(host, "[]"), port) ro.Host = address var buf bytes.Buffer cc, err = h.options.Router.Dial(ctxvalue.ContextWithBuffer(ctx, &buf), "tcp", address) ro.Route = buf.String() if err != nil && !h.md.sniffingFallback { return nil, err } } if cc == nil { if h.options.Bypass != nil && h.options.Bypass.Contains(ctx, "tcp", dstAddr.String()) { return nil, xbypass.ErrBypass } var buf bytes.Buffer cc, err = h.options.Router.Dial(ctxvalue.ContextWithBuffer(ctx, &buf), "tcp", dstAddr.String()) ro.Route = buf.String() ro.Host = dstAddr.String() } return cc, err } dialTLS := func(ctx context.Context, network, address string, cfg *tls.Config) (net.Conn, error) { return dial(ctx, network, address) } sniffer := &sniffing.Sniffer{ Recorder: h.recorder.Recorder, RecorderOptions: h.recorder.Options, Certificate: h.md.certificate, PrivateKey: h.md.privateKey, NegotiatedProtocol: h.md.alpn, CertPool: h.certPool, MitmBypass: h.md.mitmBypass, ReadTimeout: h.md.readTimeout, } conn = xnet.NewReadWriteConn(br, conn, conn) switch proto { case sniffing.ProtoHTTP: return sniffer.HandleHTTP(ctx, conn, sniffing.WithDial(dial), sniffing.WithDialTLS(dialTLS), sniffing.WithBypass(h.options.Bypass), sniffing.WithRecorderObject(ro), sniffing.WithLog(log), ) case sniffing.ProtoTLS: return sniffer.HandleTLS(ctx, conn, sniffing.WithDial(dial), sniffing.WithDialTLS(dialTLS), sniffing.WithBypass(h.options.Bypass), sniffing.WithRecorderObject(ro), sniffing.WithLog(log), ) } } log.Debugf("%s >> %s", conn.RemoteAddr(), dstAddr) if h.options.Bypass != nil && h.options.Bypass.Contains(ctx, dstAddr.Network(), dstAddr.String()) { log.Debug("bypass: ", dstAddr) return xbypass.ErrBypass } var buf bytes.Buffer cc, err := h.options.Router.Dial(ctxvalue.ContextWithBuffer(ctx, &buf), dstAddr.Network(), dstAddr.String()) ro.Route = buf.String() if err != nil { log.Error(err) return err } defer cc.Close() t := time.Now() log.Infof("%s <-> %s", conn.RemoteAddr(), dstAddr) xnet.Transport(conn, cc) log.WithFields(map[string]any{ "duration": time.Since(t), }).Infof("%s >-< %s", conn.RemoteAddr(), dstAddr) return nil } func (h *redirectHandler) checkRateLimit(addr net.Addr) bool { if h.options.RateLimiter == nil { return true } host, _, _ := net.SplitHostPort(addr.String()) if limiter := h.options.RateLimiter.Limiter(host); limiter != nil { return limiter.Allow(1) } return true }