[camel-kafka-connector] 01/02: Create descriptors for source and sink connector for catalog purpose

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch issue-523
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit d6eb515290fbc69e97f5cb195ce3deb947641bbf
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Oct 7 08:59:54 2020 +0200

    Create descriptors for source and sink connector for catalog purpose
---
 .../maven/CamelKafkaConnectorUpdateMojo.java       | 22 +++++++++++++++++++---
 1 file changed, 19 insertions(+), 3 deletions(-)

diff --git 
a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
 
b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
index a2533cc..65e428f 100644
--- 
a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
+++ 
b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
@@ -583,6 +583,7 @@ public class CamelKafkaConnectorUpdateMojo extends 
AbstractCamelKafkaConnectorMo
             getLog().debug("No changes to website doc file: " + 
docFileWebsite);
         }
         writeJson(listOptions, getMainDepArtifactId(), connectorDir, ct, 
packageName + "." + javaClassConnectorName, convertersList, transformsList, 
aggregationStrategiesList);
+        writeDescriptors(connectorDir, ct);
     }
 
     private void addProperties(Map<String, String> additionalProperties, 
String additionalProp) {
@@ -736,7 +737,22 @@ public class CamelKafkaConnectorUpdateMojo extends 
AbstractCamelKafkaConnectorMo
         File docFolder = new File(connectorDir, "src/generated/resources/");
         File docFile = new File(docFolder, getMainDepArtifactId() + "-kafka-" 
+ ct.name().toLowerCase() + "-connector.json");
         JsonObject j = JsonMapperKafkaConnector.asJsonObject(model);
-        updateJsonFile(docFile, Jsoner.prettyPrint(j.toJson()));
+        updateFile(docFile, Jsoner.prettyPrint(j.toJson()));
+    }
+    
+    private void writeDescriptors(File connectorDir, ConnectorType ct) throws 
MojoExecutionException {
+
+        String title;
+        if (getMainDepArtifactId().equalsIgnoreCase("camel-coap+tcp")) {
+            title = "camel-coap-tcp";
+        } else if (getMainDepArtifactId().equalsIgnoreCase("camel-coaps+tcp")) 
{
+            title = "camel-coaps-tcp";
+        } else {
+            title = getMainDepArtifactId();
+        }
+        File docFolder = new File(connectorDir, "src/generated/descriptors/");
+        File docFile = new File(docFolder, "connector-" + 
ct.name().toLowerCase() + ".properties");
+        updateFile(docFile, title + "-" + ct.name().toLowerCase());
     }
 
     private boolean updateAutoConfigureOptions(File file, String changed) 
throws MojoExecutionException {
@@ -776,7 +792,7 @@ public class CamelKafkaConnectorUpdateMojo extends 
AbstractCamelKafkaConnectorMo
         }
     }
 
-    private boolean updateJsonFile(File file, String changed) throws 
MojoExecutionException {
+    private boolean updateFile(File file, String changed) throws 
MojoExecutionException {
         try {
             if (!file.exists()) {
                 writeText(file, changed);
@@ -807,4 +823,4 @@ public class CamelKafkaConnectorUpdateMojo extends 
AbstractCamelKafkaConnectorMo
     private enum ConnectorType {
         SINK, SOURCE
     }
-}
+}
\ No newline at end of file