Merge pull request #228 from fjtirado/Fix_#211

[Fix #211] Adding Uni and Multi converter

Author: fjtirado

core/deployment/pom.xml

@@ -29,6 +29,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-jackson-deployment</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.serverlessworkflow</groupId>
+            <artifactId>serverlessworkflow-experimental-lambda</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-jackson-deployment</artifactId>

core/deployment/src/main/java/io/quarkiverse/flow/deployment/FlowNativeProcessor.java

@@ -1,5 +1,7 @@
 package io.quarkiverse.flow.deployment;
 
+import io.quarkiverse.flow.converters.Multi2CompletableFuture;
+import io.quarkiverse.flow.converters.Uni2CompletableFuture;
 import io.quarkiverse.flow.providers.MetadataPropagationRequestDecorator;
 import io.quarkus.deployment.annotations.BuildProducer;
 import io.quarkus.deployment.annotations.BuildStep;
@@ -9,6 +11,7 @@
 import io.serverlessworkflow.impl.events.EventPublisher;
 import io.serverlessworkflow.impl.events.InMemoryEvents;
 import io.serverlessworkflow.impl.executors.TaskExecutorFactory;
+import io.serverlessworkflow.impl.executors.func.DataTypeConverter;
 import io.serverlessworkflow.impl.executors.func.JavaTaskExecutorFactory;
 import io.serverlessworkflow.impl.executors.http.HttpRequestDecorator;
 import io.serverlessworkflow.impl.expressions.ExpressionFactory;
@@ -41,6 +44,8 @@ void registerSDKServiceProviders(BuildProducer<ServiceProviderBuildItem> sp) {
                 JacksonModelFactory.class.getName()));
         sp.produce(new ServiceProviderBuildItem(HttpRequestDecorator.class.getName(),
                 MetadataPropagationRequestDecorator.class.getName()));
+        sp.produce(new ServiceProviderBuildItem(DataTypeConverter.class.getName(),
+                Uni2CompletableFuture.class.getName(), Multi2CompletableFuture.class.getName()));
     }
 
 }

core/integration-tests/src/main/java/io/quarkiverse/flow/it/UniWorkflow.java

@@ -0,0 +1,18 @@
+package io.quarkiverse.flow.it;
+
+import jakarta.enterprise.context.ApplicationScoped;
+
+import io.quarkiverse.flow.Flow;
+import io.serverlessworkflow.api.types.Workflow;
+import io.serverlessworkflow.fluent.func.FuncWorkflowBuilder;
+import io.smallrye.mutiny.Uni;
+
+@ApplicationScoped
+public class UniWorkflow extends Flow {
+
+    public Workflow descriptor() {
+        return FuncWorkflowBuilder.workflow("uniTest")
+                .tasks(tasks -> tasks.function(f -> f.function(t -> Uni.createFrom().item("Javierito"))))
+                .build();
+    }
+}

core/integration-tests/src/test/java/io/quarkiverse/flow/it/UniWorkflowTest.java

@@ -0,0 +1,21 @@
+package io.quarkiverse.flow.it;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import jakarta.inject.Inject;
+
+import org.junit.jupiter.api.Test;
+
+import io.quarkus.test.junit.QuarkusTest;
+
+@QuarkusTest
+public class UniWorkflowTest {
+
+    @Inject
+    UniWorkflow def;
+
+    @Test
+    void testUni() {
+        assertThat(def.startInstance().await().indefinitely().as(String.class).orElseThrow()).isEqualTo("Javierito");
+    }
+}

core/runtime/src/main/java/io/quarkiverse/flow/converters/Multi2CompletableFuture.java

@@ -0,0 +1,20 @@
+package io.quarkiverse.flow.converters;
+
+import java.util.concurrent.CompletableFuture;
+
+import io.serverlessworkflow.impl.executors.func.DataTypeConverter;
+import io.smallrye.mutiny.Multi;
+
+@SuppressWarnings("rawtypes")
+public class Multi2CompletableFuture implements DataTypeConverter<Multi, CompletableFuture> {
+
+    @Override
+    public CompletableFuture apply(Multi t) {
+        return t.toUni().subscribeAsCompletionStage();
+    }
+
+    @Override
+    public Class<Multi> sourceType() {
+        return Multi.class;
+    }
+}

core/runtime/src/main/java/io/quarkiverse/flow/converters/Uni2CompletableFuture.java

@@ -0,0 +1,20 @@
+package io.quarkiverse.flow.converters;
+
+import java.util.concurrent.CompletableFuture;
+
+import io.serverlessworkflow.impl.executors.func.DataTypeConverter;
+import io.smallrye.mutiny.Uni;
+
+@SuppressWarnings("rawtypes")
+public class Uni2CompletableFuture implements DataTypeConverter<Uni, CompletableFuture> {
+
+    @Override
+    public CompletableFuture apply(Uni t) {
+        return t.subscribeAsCompletionStage();
+    }
+
+    @Override
+    public Class<Uni> sourceType() {
+        return Uni.class;
+    }
+}

core/runtime/src/main/resources/META-INF/services/io.serverlessworkflow.impl.executors.func.DataTypeConverter

@@ -0,0 +1,2 @@
+ io.quarkiverse.flow.converters.Uni2CompletableFuture
+ io.quarkiverse.flow.converters.Multi2CompletableFuture