fix: assumeThat Route CRD exists in CustomResourceValidationIT

Signed-off-by: Piotr Płaczek <piotrpdev@gmail.com>

Author: piotrpdev

kroxylicious-operator/src/test/java/io/kroxylicious/kubernetes/operator/CustomResourceValidationIT.java

@@ -10,6 +10,7 @@
 import java.io.InputStream;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.util.Objects;
 import java.util.stream.Stream;
 
 import org.assertj.core.api.Assertions;
@@ -32,6 +33,7 @@
 import io.fabric8.kubernetes.client.KubernetesClientException;
 import io.fabric8.kubernetes.client.dsl.NamespaceableResource;
 import io.fabric8.kubernetes.client.dsl.NonDeletingOperation;
+import io.fabric8.openshift.api.model.Route;
 import io.javaoperatorsdk.operator.junit.LocallyRunOperatorExtension;
 
 import io.kroxylicious.kubernetes.api.v1alpha1.KafkaProtocolFilter;
@@ -41,12 +43,14 @@
 import io.kroxylicious.kubernetes.api.v1alpha1.VirtualKafkaCluster;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assumptions.assumeThat;
 
 @EnabledIf(value = "io.kroxylicious.kubernetes.operator.OperatorTestUtils#isKubeClientAvailable", disabledReason = "no viable kube client available")
 class CustomResourceValidationIT {
 
     public static final Namespace NAMESPACE = new NamespaceBuilder().withNewMetadata().withName("proxy-ns").endMetadata().build();
     public static final ObjectMapper YAML_MAPPER = new ObjectMapper(new YAMLFactory());
+    private static boolean isOpenShiftRouteApiAvailable;
 
     @BeforeAll
     static void beforeAll() {
@@ -57,6 +61,8 @@ static void beforeAll() {
         LocallyRunOperatorExtension.applyCrd(KafkaService.class, client);
         LocallyRunOperatorExtension.applyCrd(KafkaProxyIngress.class, client);
         client.namespaces().resource(NAMESPACE).createOr(NonDeletingOperation::update);
+
+        isOpenShiftRouteApiAvailable = client.supports(Route.class);
     }
 
     @AfterAll
@@ -116,6 +122,7 @@ void testResourceValid(Path validYaml) {
     private static void testValid(Path validYaml) {
         try (InputStream is = Files.newInputStream(validYaml)) {
             NamespaceableResource<HasMetadata> resource = OperatorTestUtils.kubeClient().resource(is);
+            assumeThatOpenShiftRouteApiAvailable(resource);
             Assertions.assertThatCode(resource::create).doesNotThrowAnyException();
             Assertions.assertThatCode(resource::delete).doesNotThrowAnyException();
         }
@@ -139,6 +146,7 @@ String resourceAsString() {
     @ParameterizedTest
     void testResourceInvalid(InvalidResource invalidYaml) {
         NamespaceableResource<HasMetadata> resource = OperatorTestUtils.kubeClient().resource(invalidYaml.resourceAsString());
+        assumeThatOpenShiftRouteApiAvailable(resource);
         try {
             Assertions.assertThatThrownBy(resource::create).isInstanceOfSatisfying(KubernetesClientException.class, e -> {
                 Status status = e.getStatus();
@@ -166,6 +174,7 @@ public static Stream<Path> testResourceValidStatus() {
     void testResourceValidStatus(Path validYaml) {
         try (InputStream is = Files.newInputStream(validYaml)) {
             NamespaceableResource<HasMetadata> resource = OperatorTestUtils.kubeClient().resource(is);
+            assumeThatOpenShiftRouteApiAvailable(resource);
             Assertions.assertThatCode(resource::create).doesNotThrowAnyException();
             Assertions.assertThatCode(resource::patchStatus).doesNotThrowAnyException();
             Assertions.assertThatCode(resource::delete).doesNotThrowAnyException();
@@ -179,6 +188,7 @@ void testResourceValidStatus(Path validYaml) {
     @ParameterizedTest
     void testResourceInvalidStatus(InvalidResource invalidYaml) {
         NamespaceableResource<HasMetadata> resource = OperatorTestUtils.kubeClient().resource(invalidYaml.resourceAsString());
+        assumeThatOpenShiftRouteApiAvailable(resource);
         try {
             Assertions.assertThatCode(resource::create).doesNotThrowAnyException();
             Assertions.assertThatThrownBy(resource::patchStatus).isInstanceOfSatisfying(KubernetesClientException.class, e -> {
@@ -198,4 +208,10 @@ void testResourceInvalidStatus(InvalidResource invalidYaml) {
         }
     }
 
+    static void assumeThatOpenShiftRouteApiAvailable(NamespaceableResource<HasMetadata> resource) {
+        if (Objects.equals(resource.item().getKind(), "Route")) {
+            assumeThat(isOpenShiftRouteApiAvailable).withFailMessage("kubernetes server is missing support for resource kind Route").isTrue();
+        }
+    }
+
 }