feat(crd-generator): Add CRD-Generator Maven plugin

crd-generator/api-v2/src/main/java/io/fabric8/crdv2/generator/CRDGenerator.java

@@ -32,6 +32,7 @@
 import java.net.URI;
 import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
+import java.util.Collection;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -42,7 +43,6 @@
 import java.util.concurrent.ForkJoinPool;
 import java.util.concurrent.ForkJoinTask;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 public class CRDGenerator {
 
@@ -112,7 +112,27 @@ Map<String, AbstractCustomResourceHandler> getHandlers() {
   // (we also cannot use @SafeVarargs, because that requires the method to be final, which is another signature change)
   @SuppressWarnings("unchecked")
   public final CRDGenerator customResourceClasses(Class<? extends HasMetadata>... crClasses) {
-    return customResources(Stream.of(crClasses).map(CustomResourceInfo::fromClass).toArray(CustomResourceInfo[]::new));
+    if (crClasses == null) {
+      return this;
+    }
+    return customResourceClasses(Arrays.asList(crClasses));
+  }
+
+  public CRDGenerator customResourceClasses(Collection<Class<? extends HasMetadata>> crClasses) {
+    if (crClasses == null) {
+      return this;
+    }
+    return customResources(crClasses.stream()
+        .filter(Objects::nonNull)
+        .map(CustomResourceInfo::fromClass)
+        .toArray(CustomResourceInfo[]::new));
+  }
+
+  public CRDGenerator customResources(Collection<CustomResourceInfo> infos) {
+    if (infos == null) {
+      return this;
+    }
+    return customResources(infos.toArray(new CustomResourceInfo[0]));
   }
 
   public CRDGenerator customResources(CustomResourceInfo... infos) {

crd-generator/api-v2/src/test/java/io/fabric8/crdv2/generator/CRDGeneratorTest.java

@@ -29,6 +29,7 @@
 import io.fabric8.crdv2.example.nocyclic.NoCyclic;
 import io.fabric8.crdv2.example.simplest.Simplest;
 import io.fabric8.crdv2.generator.CRDGenerator.AbstractCRDOutput;
+import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceColumnDefinition;
 import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition;
 import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinitionNames;
@@ -51,6 +52,7 @@
 import java.net.URL;
 import java.nio.file.Files;
 import java.util.ArrayList;
+import java.util.Collection;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -109,12 +111,27 @@ void addingCustomResourceInfosShouldWork() {
     generator.customResources();
     assertTrue(generator.getCustomResourceInfos().isEmpty());
 
-    generator.customResources(null);
+    generator.customResources((CustomResourceInfo[]) null);
+    assertTrue(generator.getCustomResourceInfos().isEmpty());
+
+    generator.customResources((CustomResourceInfo) null);
+    assertTrue(generator.getCustomResourceInfos().isEmpty());
+
+    generator.customResources((Collection<CustomResourceInfo>) null);
     assertTrue(generator.getCustomResourceInfos().isEmpty());
 
     generator.customResources(null, null);
     assertTrue(generator.getCustomResourceInfos().isEmpty());
 
+    generator.customResourceClasses((Class<? extends HasMetadata>[]) null);
+    assertTrue(generator.getCustomResourceInfos().isEmpty());
+
+    generator.customResourceClasses((Class<? extends HasMetadata>) null);
+    assertTrue(generator.getCustomResourceInfos().isEmpty());
+
+    generator.customResourceClasses((Collection<Class<? extends HasMetadata>>) null);
+    assertTrue(generator.getCustomResourceInfos().isEmpty());
+
     generator.customResourceClasses(Simplest.class);
     assertEquals(1, generator.getCustomResourceInfos().size());
     assertTrue(generator.getCustomResourceInfos().stream().allMatch(cri -> cri.crClassName().equals(Simplest.class.getName())));

crd-generator/collector/pom.xml

@@ -0,0 +1,66 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Copyright (C) 2015 Red Hat, Inc.
+
+    Licensed under the Apache License, Version 2.0 (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+
+            http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+-->
+<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <parent>
+    <artifactId>crd-generator-parent</artifactId>
+    <groupId>io.fabric8</groupId>
+    <version>7.0-SNAPSHOT</version>
+  </parent>
+  <modelVersion>4.0.0</modelVersion>
+
+  <artifactId>crd-generator-collector</artifactId>
+  <name>Fabric8 :: CRD generator :: Collector</name>
+
+  <packaging>jar</packaging>
+
+  <dependencies>
+    <dependency>
+      <groupId>io.fabric8</groupId>
+      <artifactId>crd-generator-api-v2</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.smallrye</groupId>
+      <artifactId>jandex</artifactId>
+    </dependency>
+
+    <!-- Testing -->
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-api</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-engine</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-simple</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

crd-generator/collector/src/main/java/io/fabric8/crd/generator/collector/CustomResourceClassLoader.java

@@ -0,0 +1,139 @@
+/*
+ * Copyright (C) 2015 Red Hat, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *         http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.fabric8.crd.generator.collector;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.LinkedHashSet;
+import java.util.Objects;
+import java.util.Set;
+
+/**
+ * Allows to build a class loader to load Custom Resource classes.
+ * The actual class loader is built lazy and is cached once used.
+ */
+class CustomResourceClassLoader {
+
+  private static final Logger log = LoggerFactory.getLogger(CustomResourceClassLoader.class);
+
+  private final Set<String> classpathElements = new LinkedHashSet<>();
+
+  private ClassLoader parentClassLoader;
+
+  private ClassLoader cachedClassLoader;
+
+  @SuppressWarnings("UnusedReturnValue")
+  public CustomResourceClassLoader withParentClassLoader(ClassLoader parentClassLoader) {
+    this.parentClassLoader = parentClassLoader;
+    return this;
+  }
+
+  @SuppressWarnings("UnusedReturnValue")
+  public CustomResourceClassLoader withClasspathElement(String... classpathElements) {
+    if (classpathElements != null) {
+      withClasspathElements(Arrays.asList(classpathElements));
+    }
+    return this;
+  }
+
+  @SuppressWarnings("UnusedReturnValue")
+  public CustomResourceClassLoader withClasspathElements(Collection<String> classpathElements) {
+    if (classpathElements != null) {
+      classpathElements.stream()
+          .filter(Objects::nonNull)
+          .forEach(this.classpathElements::add);
+    }
+    return this;
+  }
+
+  /**
+   * Load a Custom Resource class by its name and the previously configured class loader.
+   *
+   * @param className the class name of the Custom Resource class
+   * @return the Custom Resource class
+   */
+  public Class<? extends HasMetadata> loadCustomResourceClass(String className) {
+    Class<?> clazz = loadClass(className);
+    if (HasMetadata.class.isAssignableFrom(clazz)) {
+      return clazz.asSubclass(HasMetadata.class);
+    }
+    throw new CustomResourceClassLoaderException(
+        "Could not load Custom Resource. Class does not implement HasMetadata: " + className);
+  }
+
+  private Class<?> loadClass(String className) {
+    try {
+      return getClassLoader().loadClass(className);
+    } catch (ClassNotFoundException e) {
+      throw new CustomResourceClassLoaderException(e);
+    }
+  }
+
+  ClassLoader getClassLoader() {
+    if (cachedClassLoader == null) {
+      cachedClassLoader = createClassLoader();
+    }
+    return cachedClassLoader;
+  }
+
+  private ClassLoader createClassLoader() {
+    if (!classpathElements.isEmpty()) {
+      URL[] urls = classpathElements.stream()
+          .map(s -> {
+            try {
+              return new File(s).toURI().toURL();
+            } catch (MalformedURLException e) {
+              throw new CustomResourceClassLoaderException("Could not transform file to URL: " + s, e);
+            }
+          }).toArray(URL[]::new);
+      String urlsAsString = Arrays.toString(urls);
+      if (parentClassLoader != null) {
+        log.trace("Using URLClassLoader with parent ClassLoader {} and {}", parentClassLoader, urlsAsString);
+        return new URLClassLoader(urls, parentClassLoader);
+      } else {
+        log.trace("Using URLClassLoader with {}", urlsAsString);
+        return new URLClassLoader(urls);
+      }
+    } else {
+      if (parentClassLoader != null) {
+        log.trace("Using given ClassLoader {}", parentClassLoader);
+        return parentClassLoader;
+      } else {
+        log.trace("Using default ClassLoader");
+        return getDefaultClassLoader();
+      }
+    }
+  }
+
+  private ClassLoader getDefaultClassLoader() {
+    return Thread.currentThread().getContextClassLoader();
+  }
+
+  void reset() {
+    classpathElements.clear();
+    parentClassLoader = null;
+    cachedClassLoader = null;
+  }
+
+}

crd-generator/collector/src/main/java/io/fabric8/crd/generator/collector/CustomResourceClassLoaderException.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright (C) 2015 Red Hat, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *         http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.fabric8.crd.generator.collector;
+
+public class CustomResourceClassLoaderException extends RuntimeException {
+
+  public CustomResourceClassLoaderException(String message) {
+    super(message);
+  }
+
+  public CustomResourceClassLoaderException(String message, Throwable cause) {
+    super(message, cause);
+  }
+
+  public CustomResourceClassLoaderException(Throwable cause) {
+    super(cause);
+  }
+}