[Bugfix] Ensure NodePort wont be duplicated (#1209)

CHANGELOG.md

@@ -42,6 +42,7 @@
 - (Bugfix) Change member port discovery
 - (Feature) Do not change external service ports
 - (Bugfix) Fix Operator Debug mode
+- (Bugfix) Ensure NodePort wont be duplicated
 
 ## [1.2.20](https://github.com/arangodb/kube-arangodb/tree/1.2.20) (2022-10-25)
 - (Feature) Add action progress

pkg/deployment/resources/services.go

@@ -375,7 +375,7 @@ func (r *Resources) ensureExternalAccessManagedServices(ctx context.Context, cac
 
 	apply := func(svc *core.Service) (bool, error) {
 		return patcher.ServicePatcher(ctx, cachedStatus.ServicesModInterface().V1(), svc, meta.PatchOptions{},
-			patcher.PatchServiceOnlyPorts(ports...),
+			patcher.PatchServiceOnlyPortsWithoutNodePort(ports...),
 			patcher.PatchServiceSelector(selectors))
 	}
 

pkg/util/k8sutil/patcher/service.go

@@ -149,9 +149,58 @@ func PatchServiceOnlyPorts(ports ...core.ServicePort) ServicePatch {
 	}
 }
 
+func PatchServiceOnlyPortsWithoutNodePort(ports ...core.ServicePort) ServicePatch {
+	return func(in *core.Service) []patch.Item {
+		psvc := in.Spec.DeepCopy()
+		cp := psvc.Ports
+
+		changed := false
+
+		for pid := range ports {
+			got := false
+			for id := range cp {
+				if ports[pid].Name == cp[id].Name {
+					got = true
+
+					// Set ignored fields
+					if ports[pid].AppProtocol == nil {
+						ports[pid].AppProtocol = cp[id].AppProtocol
+					}
+					if ports[pid].Protocol == "" {
+						ports[pid].Protocol = cp[id].Protocol
+					}
+					if ports[pid].TargetPort.StrVal == "" && ports[pid].TargetPort.IntVal == 0 {
+						ports[pid].TargetPort = cp[id].TargetPort
+					}
+
+					if !equality.Semantic.DeepEqual(ports[pid], cp[id]) {
+						q := ports[pid].DeepCopy()
+						cp[id] = *q
+						changed = true
+						break
+					}
+				}
+			}
+			if !got {
+				q := ports[pid].DeepCopy()
+				cp = append(cp, *q)
+				changed = true
+			}
+		}
+
+		if !changed {
+			return nil
+		}
+
+		return []patch.Item{
+			patch.ItemReplace(patch.NewPath("spec", "ports"), cp),
+		}
+	}
+}
+
 func PatchServiceSelector(selector map[string]string) ServicePatch {
 	return func(in *core.Service) []patch.Item {
-		if equality.Semantic.DeepEqual(in.Spec.Selector, selector) {
+		if in.Spec.Selector != nil && equality.Semantic.DeepEqual(in.Spec.Selector, selector) {
 			return nil
 		}