fix: add clean up of applied CRDs after tests

Signed-off-by: xstefank <[email protected]>

Author: xstefank

operator-framework-junit5/src/main/java/io/javaoperatorsdk/operator/junit/LocallyRunOperatorExtension.java

@@ -10,12 +10,14 @@
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.stream.Stream;
 
+import io.fabric8.kubernetes.client.dsl.NamespaceListVisitFromServerGetDeleteRecreateWaitApplicable;
 import org.junit.jupiter.api.extension.ExtensionContext;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -48,6 +50,7 @@ public class LocallyRunOperatorExtension extends AbstractOperatorExtension {
   private final List<Class<? extends CustomResource>> additionalCustomResourceDefinitions;
   private final Map<Reconciler, RegisteredController> registeredControllers;
   private final Map<String, String> crdMappings;
+  private static final LinkedList<AppliedCRD> appliedCRDs = new LinkedList<>();
 
   private LocallyRunOperatorExtension(
       List<ReconcilerSpec> reconcilers,
@@ -144,6 +147,7 @@ private static void applyCrd(String crdString, String path, KubernetesClient cli
       LOGGER.debug("Applying CRD: {}", crdString);
       final var crd = client.load(new ByteArrayInputStream(crdString.getBytes()));
       crd.serverSideApply();
+      appliedCRDs.add(new AppliedCRD(crdString, path));
       Thread.sleep(CRD_READY_WAIT); // readiness is not applicable for CRD, just wait a little
       LOGGER.debug("Applied CRD with path: {}", path);
     } catch (InterruptedException ex) {
@@ -304,8 +308,29 @@ protected void after(ExtensionContext context) {
       }
     }
     localPortForwards.clear();
+
+    var kubernetesClient = getKubernetesClient();
+
+    while (!appliedCRDs.isEmpty()) {
+      deleteCrd(appliedCRDs.poll(), kubernetesClient);
+    }
+
+    kubernetesClient.close();
+  }
+
+  private void deleteCrd(AppliedCRD appliedCRD, KubernetesClient client) {
+    try {
+      LOGGER.debug("Deleting CRD: {}", appliedCRD.crdString);
+      final var crd = client.load(new ByteArrayInputStream(appliedCRD.crdString.getBytes()));
+      crd.withTimeoutInMillis(10000).delete();
+      LOGGER.debug("Deleted CRD with path: {}", appliedCRD.path);
+    } catch (Exception ex) {
+      throw new IllegalStateException("Cannot delete CRD yaml: " + appliedCRD.path, ex);
+    }
   }
 
+  private record AppliedCRD(String crdString, String path) {}
+
   @SuppressWarnings("rawtypes")
   public static class Builder extends AbstractBuilder<Builder> {
     private final List<ReconcilerSpec> reconcilers;