feat: embed terasu inside

ingress/origin_dialer.go

@@ -8,6 +8,7 @@ import (
 	"sync"
 	"time"
 
+	"github.com/fumiama/terasu"
 	"github.com/rs/zerolog"
 )
 
@@ -87,7 +88,7 @@ func (d *OriginDialerService) DialTCP(ctx context.Context, addr netip.AddrPort)
 	}
 	// Assign the write timeout for the TCP operations
 	return &tcpConnection{
-		Conn:         conn,
+		Conn:         terasu.NewConn(conn),
 		writeTimeout: d.writeTimeout,
 		logger:       d.logger,
 	}, nil

ingress/origin_proxy.go

@@ -7,6 +7,7 @@ import (
 	"net"
 	"net/http"
 
+	"github.com/fumiama/terasu"
 	"github.com/rs/zerolog"
 )
 
@@ -64,6 +65,9 @@ func (o *httpService) SetOriginServerName(req *http.Request) {
 		if err != nil {
 			return nil, err
 		}
+		if tc, ok := conn.(*net.TCPConn); ok {
+			conn = terasu.NewConn(tc)
+		}
 		return tls.Client(conn, &tls.Config{
 			RootCAs:            o.transport.TLSClientConfig.RootCAs,
 			InsecureSkipVerify: o.transport.TLSClientConfig.InsecureSkipVerify, // nolint: gosec