fix: unwrap CDI proxies to get the proper class name

metacosm · metacosm · commit 7dc1c237f024 · 2021-01-15T11:46:53.000+01:00
diff --git a/operator-framework-quarkus-extension/runtime/src/main/java/io/javaoperatorsdk/quarkus/extension/QuarkusConfigurationService.java b/operator-framework-quarkus-extension/runtime/src/main/java/io/javaoperatorsdk/quarkus/extension/QuarkusConfigurationService.java
@@ -1,14 +1,18 @@
 package io.javaoperatorsdk.quarkus.extension;
 
 import io.fabric8.kubernetes.client.Config;
+import io.fabric8.kubernetes.client.CustomResource;
 import io.fabric8.kubernetes.client.KubernetesClient;
+import io.javaoperatorsdk.operator.api.ResourceController;
 import io.javaoperatorsdk.operator.api.config.AbstractConfigurationService;
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
+import io.quarkus.arc.runtime.ClientProxyUnwrapper;
 import java.util.List;
 import javax.inject.Inject;
 
 public class QuarkusConfigurationService extends AbstractConfigurationService {
   @Inject KubernetesClient client;
+  private static final ClientProxyUnwrapper unwrapper = new ClientProxyUnwrapper();
 
   public QuarkusConfigurationService(List<ControllerConfiguration> configurations) {
     if (configurations != null && !configurations.isEmpty()) {
@@ -20,4 +24,16 @@ public QuarkusConfigurationService(List<ControllerConfiguration> configurations)
   public Config getClientConfiguration() {
     return client.getConfiguration();
   }
+
+  @Override
+  public <R extends CustomResource> ControllerConfiguration<R> getConfigurationFor(
+      ResourceController<R> controller) {
+    final var unwrapped = unwrap(controller);
+    return super.getConfigurationFor(unwrapped);
+  }
+
+  private static <R extends CustomResource> ResourceController<R> unwrap(
+      ResourceController<R> controller) {
+    return (ResourceController<R>) unwrapper.apply(controller);
+  }
 }
