You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/07 08:40:32 UTC
[camel-kafka-connector] 01/03: Create descriptors for source and
sink connector for catalog purpose
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 7680e8964d4332d1118543717ab9d8d96d715d61
Author: Andrea Cosentino <an...@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