Merge pull request #227 from camunda-community-hub/dependabot/maven/c…

…amunda-connector-bundle.version-0.21.3 build(deps): bump camunda-connector-bundle.version from 0.20.0 to 0.21.3
camunda-community-hub · Jul 19, 2023 · aec0737 · aec0737
2 parents 7a4bc76 + b3b8bf8
commit aec0737
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/pom.xml b/pom.xml
@@ -23,7 +23,7 @@
     <zeeqs.version>2.9.0</zeeqs.version>
     <eze.version>1.2.0</eze.version>
     <hazelcast.version>1.4.0</hazelcast.version>
-    <camunda-connector-bundle.version>0.20.0</camunda-connector-bundle.version>
+    <camunda-connector-bundle.version>0.21.3</camunda-connector-bundle.version>
 
     <kotlin.version>1.9.0</kotlin.version>
     <spring.boot.version>2.7.13</spring.boot.version>

diff --git a/src/main/kotlin/org/camunda/community/zeebe/play/connectors/ConnectorsConfig.kt b/src/main/kotlin/org/camunda/community/zeebe/play/connectors/ConnectorsConfig.kt
@@ -1,8 +1,10 @@
 package org.camunda.community.zeebe.play.connectors
 
+import com.fasterxml.jackson.databind.ObjectMapper
 import io.camunda.connector.api.secret.SecretProvider
 import io.camunda.connector.runtime.core.ConnectorHelper
 import io.camunda.connector.runtime.core.outbound.ConnectorJobHandler
+import io.camunda.connector.validation.impl.DefaultValidationProvider
 import io.camunda.zeebe.client.ZeebeClient
 import org.slf4j.LoggerFactory
 import org.springframework.boot.autoconfigure.domain.EntityScan
@@ -34,7 +36,9 @@ class ConnectorsConfig(
                 .forEach { connectorConfig ->
                     val connector =
                         ConnectorHelper.instantiateConnector(connectorConfig.connectorClass)
-                    val jobHandler = ConnectorJobHandler(connector, secretProvider)
+                    val validationProvider = DefaultValidationProvider()
+                    val objectMapper = ObjectMapper()
+                    val jobHandler = ConnectorJobHandler(connector, secretProvider, validationProvider, objectMapper)
 
                     zeebeClient
                         .newWorker()

diff --git a/src/main/kotlin/org/camunda/community/zeebe/play/rest/ConnectorsResource.kt b/src/main/kotlin/org/camunda/community/zeebe/play/rest/ConnectorsResource.kt
@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.ObjectMapper
 import io.camunda.connector.impl.outbound.OutboundConnectorConfiguration
 import io.camunda.connector.runtime.core.ConnectorHelper
 import io.camunda.connector.runtime.core.outbound.ConnectorJobHandler
+import io.camunda.connector.validation.impl.DefaultValidationProvider
 import io.camunda.zeebe.client.ZeebeClient
 import io.camunda.zeebe.client.api.response.ActivatedJob
 import io.camunda.zeebe.model.bpmn.Bpmn
@@ -66,7 +67,8 @@ class ConnectorsResource(
             ?: throw RuntimeException("No connector found with job type '$jobType'."))
 
         val connector = ConnectorHelper.instantiateConnector(connectorConfig.connectorClass)
-        val jobHandler = ConnectorJobHandler(connector, connectorsSecretProvider)
+        val validationProvider = DefaultValidationProvider()
+        val jobHandler = ConnectorJobHandler(connector, connectorsSecretProvider, validationProvider, objectMapper)
 
         jobRepository.findByIdOrNull(jobKey)
             ?.takeIf { it.state == JobState.ACTIVATABLE && !keysOfPendingJobs.contains(jobKey) }