Use Jackson

Signed-off-by: Matheus Cruz <matheuscruz.dev@gmail.com>

Author: mcruzdev

impl/openapi/src/main/java/io/serverlessworkflow/impl/executors/openapi/JacksonOpenAPIExecutor.java

@@ -15,6 +15,7 @@
  */
 package io.serverlessworkflow.impl.executors.openapi;
 
+import com.fasterxml.jackson.databind.JsonNode;
 import io.serverlessworkflow.api.types.ExternalResource;
 import io.serverlessworkflow.impl.TaskContext;
 import io.serverlessworkflow.impl.WorkflowApplication;
@@ -24,7 +25,6 @@
 import io.serverlessworkflow.impl.executors.http.HttpExecutor;
 import io.serverlessworkflow.impl.executors.http.HttpExecutorBuilder;
 import io.serverlessworkflow.impl.resources.ResourceLoaderUtils;
-import io.swagger.v3.oas.models.media.Schema;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -35,13 +35,13 @@
 
 class JacksonOpenAPIExecutor implements CallableTask {
 
-  private final OpenAPIProcessor processor;
+  private final JacksonOpenAPIProcessor processor;
   private final ExternalResource resource;
   private final Map<String, Object> parameters;
   private final HttpExecutorBuilder builder;
 
   JacksonOpenAPIExecutor(
-      OpenAPIProcessor processor,
+      JacksonOpenAPIProcessor processor,
       ExternalResource resource,
       Map<String, Object> parameters,
       HttpExecutorBuilder builder) {
@@ -56,7 +56,7 @@ public CompletableFuture<WorkflowModel> apply(
       WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
 
     // In the same workflow, access to an already cached document
-    final OperationDefinition operationDefinition =
+    final JacksonOperationDefinition operationDefinition =
         processor.parse(
             workflowContext
                 .definition()
@@ -89,14 +89,15 @@ public CompletableFuture<WorkflowModel> apply(
     return future;
   }
 
-  private void fillHttpBuilder(WorkflowApplication application, OperationDefinition operation) {
+  private void fillHttpBuilder(
+      WorkflowApplication application, JacksonOperationDefinition operation) {
     Map<String, Object> headersMap = new HashMap<>();
     Map<String, Object> queryMap = new HashMap<>();
     Map<String, Object> pathParameters = new HashMap<>();
     Set<String> missingParams = new HashSet<>();
 
     Map<String, Object> bodyParameters = new HashMap<>(parameters);
-    for (ParameterDefinition parameter : operation.getParameters()) {
+    for (JacksonParameterDefinition parameter : operation.getParameters()) {
       switch (parameter.getIn()) {
         case "header":
           param(parameter, bodyParameters, headersMap, missingParams);
@@ -113,8 +114,8 @@ private void fillHttpBuilder(WorkflowApplication application, OperationDefinitio
     if (!missingParams.isEmpty()) {
       throw new IllegalArgumentException(
           "Missing required OpenAPI parameters for operation '"
-              + (operation.getOperation().getOperationId() != null
-                  ? operation.getOperation().getOperationId()
+              + (operation.getOperation().get("operationId") != null
+                  ? operation.getOperation().get("operationId").asText()
                   : "<unknown>" + "': ")
               + missingParams);
     }
@@ -127,16 +128,17 @@ private void fillHttpBuilder(WorkflowApplication application, OperationDefinitio
   }
 
   private void param(
-      ParameterDefinition parameter,
+      JacksonParameterDefinition parameter,
       Map<String, Object> origMap,
       Map<String, Object> collectorMap,
       Set<String> missingParams) {
     String name = parameter.getName();
     if (origMap.containsKey(name)) {
       collectorMap.put(parameter.getName(), origMap.remove(name));
     } else if (parameter.getRequired()) {
-      Schema<?> schema = parameter.getSchema();
-      Object defaultValue = schema != null ? schema.getDefault() : null;
+
+      JsonNode schema = parameter.getSchema();
+      Object defaultValue = schema != null ? schema.get("default") : null;
       if (defaultValue != null) {
         collectorMap.put(name, defaultValue);
       } else {

impl/openapi/src/main/java/io/serverlessworkflow/impl/executors/openapi/OpenAPIExecutorBuilder.java

@@ -28,7 +28,7 @@
 
 public class OpenAPIExecutorBuilder implements CallableTaskBuilder<CallOpenAPI> {
 
-  private OpenAPIProcessor processor;
+  private JacksonOpenAPIProcessor processor;
   private ExternalResource resource;
   private Map<String, Object> parameters;
   private HttpExecutorBuilder builder;
@@ -42,7 +42,7 @@ public boolean accept(Class<? extends TaskBase> clazz) {
   public void init(
       CallOpenAPI task, WorkflowDefinition definition, WorkflowMutablePosition position) {
     OpenAPIArguments with = task.getWith();
-    this.processor = new OpenAPIProcessor(with.getOperationId());
+    this.processor = new JacksonOpenAPIProcessor(with.getOperationId());
     this.resource = with.getDocument();
     this.parameters =
         with.getParameters() != null && with.getParameters().getAdditionalProperties() != null
@@ -56,6 +56,6 @@ public void init(
 
   @Override
   public CallableTask build() {
-    return new OpenAPIExecutor(processor, resource, parameters, builder);
+    return new JacksonOpenAPIExecutor(processor, resource, parameters, builder);
   }
 }