[camel-kafka-connector] branch main updated: GenerateCamelKafkaConnectorsMojo : Added possibility to exclude connectors from automatic deletion during generation.

[valdar]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new fd25e49  GenerateCamelKafkaConnectorsMojo : Added possibility to 
exclude connectors from automatic deletion during generation.
fd25e49 is described below

commit fd25e49824f5798ff1a2570a37a0e8d3246a2556
Author: Andrea Tarocchi <andrea.taroc...@gmail.com>
AuthorDate: Sun Oct 31 01:22:26 2021 +0200

    GenerateCamelKafkaConnectorsMojo : Added possibility to exclude connectors 
from automatic deletion during generation.
---
 .../maven/GenerateCamelKafkaConnectorsMojo.java          | 16 ++++++++++++----
 .../maven_project/pom.xml                                |  3 +++
 2 files changed, 15 insertions(+), 4 deletions(-)

diff --git 
a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
 
b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
index aff55e1..275469d 100644
--- 
a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
+++ 
b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
@@ -148,6 +148,12 @@ public class GenerateCamelKafkaConnectorsMojo extends 
AbstractCamelKafkaConnecto
     @Parameter(defaultValue = "", readonly = true)
     private List excludedComponents = Collections.EMPTY_LIST;
 
+    /**
+     * The Exclusion List of connectors that must be skipped while deleting 
kafka connector.
+     */
+    @Parameter(defaultValue = "", readonly = true)
+    private List excludedConnectorsFromDeletion = Collections.EMPTY_LIST;
+
     @Component
     private ProjectDependenciesResolver projectDependenciesResolver;
 
@@ -335,13 +341,15 @@ public class GenerateCamelKafkaConnectorsMojo extends 
AbstractCamelKafkaConnecto
                 if (existingConnectorNames != null) {
                     List<String> connectorsToRemove = 
Stream.of(existingConnectorNames).sorted().filter(filename -> {
                         String componentName = extractComponentName(filename);
-                        // set to remove connectors that are not generated 
from camel components or a kamelet
-                        return 
!sanitizedGeneratedFromComponentsConnectorsNames.contains(componentName) && 
!sanitizedGeneratedFromKameletsConnectorsNames.contains(componentName);
+                        // set to remove connectors that are not generated 
from camel components or a kamelet and are not excluded in 
excludedConnectorsFromDeletion
+                        return 
!sanitizedGeneratedFromComponentsConnectorsNames.contains(componentName)
+                                && 
!sanitizedGeneratedFromKameletsConnectorsNames.contains(componentName)
+                                && 
!excludedConnectorsFromDeletion.contains(componentName);
                     }).collect(Collectors.toList());
 
                     getLog().info("Connectors previously generated found to be 
removed: " + connectorsToRemove);
 
-                    for (String component: connectorsToRemove) {
+                    for (String connectorToBeRemoved: connectorsToRemove) {
 
                         executeMojo(
                                 plugin(
@@ -351,7 +359,7 @@ public class GenerateCamelKafkaConnectorsMojo extends 
AbstractCamelKafkaConnecto
                                 ),
                                 goal("camel-kafka-connector-delete"),
                                 configuration(
-                                        element(name("name"), component),
+                                        element(name("name"), 
connectorToBeRemoved),
                                         element(name("connectorsProjectName"), 
connectorsProjectName)
                                 ),
                                 executionEnvironment(
diff --git 
a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
 
b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
index 7ac1eaa..a3816c1 100644
--- 
a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
+++ 
b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
@@ -131,6 +131,9 @@
                         <param>ref</param>
                         <param>robotframework</param>
                     </excludedComponents>
+                    <excludedConnectorsFromDeletion>
+                        <param>test</param>
+                    </excludedConnectorsFromDeletion>
                 </configuration>
                 <executions>
                     <execution>