asyncapi-generator: authentication and README.md (#77)

Author: ivangsa

plugins/asyncapi-generator/README.md

@@ -15,19 +15,22 @@
         mainOptions = {
             "apiFile",
             "role",
-            "style",
+            "templates",
             "modelPackage",
             "producerApiPackage",
             "consumerApiPackage",
             "apiPackage",
+            "operationIds",
+            "excludeOperationIds",
             "transactionalOutbox",
+            "jsonschema2pojo",
+            "avroCompilerProperties",
             "bindingPrefix",
             "bindingSuffix",
             "generatedAnnotationClass",
-            "jsonschema2pojo",
-            "avroCompilerProperties"
+
         },
-        hiddenOptions = {"layout", "apiFiles", "zdlFile", "zdlFiles"})
+        hiddenOptions = {"layout", "apiFiles", "zdlFile", "zdlFiles", "style"})
 public class AsyncAPIGeneratorPlugin extends Plugin {
 
     public AsyncAPIGeneratorPlugin() {

plugins/asyncapi-generator/src/main/java/io/zenwave360/sdk/plugins/AsyncAPIGeneratorPlugin.java

@@ -155,5 +155,24 @@ public void test_generate_asyncapi_avro_from_http() throws Exception {
         Assertions.assertTrue(new File(targetFolder + "/src/main/java/io/example/api/avro/Address.java").exists());
     }
 
+    @Test
+    public void test_generate_asyncapi_avro_from_playground() throws Exception {
+        String targetFolder = "target/out/asyncapi_avro_from_playground";
+        String baseUrl = "https://raw.githubusercontent.com/ZenWave360/zenwave-playground/refs/heads/main/examples/asyncapi/apis";
+        Plugin plugin = new AsyncAPIGeneratorPlugin()
+                .withApiFile(baseUrl + "/asyncapi-avro-refs.yml")
+                .withTargetFolder(targetFolder)
+                .withOption("avroCompilerProperties.imports", List.of(
+                        baseUrl + "/avro/Address.avsc",
+                        baseUrl + "/avro/PaymentMethod.avsc",
+                        baseUrl + "/avro/PaymentMethodType.avsc"))
+                .withOption("producerApiPackage", "io.example.api.producer")
+                .withOption("role", AsyncapiRoleType.provider)
+                .withOption("style", ProgrammingStyle.imperative)
+                .withOption("skipFormatting", false);
+
+        new MainGenerator().generate(plugin);
+
+    }
 
 }

plugins/asyncapi-generator/src/test/java/io/zenwave360/sdk/plugins/kafka/AsyncAPIGeneratorAvroTest.java

@@ -56,7 +56,7 @@
         <reflections.version>0.10.2</reflections.version>
         <handlebars-java.version>4.3.1</handlebars-java.version>
         <json-path.version>2.9.0</json-path.version>
-        <json-schema-ref-parser-jvm.version>0.9.0</json-schema-ref-parser-jvm.version>
+        <json-schema-ref-parser-jvm.version>1.0.0-SNAPSHOT</json-schema-ref-parser-jvm.version>
         <zdl-jvm.version>1.3.0</zdl-jvm.version>
         <graphql-java.version>19.2</graphql-java.version>
         <google-java-format.version>1.25.2</google-java-format.version>

pom.xml

@@ -8,6 +8,7 @@
 import java.util.Map;
 import java.util.Optional;
 
+import io.zenwave360.jsonrefparser.AuthenticationValue;
 import io.zenwave360.sdk.zdl.layouts.DefaultProjectLayout;
 import io.zenwave360.sdk.zdl.layouts.ProjectLayout;
 import org.apache.commons.lang3.ClassUtils;
@@ -38,10 +39,13 @@ public class Plugin {
     @DocumentedOption(description = "API Spec files to parse (comma separated)")
     public List<String> apiFiles;
 
+    @DocumentedOption(description = "Authentication configuration values for fetching remote resources.")
+    public List<AuthenticationValue> authentication = List.of();
+
     @DocumentedOption(description = "Target folder for generated output")
     public String targetFolder;
 
-    private List<Class> chain;
+    private List<Class> chainXX;
 
     private boolean forceOverwrite = false;
 
@@ -50,6 +54,7 @@ public class Plugin {
     private ClassLoader projectClassLoader;
 
     public static Plugin of(String pluginConfigAsString) throws Exception {
+        System.out.println("of: " + pluginConfigAsString);
         if (pluginConfigAsString != null) {
             if (pluginConfigAsString.contains(".")) {
                 return (Plugin) Plugin.class.getClassLoader().loadClass(pluginConfigAsString).getDeclaredConstructor().newInstance();
@@ -78,6 +83,7 @@ private static Plugin ofSimpleClassName(String simpleClassName) {
                 return pluginClass.getDeclaredConstructor().newInstance();
             } catch (Exception ignored) {
                 // ignore
+                System.out.println("ignored: " + ignored.getMessage() + " " + simpleClassName);
             }
         }
         return null;
@@ -163,6 +169,12 @@ public Plugin withZdlFiles(List<String> zdlFiles) {
         return this;
     }
 
+    public Plugin withAuthentication(List<AuthenticationValue> authentication) {
+        this.authentication = authentication;
+        this.options.put("authentication", this.authentication);
+        return this;
+    }
+
     public Plugin withTargetFolder(String targetFolder) {
         if (targetFolder != null) {
             this.targetFolder = targetFolder;

zenwave-sdk-cli/src/main/java/io/zenwave360/sdk/Plugin.java

@@ -6,8 +6,10 @@
 import java.io.IOException;
 import java.net.URI;
 import java.util.LinkedHashMap;
+import java.util.List;
 import java.util.Map;
 
+import io.zenwave360.jsonrefparser.AuthenticationValue;
 import io.zenwave360.sdk.doc.DocumentedOption;
 import io.zenwave360.jsonrefparser.$RefParser;
 import io.zenwave360.jsonrefparser.$RefParserOptions;
@@ -23,6 +25,9 @@ public class DefaultYamlParser implements io.zenwave360.sdk.parsers.Parser {
     public URI apiFile;
     public String targetProperty = "api";
 
+    @DocumentedOption(description = "Authentication configuration values for fetching remote resources.")
+    public List<AuthenticationValue> authentication = List.of();
+
     private ClassLoader projectClassLoader;
 
     @DocumentedOption(description = "API Specification File (@deprecated use apiFile)")
@@ -63,6 +68,7 @@ public Map<String, Object> parse() throws IOException {
         if(apiFile != null) {
             $RefParser parser = new $RefParser(apiFile)
                     .withResourceClassLoader(this.projectClassLoader)
+//                    .withAuthenticationValues(authentication)
                     .withOptions(new $RefParserOptions().withOnCircular(SKIP).withOnMissing(OnMissing.SKIP));
             model.put(targetProperty, new Model(apiFile, parser.parse().dereference().mergeAllOf().getRefs()));
         } else {

zenwave-sdk-cli/src/main/java/io/zenwave360/sdk/parsers/DefaultYamlParser.java

@@ -6,6 +6,7 @@
 import java.util.*;
 import java.util.stream.Collectors;
 
+import io.zenwave360.jsonrefparser.AuthenticationValue;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.maven.artifact.Artifact;
 import org.apache.maven.plugin.AbstractMojo;
@@ -48,6 +49,11 @@ public class GeneratorMojo extends AbstractMojo {
     @Parameter(name = "zdlFiles", property = "zenwave.zdlFiles")
     private String[] zdlFiles;
 
+    /**
+     * Authentication configuration values for fetching remote resources.
+     */
+    @Parameter(name = "authentication", property = "zenwave.authentication")
+    private List<AuthenticationValue> authentication = List.of();
 
     /**
      * Location of the output directory.
@@ -136,6 +142,7 @@ public void execute() throws MojoExecutionException {
             Plugin plugin = Plugin.of(this.generatorName)
                     .withApiFile(apiFile)
                     .withZdlFiles(zdls)
+                    .withAuthentication(authentication)
                     .withTargetFolder(targetFolder.getAbsolutePath())
                     .withProjectClassLoader(projectClassLoader)
                     .withOptions(options);