Add initial openapi module

Signed-off-by: Matheus Cruz <[email protected]>

Author: mcruzdev

impl/openapi/pom.xml

@@ -0,0 +1,43 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>io.serverlessworkflow</groupId>
+    <artifactId>serverlessworkflow-impl</artifactId>
+    <version>7.0.0-SNAPSHOT</version>
+  </parent>
+  <artifactId>serverlessworkflow-impl-openapi</artifactId>
+  <dependencies>
+    <dependency>
+      <groupId>org.glassfish.jersey.core</groupId>
+      <artifactId>jersey-client</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.glassfish.jersey.media</groupId>
+      <artifactId>jersey-media-json-jackson</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.serverlessworkflow</groupId>
+      <artifactId>serverlessworkflow-impl-core</artifactId>
+    </dependency>
+      <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-api</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-engine</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-params</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.assertj</groupId>
+      <artifactId>assertj-core</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

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

@@ -0,0 +1,40 @@
+/*
+ * Copyright 2020-Present The Serverless Workflow Specification Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.serverlessworkflow.impl.executors;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import io.serverlessworkflow.api.types.CallOpenAPI;
+import io.serverlessworkflow.api.types.TaskBase;
+import io.serverlessworkflow.impl.TaskContext;
+import io.serverlessworkflow.impl.WorkflowContext;
+import io.serverlessworkflow.impl.WorkflowDefinition;
+
+public class OpenAPIExecutor implements CallableTask<CallOpenAPI> {
+
+  @Override
+  public void init(CallOpenAPI task, WorkflowDefinition definition) {}
+
+  @Override
+  public JsonNode apply(
+      WorkflowContext workflowContext, TaskContext<CallOpenAPI> taskContext, JsonNode input) {
+    return input;
+  }
+
+  @Override
+  public boolean accept(Class<? extends TaskBase> clazz) {
+    return clazz.isAssignableFrom(CallOpenAPI.class);
+  }
+}

impl/openapi/src/main/resources/META-INF/services/io.serverlessworkflow.impl.executors.CallableTask

@@ -0,0 +1 @@
+io.serverlessworkflow.impl.executors.OpenAPIExecutor

impl/openapi/src/test/java/io/serverlessworkflow/impl/OpenAPIWorkflowDefinitionTest.java

@@ -0,0 +1,50 @@
+/*
+ * Copyright 2020-Present The Serverless Workflow Specification Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.serverlessworkflow.impl;
+
+import static io.serverlessworkflow.api.WorkflowReader.readWorkflowFromClasspath;
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import java.io.IOException;
+import java.util.Map;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+
+public class OpenAPIWorkflowDefinitionTest {
+
+  private static WorkflowApplication app;
+
+  @BeforeAll
+  static void init() {
+    app = WorkflowApplication.builder().build();
+  }
+
+  @Test
+  void testWorkflowExecution() throws IOException {
+    Object output =
+        app.workflowDefinition(readWorkflowFromClasspath("findPetsByStatus.yaml"))
+            .execute(Map.of("status", "sold"))
+            .outputAsJsonNode();
+    assertThat(output)
+        .isInstanceOf(JsonNode.class)
+        .satisfies(
+            (obj) -> {
+              JsonNode json = (JsonNode) obj;
+              assertThat(json.get("status").asText()).isEqualTo("sold");
+            });
+  }
+}

impl/openapi/src/test/resources/findPetsByStatus.yaml

@@ -0,0 +1,14 @@
+document:
+  dsl: '1.0.0-alpha5'
+  namespace: test
+  name: openapi-example
+  version: '0.1.0'
+do:
+  - findPet:
+      call: openapi
+      with:
+        document:
+          endpoint: https://petstore.swagger.io/v2/swagger.json
+        operationId: findPetsByStatus
+        parameters:
+          status: available

impl/pom.xml

@@ -38,5 +38,6 @@
   	<module>http</module>
   	<module>core</module>
   	<module>bom</module>
+    <module>openapi</module>
   </modules>
 </project>