@@ -1237,6 +1237,66 @@ func TestDesiredRouterDeploymentDynamicConfigManager(t *testing.T) {
12371237 }
12381238}
12391239
1240+ func TestDesiredRouterDeploymentMutualTLSHeaderFilter (t * testing.T ) {
1241+ testCases := []struct {
1242+ name string
1243+ unsupportedConfigOverrides string
1244+ expectedEnv []envData
1245+ }{
1246+ {
1247+ name : "not-set" ,
1248+ unsupportedConfigOverrides : `{}` ,
1249+ expectedEnv : []envData {
1250+ {"ROUTER_MUTUAL_TLS_HEADER_FILTER" , false , "" },
1251+ },
1252+ },
1253+ {
1254+ name : "set-to-false" ,
1255+ unsupportedConfigOverrides : `{"mutualTLSHeaderFilter":"false"}` ,
1256+ expectedEnv : []envData {
1257+ {"ROUTER_MUTUAL_TLS_HEADER_FILTER" , true , "false" },
1258+ },
1259+ },
1260+ {
1261+ name : "set-to-true" ,
1262+ unsupportedConfigOverrides : `{"mutualTLSHeaderFilter":"true"}` ,
1263+ expectedEnv : []envData {
1264+ {"ROUTER_MUTUAL_TLS_HEADER_FILTER" , false , "" },
1265+ },
1266+ },
1267+ {
1268+ name : "set-to-invalid-value" ,
1269+ unsupportedConfigOverrides : `{"mutualTLSHeaderFilter":"banana"}` ,
1270+ expectedEnv : []envData {
1271+ {"ROUTER_MUTUAL_TLS_HEADER_FILTER" , false , "" },
1272+ },
1273+ },
1274+ }
1275+ for _ , tc := range testCases {
1276+ t .Run (tc .name , func (t * testing.T ) {
1277+ ic := & operatorv1.IngressController {
1278+ ObjectMeta : metav1.ObjectMeta {
1279+ Name : "default" ,
1280+ },
1281+ Spec : operatorv1.IngressControllerSpec {
1282+ UnsupportedConfigOverrides : runtime.RawExtension {
1283+ Raw : []byte (tc .unsupportedConfigOverrides ),
1284+ },
1285+ },
1286+ Status : operatorv1.IngressControllerStatus {
1287+ EndpointPublishingStrategy : & operatorv1.EndpointPublishingStrategy {
1288+ Type : operatorv1 .PrivateStrategyType ,
1289+ },
1290+ },
1291+ }
1292+
1293+ deployment , err := desiredRouterDeployment (ic , & Config {IngressControllerImage : ingressControllerImage }, & configv1.Ingress {}, & configv1.Infrastructure {}, & configv1.APIServer {}, & configv1.Network {}, false , false , nil , & configv1.Proxy {})
1294+ assert .NoError (t , err )
1295+ assert .NoError (t , checkDeploymentEnvironment (t , deployment , tc .expectedEnv ))
1296+ })
1297+ }
1298+ }
1299+
12401300func checkContainerPort (t * testing.T , d * appsv1.Deployment , portName string , port int32 ) {
12411301 t .Helper ()
12421302 for _ , p := range d .Spec .Template .Spec .Containers [0 ].Ports {
0 commit comments