Add new CDI test module and add tests for conditions injections

integration-tests/cdi/pom.xml

@@ -0,0 +1,160 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>io.quarkiverse.operatorsdk</groupId>
+    <artifactId>quarkus-operator-sdk-integration-tests-parent</artifactId>
+    <version>7.3.1-SNAPSHOT</version>
+    <relativePath>../pom.xml</relativePath>
+  </parent>
+  <artifactId>quarkus-operator-sdk-integration-tests-cdi</artifactId>
+  <name>Quarkus - Operator SDK - Integration Tests - CDI</name>
+  <dependencies>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-resteasy</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkiverse.operatorsdk</groupId>
+      <artifactId>quarkus-operator-sdk</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-junit5</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-test-kubernetes-client</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-resteasy-jackson</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.rest-assured</groupId>
+      <artifactId>rest-assured</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.awaitility</groupId>
+      <artifactId>awaitility</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <!--  to check that MeterRegistry are properly bound to custom Metrics implementations -->
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-micrometer-registry-prometheus</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.bouncycastle</groupId>
+      <artifactId>bcpkix-jdk18on</artifactId>
+      <optional>true</optional>
+    </dependency>
+  </dependencies>
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>io.quarkus</groupId>
+        <artifactId>quarkus-maven-plugin</artifactId>
+        <executions>
+          <execution>
+            <goals>
+              <goal>build</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-jar-plugin</artifactId>
+        <executions>
+          <execution>
+            <goals>
+              <goal>test-jar</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <configuration>
+          <environmentVariables>
+            <NAMESPACE_FROM_ENV>fromEnvVarNS</NAMESPACE_FROM_ENV>
+            <QUARKUS_OPERATOR_SDK_CONTROLLERS_EMPTY_NAMESPACES>fromEnv1,fromEnv2
+            </QUARKUS_OPERATOR_SDK_CONTROLLERS_EMPTY_NAMESPACES>
+            <VARIABLE_NS_ENV>variableNSFromEnv</VARIABLE_NS_ENV>
+            <QUARKUS_OPERATOR_SDK_CONTROLLERS_KEYCLOAKCONTROLLER_NAMESPACES>JOSDK_ALL_NAMESPACES
+            </QUARKUS_OPERATOR_SDK_CONTROLLERS_KEYCLOAKCONTROLLER_NAMESPACES>
+          </environmentVariables>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+  <profiles>
+    <profile>
+      <id>native-image</id>
+      <activation>
+        <property>
+          <name>native</name>
+        </property>
+      </activation>
+      <build>
+        <plugins>
+          <plugin>
+            <artifactId>maven-surefire-plugin</artifactId>
+            <configuration>
+              <skipTests>${native.surefire.skip}</skipTests>
+              <systemPropertyVariables>
+                <java.util.logging.manager>org.jboss.logmanager.LogManager
+                </java.util.logging.manager>
+                <maven.home>${maven.home}</maven.home>
+              </systemPropertyVariables>
+              <environmentVariables>
+                <NAMESPACE_FROM_ENV>fromEnvVarNS</NAMESPACE_FROM_ENV>
+                <QUARKUS_OPERATOR_SDK_CONTROLLERS_EMPTY_NAMESPACES>fromEnv1,fromEnv2
+                </QUARKUS_OPERATOR_SDK_CONTROLLERS_EMPTY_NAMESPACES>
+                <VARIABLE_NS_ENV>variableNSFromEnv</VARIABLE_NS_ENV>
+                <QUARKUS_OPERATOR_SDK_CONTROLLERS_KEYCLOAKCONTROLLER_NAMESPACES>JOSDK_ALL_NAMESPACES
+                </QUARKUS_OPERATOR_SDK_CONTROLLERS_KEYCLOAKCONTROLLER_NAMESPACES>
+              </environmentVariables>
+            </configuration>
+          </plugin>
+          <plugin>
+            <artifactId>maven-failsafe-plugin</artifactId>
+            <executions>
+              <execution>
+                <goals>
+                  <goal>integration-test</goal>
+                  <goal>verify</goal>
+                </goals>
+                <configuration>
+                  <systemPropertyVariables>
+                    <native.image.path>
+                      ${project.build.directory}/${project.build.finalName}-runner
+                    </native.image.path>
+                    <java.util.logging.manager>org.jboss.logmanager.LogManager
+                    </java.util.logging.manager>
+                    <maven.home>${maven.home}</maven.home>
+                  </systemPropertyVariables>
+                  <environmentVariables>
+                    <NAMESPACE_FROM_ENV>fromEnvVarNS</NAMESPACE_FROM_ENV>
+                    <QUARKUS_OPERATOR_SDK_CONTROLLERS_EMPTY_NAMESPACES>fromEnv1,fromEnv2
+                    </QUARKUS_OPERATOR_SDK_CONTROLLERS_EMPTY_NAMESPACES>
+                    <VARIABLE_NS_ENV>variableNSFromEnv</VARIABLE_NS_ENV>
+                    <QUARKUS_OPERATOR_SDK_CONTROLLERS_KEYCLOAKCONTROLLER_NAMESPACES>JOSDK_ALL_NAMESPACES
+                    </QUARKUS_OPERATOR_SDK_CONTROLLERS_KEYCLOAKCONTROLLER_NAMESPACES>
+                  </environmentVariables>
+                </configuration>
+              </execution>
+            </executions>
+          </plugin>
+        </plugins>
+      </build>
+      <properties>
+        <quarkus.package.type>native</quarkus.package.type>
+      </properties>
+    </profile>
+  </profiles>
+</project>

