Added ssl support to mongodb kamelets.

apache · Jan 23, 2023 · db7d072 · db7d072
1 parent 48ad553
commit db7d072
Show file tree

Hide file tree

Showing 8 changed files with 390 additions and 18 deletions.
diff --git a/kamelets/mongodb-changes-stream-source.kamelet.yaml b/kamelets/mongodb-changes-stream-source.kamelet.yaml
@@ -59,6 +59,20 @@ spec:
         type: string
         x-descriptors:
         - urn:camel:group:credentials
+      ssl:
+        title: Enable Ssl for Mongodb Connection
+        description: whether to enable ssl connection to mongodb
+        type: boolean
+        default: true
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+      sslValidationEnabled:
+        title: Enables Ssl Certificates Validation and Host name checks.
+        description: IMPORTANT this should be disabled only in test environment since can pose security issues.
+        type: boolean
+        default: true
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
       database:
         title: MongoDB Database
         description: Sets the name of the MongoDB database to target.
@@ -76,16 +90,22 @@ spec:
     beans:
       - name: local-mongodb
         type: "#class:org.apache.camel.component.mongodb.MongoDbComponent"
+      - name: mongo-client
+        type: "#class:org.bf2.cos.connector.camel.mongodb.SslAwareMongoClient"
+        properties:
+          password: "{{?password}}"
+          username: "{{?username}}"
+          hosts: "{{hosts}}"
+          ssl: "{{ssl}}"
+          sslValidationEnabled: "{{sslValidationEnabled}}"
     from:
       uri: "{{local-mongodb}}:test"
       parameters:
-        hosts: "{{hosts}}"
         collection: "{{collection}}"
-        password: "{{?password}}"
-        username: "{{?username}}"
         database: "{{database}}"
         consumerType: "changeStreams"
         streamFilter: "{{?streamFilter}}"
+        mongoConnection: "#{{mongo-client}}"
       steps:
       - marshal:
           json: {}

diff --git a/kamelets/mongodb-sink.kamelet.yaml b/kamelets/mongodb-sink.kamelet.yaml
@@ -63,6 +63,20 @@ spec:
         type: string
         x-descriptors:
         - urn:camel:group:credentials
+      ssl:
+        title: Enable Ssl for Mongodb Connection
+        description: whether to enable ssl connection to mongodb
+        type: boolean
+        default: true
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+      sslValidationEnabled:
+        title: Enables Ssl Certificates Validation and Host name checks.
+        description: IMPORTANT this should be disabled only in test environment since can pose security issues.
+        type: boolean
+        default: true
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
       database:
         title: MongoDB Database
         description: The name of the MongoDB database.
@@ -90,6 +104,14 @@ spec:
     beans:
       - name: local-mongodb
         type: "#class:org.apache.camel.component.mongodb.MongoDbComponent"
+      - name: mongo-client
+        type: "#class:org.bf2.cos.connector.camel.mongodb.SslAwareMongoClient"
+        properties:
+          password: "{{?password}}"
+          username: "{{?username}}"
+          hosts: "{{hosts}}"
+          ssl: "{{ssl}}"
+          sslValidationEnabled: "{{sslValidationEnabled}}"
     from:
       uri: kamelet:source
       steps:
@@ -110,9 +132,7 @@ spec:
           parameters:
             createCollection: "{{?createCollection}}"
             writeConcern: "{{?writeConcern}}"
-            hosts: "{{hosts}}"
             collection: "{{collection}}"
-            password: "{{?password}}"
-            username: "{{?username}}"
             database: "{{database}}"
             operation: "insert"
+            mongoConnection: "#{{mongo-client}}"
diff --git a/kamelets/mongodb-source.kamelet.yaml b/kamelets/mongodb-source.kamelet.yaml
@@ -65,6 +65,20 @@ spec:
         type: string
         x-descriptors:
         - urn:camel:group:credentials
+      ssl:
+        title: Enable Ssl for Mongodb Connection
+        description: whether to enable ssl connection to mongodb
+        type: boolean
+        default: true
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+      sslValidationEnabled:
+        title: Enables Ssl Certificates Validation and Host name checks.
+        description: IMPORTANT this should be disabled only in test environment since can pose security issues.
+        type: boolean
+        default: true
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
       database:
         title: MongoDB Database
         description: The name of the MongoDB database.
@@ -88,16 +102,22 @@ spec:
     beans:
       - name: local-mongodb
         type: "#class:org.apache.camel.component.mongodb.MongoDbComponent"
+      - name: mongo-client
+        type: "#class:org.bf2.cos.connector.camel.mongodb.SslAwareMongoClient"
+        properties:
+          password: "{{?password}}"
+          username: "{{?username}}"
+          hosts: "{{hosts}}"
+          ssl: "{{ssl}}"
+          sslValidationEnabled: "{{sslValidationEnabled}}"
     from:
       uri: "{{local-mongodb}}:test"
       parameters:
-        hosts: "{{hosts}}"
         collection: "{{collection}}"
-        password: "{{?password}}"
-        username: "{{?username}}"
         database: "{{database}}"
         persistentTailTracking: "{{persistentTailTracking}}"
         tailTrackIncreasingField: "{{?tailTrackIncreasingField}}"
+        mongoConnection: "#{{mongo-client}}"
       steps:
       - marshal:
           json: {}

diff --git a/library/camel-kamelets-utils/pom.xml b/library/camel-kamelets-utils/pom.xml
@@ -83,6 +83,13 @@
             <scope>provided</scope>
         </dependency>
 
+        <!-- Dependencies for mongodb connection configuration -->
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-mongodb</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
         <!-- Test scoped dependencies -->
         <dependency>
             <groupId>org.junit.jupiter</groupId>