From e05d610882d85fb638b3491af2f62740ee7e7037 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=9E=D0=BB=D0=B5=D0=B3=20=D0=91=D0=BE=D1=80=D0=BE=D0=B4?=
 =?UTF-8?q?=D0=B8=D0=BD?= <onborodin@gmail.com>
Date: Wed, 25 Mar 2026 19:03:05 +0200
Subject: [PATCH] working commit

---
 app/rproxy/forwarder.go | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/app/rproxy/forwarder.go b/app/rproxy/forwarder.go
index 6c7efd7..669baf5 100644
--- a/app/rproxy/forwarder.go
+++ b/app/rproxy/forwarder.go
@@ -30,7 +30,7 @@ func NewForwarder(ctx context.Context, lport, dport uint32, addrs ...string) (*F
 		ctx:    ctx,
 		cancel: cancel,
 	}
-        id := strconv.FormatUint(uint64(lport), 10)
+	id := strconv.FormatUint(uint64(lport), 10)
 	forw.log = logger.NewLogger("forwarder:" + id)
 	for _, addr := range addrs {
 		dest := NewDestination(addr)
@@ -38,7 +38,7 @@ func NewForwarder(ctx context.Context, lport, dport uint32, addrs ...string) (*F
 	}
 
 	portinfo := ":" + strconv.FormatUint(uint64(forw.Lport), 10)
-        laddr, err := net.ResolveTCPAddr("tcp", portinfo)
+	laddr, err := net.ResolveTCPAddr("tcp", portinfo)
 	if err != nil {
 		return forw, err
 	}
@@ -68,18 +68,18 @@ func (forw *Forwarder) Stop() error {
 }
 
 type Streamer struct {
-        source string
-        dest string
-        ctx context.Context
-        cancel context.CancelFunc
+	source string
+	dest   string
+	ctx    context.Context
+	cancel context.CancelFunc
 }
 
 func NewStreamer(ctx context.Context) *Streamer {
-        ctx, cancel := context.WithCancel(ctx)
-        return &Streamer{
-                ctx: ctx,
-                cancel: cancel,
-        }
+	ctx, cancel := context.WithCancel(ctx)
+	return &Streamer{
+		ctx:    ctx,
+		cancel: cancel,
+	}
 }
 
 func (forw *Forwarder) handle(ctx context.Context, inconn net.Conn) {
@@ -95,7 +95,7 @@ func (forw *Forwarder) handle(ctx context.Context, inconn net.Conn) {
 	if err != nil {
 		return
 	}
-        defer outconn.Close()
+	defer outconn.Close()
 	var wg sync.WaitGroup
 	wg.Add(1)
 	go forw.stream(&wg, inconn, outconn)