integration-tests/cdi/src/main/java/io/quarkiverse/operatorsdk/it/cdi/ConfigMapDependent.java

@@ -0,0 +1,57 @@
+package io.quarkiverse.operatorsdk.it.cdi;
+
+import java.util.Map;
+import java.util.Optional;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDKubernetesDependentResource;
+import io.javaoperatorsdk.operator.processing.event.ResourceID;
+
+public class ConfigMapDependent extends CRUDKubernetesDependentResource<ConfigMap, TestResource> {
+
+    private static final Logger log = LoggerFactory.getLogger(ConfigMapDependent.class);
+
+    @Override
+    protected ConfigMap desired(TestResource primary, Context<TestResource> context) {
+        Optional<ConfigMap> optionalConfigMap = getConfigMap(primary, context);
+        if (!optionalConfigMap.isPresent()) {
+            ConfigMap configMap = new ConfigMap();
+            configMap.setMetadata(
+                    new ObjectMetaBuilder()
+                            .withName(primary.getMetadata().getName() + "-cm")
+                            .withNamespace(primary.getMetadata().getNamespace())
+                            .build());
+            configMap.setData(Map.of("key", "data"));
+            return configMap;
+        }
+        return optionalConfigMap.get();
+    }
+
+    @Override
+    public void delete(TestResource primary, Context<TestResource> context) {
+        Optional<ConfigMap> optionalConfigMap = getConfigMap(primary, context);
+        if (optionalConfigMap == null)
+            return;
+        optionalConfigMap.ifPresent(
+                (configMap -> {
+                    if (configMap.getMetadata().getAnnotations() != null) {
+                        context.getClient().resource(configMap).delete();
+                    }
+                }));
+
+    }
+
+    private static Optional<ConfigMap> getConfigMap(TestResource primary, Context<TestResource> context) {
+        Optional<ConfigMap> optionalConfigMap = context.getSecondaryResource(ConfigMap.class);
+        if (optionalConfigMap.isEmpty()) {
+            log.debug("Config Map not found for primary: {}", ResourceID.fromResource(primary));
+            return Optional.empty();
+        }
+        return optionalConfigMap;
+    }
+}

integration-tests/cdi/src/main/java/io/quarkiverse/operatorsdk/it/cdi/CustomActionvationCondition.java

@@ -0,0 +1,30 @@
+package io.quarkiverse.operatorsdk.it.cdi;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+import io.quarkus.arc.Unremovable;
+
+@ApplicationScoped
+@Unremovable
+public class CustomActionvationCondition implements Condition {
+
+    @Inject
+    TestUUIDBean testUUIDBean;
+
+    private String uuid;
+
+    @Override
+    public boolean isMet(DependentResource dependentResource, HasMetadata primary, Context context) {
+        uuid = testUUIDBean.uuid();
+        return true;
+    }
+
+    public String getUuid() {
+        return uuid;
+    }
+}

