Update(CleanupTests): Clean clusterwide/namespaced operator

Apicurio · Feb 3, 2025 · 7e2888d · 7e2888d
1 parent 06b4f66
commit 7e2888d
Showing 1 changed file with 35 additions and 12 deletions.
diff --git a/src/test/java/io/apicurio/registry/systemtests/CleanupTests.java b/src/test/java/io/apicurio/registry/systemtests/CleanupTests.java
@@ -13,20 +13,20 @@ public class CleanupTests {
 
     @Test
     public void cleanupCluster() {
-        // Namespace with PostgreSQL database
-        if (Kubernetes.getNamespace(Constants.DB_NAMESPACE) != null) {
-            LOGGER.info("Deleting Namespace {}...", Constants.DB_NAMESPACE);
-
-            Kubernetes.deleteNamespace(Constants.DB_NAMESPACE);
-        }
-
         // Namespace with all test resources
         if (Kubernetes.getNamespace(Environment.NAMESPACE) != null) {
             LOGGER.info("Deleting Namespace {}...", Environment.NAMESPACE);
 
             Kubernetes.deleteNamespace(Environment.NAMESPACE);
         }
 
+        // Namespace with PostgreSQL database
+        if (Kubernetes.getNamespace(Constants.DB_NAMESPACE) != null) {
+            LOGGER.info("Deleting Namespace {}...", Constants.DB_NAMESPACE);
+
+            Kubernetes.deleteNamespace(Constants.DB_NAMESPACE);
+        }
+
         // ### KAFKA OPERATOR
         // Subscription of Kafka operator
         if (Kubernetes.getSubscription(Environment.CLUSTER_WIDE_NAMESPACE, Constants.KAFKA_SUBSCRIPTION_NAME) != null) {
@@ -59,17 +59,40 @@ public void cleanupCluster() {
         }
 
         // ClusterServiceVersion of Registry operator
-        ClusterServiceVersion csvRegistry = Kubernetes.getClusterServiceVersionByPrefix(
+        ClusterServiceVersion csvRegistryClusterWide = Kubernetes.getClusterServiceVersionByPrefix(
                 Environment.CLUSTER_WIDE_NAMESPACE,
                 Constants.REGISTRY_CSV_PREFIX
         );
 
-        if (csvRegistry != null) {
-            LOGGER.info("Deleting ClusterServiceVersion {}...", csvRegistry.getMetadata().getName());
+        if (csvRegistryClusterWide != null) {
+            LOGGER.info("Deleting ClusterServiceVersion {}...", csvRegistryClusterWide.getMetadata().getName());
+
+            Kubernetes.deleteClusterServiceVersion(
+                    csvRegistryClusterWide.getMetadata().getNamespace(),
+                    csvRegistryClusterWide.getMetadata().getName()
+            );
+        }
+
+        // ### REGISTRY OPERATOR
+        // Subscription of namespace Registry operator
+        if (Kubernetes.getSubscription(Environment.NAMESPACE, Constants.REGISTRY_SUBSCRIPTION) != null) {
+            LOGGER.info("Deleting Subscription {}...", Constants.REGISTRY_SUBSCRIPTION);
+
+            Kubernetes.deleteSubscription(Environment.NAMESPACE, Constants.REGISTRY_SUBSCRIPTION);
+        }
+
+        // ClusterServiceVersion of Registry operator
+        ClusterServiceVersion csvRegistryNamespaced = Kubernetes.getClusterServiceVersionByPrefix(
+                Environment.NAMESPACE,
+                Constants.REGISTRY_CSV_PREFIX
+        );
+
+        if (csvRegistryNamespaced != null) {
+            LOGGER.info("Deleting ClusterServiceVersion {}...", csvRegistryNamespaced.getMetadata().getName());
 
             Kubernetes.deleteClusterServiceVersion(
-                    csvRegistry.getMetadata().getNamespace(),
-                    csvRegistry.getMetadata().getName()
+                    csvRegistryNamespaced.getMetadata().getNamespace(),
+                    csvRegistryNamespaced.getMetadata().getName()
             );
         }