BUG: fix ssl-redirect precedence order with configmap and ingress

Author: ivanmatmati

pkg/haproxy/rules/main.go

@@ -86,15 +86,15 @@ func (r SectionRules) AddRule(frontend string, rule Rule, ingressRule bool) erro
 	// Update frontend ruleSet
 	ruleType := rule.GetType()
 	ruleID := GetID(rule)
-	_, ok = ftRuleSet.meta[ruleID]
-	if ok {
-		// rule already created
-		ftRuleSet.meta[ruleID].state = CREATED
-	} else {
-		// rule to be created at next refresh
+	ruleInf, ok := ftRuleSet.meta[ruleID]
+	if ok && ruleInf.state == TO_DELETE {
+		// rule already created and planned to be deleted
+		ruleInf.state = CREATED
+	} else if !ok {
 		ftRuleSet.rules[ruleType] = append(ftRuleSet.rules[ruleType], rule)
 		ftRuleSet.meta[ruleID] = &ruleInfo{state: TO_CREATE}
 	}
+
 	if ingressRule {
 		ftRuleSet.meta[ruleID].ingress = true
 	}

pkg/ingress/ingress.go

@@ -145,7 +145,7 @@ func (i *Ingress) handleAnnotations(k store.K8s, h haproxy.HAProxy) {
 	var err error
 	var result = rules.List{}
 	for _, a := range i.annotations.Frontend(i.resource, &result, h.Maps) {
-		err = a.Process(k, i.resource.Annotations)
+		err = a.Process(k, i.resource.Annotations, k.ConfigMaps.Main.Annotations)
 		if err != nil {
 			logger.Errorf("Ingress '%s/%s': annotation %s: %s", i.resource.Namespace, i.resource.Name, a.GetName(), err)
 		}
@@ -168,6 +168,8 @@ func HandleCfgMapAnnotations(k store.K8s, h haproxy.HAProxy, a annotations.Annot
 
 func addRules(list rules.List, h haproxy.HAProxy, ingressRule bool) []rules.RuleID {
 	ruleIDs := make([]rules.RuleID, 0, len(list))
+	// To avoid inserting twice the same rule id in destinating map file
+	ruleIDSet := map[rules.RuleID]struct{}{}
 	defaultFrontends := []string{h.FrontHTTP, h.FrontHTTPS}
 	for _, rule := range list {
 		frontends := defaultFrontends
@@ -185,8 +187,12 @@ func addRules(list rules.List, h haproxy.HAProxy, ingressRule bool) []rules.Rule
 			}
 		}
 		for _, frontend := range frontends {
-			logger.Error(h.AddRule(frontend, rule, ingressRule))
-			ruleIDs = append(ruleIDs, rules.GetID(rule))
+			logger.Error(h.AddRule(frontend, rule, ingressRule || rule.GetType() == rules.REQ_REDIRECT))
+			idRule := rules.GetID(rule)
+			if _, ok := ruleIDSet[idRule]; !ok {
+				ruleIDs = append(ruleIDs, idRule)
+				ruleIDSet[idRule] = struct{}{}
+			}
 		}
 	}
 	return ruleIDs