integration-tests/cdi/src/main/java/io/quarkiverse/operatorsdk/it/cdi/DeletePostCondition.java

@@ -0,0 +1,30 @@
+package io.quarkiverse.operatorsdk.it.cdi;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+import io.quarkus.arc.Unremovable;
+
+@ApplicationScoped
+@Unremovable
+public class DeletePostCondition implements Condition {
+
+    @Inject
+    TestUUIDBean testUUIDBean;
+
+    private String uuid;
+
+    @Override
+    public boolean isMet(DependentResource dependentResource, HasMetadata primary, Context context) {
+        this.uuid = testUUIDBean.uuid();
+        return true;
+    }
+
+    public String getUuid() {
+        return uuid;
+    }
+}

integration-tests/cdi/src/main/java/io/quarkiverse/operatorsdk/it/cdi/DeploymentDependent.java

@@ -0,0 +1,37 @@
+package io.quarkiverse.operatorsdk.it.cdi;
+
+import java.util.Map;
+
+import org.jboss.logging.Logger;
+
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.fabric8.kubernetes.api.model.apps.Deployment;
+import io.fabric8.kubernetes.api.model.apps.DeploymentBuilder;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDNoGCKubernetesDependentResource;
+
+public class DeploymentDependent extends CRUDNoGCKubernetesDependentResource<Deployment, TestResource> {
+
+    private static final Logger LOG = Logger.getLogger(DeploymentDependent.class);
+
+    @Override
+    protected Deployment desired(TestResource primary, Context<TestResource> context) {
+        return new DeploymentBuilder()
+                .withMetadata(new ObjectMetaBuilder()
+                        .withName(primary.getMetadata().getName() + "-deployment")
+                        .withNamespace("default")
+                        .withLabels(Map.of("app", primary.getMetadata().getName()))
+                        .build())
+                .withNewSpec()
+                .withNewSelector().withMatchLabels(Map.of("app", primary.getMetadata().getName())).endSelector()
+                .withNewTemplate().withNewMetadata().withLabels(Map.of("app", primary.getMetadata().getName())).endMetadata()
+                .withNewSpec().addNewContainer()
+                .withName("nginx").withImage("nginx:1.14.2")
+                .addNewPort().withName("http").withProtocol("TCP").withContainerPort(8080).endPort()
+                .endContainer()
+                .endSpec()
+                .endTemplate()
+                .endSpec()
+                .build();
+    }
+}

integration-tests/cdi/src/main/java/io/quarkiverse/operatorsdk/it/cdi/ReadyPostCondition.java

@@ -0,0 +1,34 @@
+package io.quarkiverse.operatorsdk.it.cdi;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+
+import io.fabric8.kubernetes.api.model.apps.Deployment;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+import io.quarkus.arc.Unremovable;
+
+@ApplicationScoped
+@Unremovable
+public class ReadyPostCondition implements Condition<Deployment, TestResource> {
+
+    @Inject
+    TestUUIDBean testUUIDBean;
+
+    private String uuid;
+
+    @Override
+    public boolean isMet(DependentResource<Deployment, TestResource> dependentResource, TestResource primary,
+            Context<TestResource> context) {
+        uuid = testUUIDBean.uuid();
+        return dependentResource
+                .getSecondaryResource(primary, context)
+                .map(deployment -> deployment.getSpec().getReplicas().equals(1))
+                .orElse(false);
+    }
+
+    public String getUuid() {
+        return uuid;
+    }
+}

integration-tests/cdi/src/main/java/io/quarkiverse/operatorsdk/it/cdi/ReconcilePrecondition.java

@@ -0,0 +1,31 @@
+package io.quarkiverse.operatorsdk.it.cdi;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+import io.quarkus.arc.Unremovable;
+
+@ApplicationScoped
+@Unremovable
+public class ReconcilePrecondition implements Condition {
+
+    @Inject
+    TestUUIDBean testUUIDBean;
+
+    private String uuid;
+
+    @Override
+
+    public boolean isMet(DependentResource dependentResource, HasMetadata primary, Context context) {
+        uuid = testUUIDBean.uuid();
+        return true;
+    }
+
+    public String getUuid() {
+        return uuid;
+    }
+}