Match headers using canonical casing

Author: Erich Shan

config/crd/bases/http.keda.sh_httpscaledobjects.yaml

@@ -97,7 +97,6 @@ spec:
                     - name
                     - value
                 type: array
-                uniqueItems: true
               replicas:
                 description: (optional) Replica information
                 properties:

interceptor/middleware/routing.go

@@ -43,7 +43,9 @@ var _ http.Handler = (*Routing)(nil)
 func (rm *Routing) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	r = util.RequestWithLoggerWithName(r, "RoutingMiddleware")
 
+	// logger := util.LoggerFromContext(r.Context())
 	httpso := rm.routingTable.Route(r)
+
 	if httpso == nil {
 		if rm.isProbe(r) {
 			rm.probeHandler.ServeHTTP(w, r)

operator/apis/http/v1alpha1/zz_generated.deepcopy.go

@@ -1,6 +1,8 @@
 package routing
 
 import (
+	"net/textproto"
+
 	"k8s.io/apimachinery/pkg/types"
 
 	httpv1alpha1 "github.com/kedacore/http-add-on/operator/apis/http/v1alpha1"
@@ -103,11 +105,14 @@ func (tm tableMemory) RouteWithHeaders(key Key, httpHeaders map[string][]string)
 		return httpsoList.Items[0]
 	}
 	var httpsoWithoutHeaders *httpv1alpha1.HTTPScaledObject
+
 	// route to first httpso which has a matching header
 	for _, httpso := range httpsoList.Items {
 		if httpso.Spec.Headers != nil {
 			for _, header := range httpso.Spec.Headers {
-				if headerValues, exists := httpHeaders[header.Name]; exists {
+				// normalize header spacing how golang does it
+				canonicalHeaderName := textproto.CanonicalMIMEHeaderKey(header.Name)
+				if headerValues, exists := httpHeaders[canonicalHeaderName]; exists {
 					for _, v := range headerValues {
 						if header.Value == v {
 							return httpso
@@ -124,7 +129,6 @@ func (tm tableMemory) RouteWithHeaders(key Key, httpHeaders map[string][]string)
 	if httpsoWithoutHeaders != nil {
 		return httpsoWithoutHeaders
 	}
-
 	// otherwise routing fails
 	return nil
 }