Ignore NS deleted events for not managed namespaces (#3983)

Author: doxiao

operator/src/main/java/oracle/kubernetes/operator/DomainNamespaces.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2020, 2022, Oracle and/or its affiliates.
+// Copyright (c) 2020, 2023, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
 
 package oracle.kubernetes.operator;
@@ -75,6 +75,10 @@ AtomicBoolean isStopping(String ns) {
     return namespaceStoppingMap.computeIfAbsent(ns, key -> new AtomicBoolean(false));
   }
 
+  AtomicBoolean getStopping(String ns) {
+    return namespaceStoppingMap.get(ns);
+  }
+
   boolean isStarting(String ns) {
     return Optional.ofNullable(namespaceStatuses.get(ns))
           .map(NamespaceStatus::isNamespaceStarting)

operator/src/main/java/oracle/kubernetes/operator/Namespaces.java

@@ -1,8 +1,9 @@
-// Copyright (c) 2020, 2022, Oracle and/or its affiliates.
+// Copyright (c) 2020, 2023, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
 
 package oracle.kubernetes.operator;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
@@ -271,7 +272,7 @@ static class NamespaceListAfterStep extends Step {
 
     @Override
     public NextAction apply(Packet packet) {
-      NamespaceValidationContext validationContext = new NamespaceValidationContext(packet);
+      NamespaceValidationContext validationContext = new NamespaceValidationContext(packet, domainNamespaces);
       getNonNullConfiguredDomainNamespaces().forEach(validationContext::validateConfiguredNamespace);
       List<StepAndPacket> nsStopEventSteps = getCreateNSStopEventSteps(packet, validationContext);
       stopRemovedNamespaces(validationContext);
@@ -280,18 +281,23 @@ public NextAction apply(Packet packet) {
 
     private List<StepAndPacket> getCreateNSStopEventSteps(Packet packet, NamespaceValidationContext validationContext) {
       return domainNamespaces.getNamespaces().stream()
-          .filter(validationContext::isNoLongerActiveDomainNamespace)
+          .filter(validationContext::isNotManaged)
           .map(n -> createNSStopEventDetails(packet, n)).collect(Collectors.toList());
     }
 
     private StepAndPacket createNSStopEventDetails(Packet packet, String namespace) {
       LOGGER.info(MessageKeys.END_MANAGING_NAMESPACE, namespace);
-      return new StepAndPacket(
-          Step.chain(
-              createEventStep(new EventData(NAMESPACE_WATCHING_STOPPED).resourceName(namespace).namespace(namespace)),
-              createEventStep(new EventData(STOP_MANAGING_NAMESPACE).resourceName(namespace)
-                  .namespace(getOperatorNamespace()))),
-          packet.copy());
+      return new StepAndPacket(getSteps(namespace), packet.copy());
+    }
+
+    private Step getSteps(String ns) {
+      List<Step> steps = new ArrayList<>();
+      if (!domainNamespaces.isStopping(ns).get()) {
+        steps.add(createEventStep(new EventData(NAMESPACE_WATCHING_STOPPED).resourceName(ns).namespace(ns)));
+      }
+      steps.add(createEventStep(
+          new EventData(STOP_MANAGING_NAMESPACE).resourceName(ns).namespace(getOperatorNamespace())));
+      return Step.chain(steps.toArray(new Step[0]));
     }
 
     private Step createNamespaceWatchStopEventsStep(List<StepAndPacket> nsStopEventDetails) {
@@ -333,9 +339,15 @@ private void stopRemovedNamespaces(NamespaceValidationContext validationContext)
   private static class NamespaceValidationContext {
 
     final Collection<String> allDomainNamespaces;
+    final DomainNamespaces domainNamespaces;
 
-    NamespaceValidationContext(Packet packet) {
+    NamespaceValidationContext(Packet packet, DomainNamespaces domainNamespaces) {
       allDomainNamespaces = Optional.ofNullable(getFoundDomainNamespaces(packet)).orElse(Collections.emptyList());
+      this.domainNamespaces = domainNamespaces;
+    }
+
+    private boolean isNotManaged(String ns) {
+      return !allDomainNamespaces.contains(ns) || domainNamespaces.isStopping(ns).get();
     }
 
     private boolean isNoLongerActiveDomainNamespace(String ns) {

operator/src/main/java/oracle/kubernetes/operator/OperatorMain.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2017, 2022, Oracle and/or its affiliates.
+// Copyright (c) 2017, 2023, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
 
 package oracle.kubernetes.operator;
@@ -445,7 +445,7 @@ void dispatchNamespaceWatch(Watch.Response<V1Namespace> item) {
       case "DELETED":
         // Mark the namespace as isStopping, which will cause the namespace be stopped
         // the next time when recheckDomains is triggered
-        mainDelegate.getDomainNamespaces().isStopping(ns).set(true);
+        Optional.ofNullable(mainDelegate.getDomainNamespaces().getStopping(ns)).ifPresent(n -> n.set(true));
 
         break;