feat: use envoy extensions to preserve case for http1 header (#754)

* refactor: optimize ssh log

* feat: use envoy extensions preserve_casev3 to preserve http1 header case

* feat: use envoy extensions preserve_casev3 to preserve http1 header case

Author: wencaiwulue

pkg/controlplane/cache.go

@@ -21,6 +21,7 @@ import (
 	dstv3inspector "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/listener/original_dst/v3"
 	httpconnectionmanager "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/http_connection_manager/v3"
 	tcpproxy "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/tcp_proxy/v3"
+	preservecasev3 "github.com/envoyproxy/go-control-plane/envoy/extensions/http/header_formatters/preserve_case/v3"
 	httpv3 "github.com/envoyproxy/go-control-plane/envoy/extensions/upstreams/http/v3"
 	matcher "github.com/envoyproxy/go-control-plane/envoy/type/matcher/v3"
 	"github.com/envoyproxy/go-control-plane/pkg/cache/types"
@@ -78,6 +79,14 @@ func ConvertContainerPort(ports ...corev1.ContainerPort) []ContainerPort {
 	return result
 }
 
+// createPreserveCaseConfig creates a TypedExtensionConfig for preserving header case
+func createPreserveCaseConfig(anyFunc func(m proto.Message) *anypb.Any) *corev3.TypedExtensionConfig {
+	return &corev3.TypedExtensionConfig{
+		Name:        "preserve_case",
+		TypedConfig: anyFunc(&preservecasev3.PreserveCaseFormatterConfig{}),
+	}
+}
+
 type Rule struct {
 	Headers      map[string]string
 	LocalTunIPv4 string
@@ -213,7 +222,15 @@ func ToCluster(clusterName string) *cluster.Cluster {
 					IdleTimeout: durationpb.New(time.Second * 10),
 				},
 				UpstreamProtocolOptions: &httpv3.HttpProtocolOptions_UseDownstreamProtocolConfig{
-					UseDownstreamProtocolConfig: &httpv3.HttpProtocolOptions_UseDownstreamHttpConfig{},
+					UseDownstreamProtocolConfig: &httpv3.HttpProtocolOptions_UseDownstreamHttpConfig{
+						HttpProtocolOptions: &corev3.Http1ProtocolOptions{
+							HeaderKeyFormat: &corev3.Http1ProtocolOptions_HeaderKeyFormat{
+								HeaderFormat: &corev3.Http1ProtocolOptions_HeaderKeyFormat_StatefulFormatter{
+									StatefulFormatter: createPreserveCaseConfig(anyFunc),
+								},
+							},
+						},
+					},
 				},
 			}),
 		},
@@ -236,7 +253,15 @@ func OriginCluster() *cluster.Cluster {
 		TypedExtensionProtocolOptions: map[string]*anypb.Any{
 			"envoy.extensions.upstreams.http.v3.HttpProtocolOptions": anyFunc(&httpv3.HttpProtocolOptions{
 				UpstreamProtocolOptions: &httpv3.HttpProtocolOptions_UseDownstreamProtocolConfig{
-					UseDownstreamProtocolConfig: &httpv3.HttpProtocolOptions_UseDownstreamHttpConfig{},
+					UseDownstreamProtocolConfig: &httpv3.HttpProtocolOptions_UseDownstreamHttpConfig{
+						HttpProtocolOptions: &corev3.Http1ProtocolOptions{
+							HeaderKeyFormat: &corev3.Http1ProtocolOptions_HeaderKeyFormat{
+								HeaderFormat: &corev3.Http1ProtocolOptions_HeaderKeyFormat_StatefulFormatter{
+									StatefulFormatter: createPreserveCaseConfig(anyFunc),
+								},
+							},
+						},
+					},
 				},
 			}),
 		},
@@ -399,6 +424,14 @@ func ToListener(listenerName string, routeName string, port int32, p corev1.Prot
 				}),
 			},
 		}},
+		// Configure HTTP protocol options to preserve header case
+		HttpProtocolOptions: &corev3.Http1ProtocolOptions{
+			HeaderKeyFormat: &corev3.Http1ProtocolOptions_HeaderKeyFormat{
+				HeaderFormat: &corev3.Http1ProtocolOptions_HeaderKeyFormat_StatefulFormatter{
+					StatefulFormatter: createPreserveCaseConfig(anyFunc),
+				},
+			},
+		},
 	}
 
 	tcpConfig := &tcpproxy.TcpProxy{

pkg/ssh/ssh.go

@@ -104,7 +104,6 @@ func PortMapUntil(ctx context.Context, conf *SshConfig, remote, local netip.Addr
 				plog.G(ctx).Debugf("Failed to accept ssh conn: %v", err1)
 				continue
 			}
-			plog.G(ctx).Debugf("Accepted ssh conn from %s", localConn.RemoteAddr().String())
 			go func() {
 				defer localConn.Close()
 
@@ -117,10 +116,10 @@ func PortMapUntil(ctx context.Context, conf *SshConfig, remote, local netip.Addr
 						cancelFunc1()
 						return
 					}
-					plog.G(ctx).Debugf("Failed to dial into remote %s: %v", remote.String(), err)
+					plog.G(ctx).Debugf("Failed to dial remote from %s<=>%s -> %s: %v", localConn.LocalAddr().String(), localConn.RemoteAddr().String(), remote.String(), err)
 					return
 				}
-				plog.G(ctx).Debugf("Opened ssh port-forward to %s", remote.String())
+				plog.G(ctx).Debugf("Opened ssh port-forward to %s<=>%s -> %s", localConn.LocalAddr().String(), localConn.RemoteAddr().String(), remote.String())
 
 				defer remoteConn.Close()
 				copyStream(ctx, localConn, remoteConn)