feat: Implement FuncDoTaskBuilder to also cover raise and tryCatch

experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/FuncDoTaskBuilder.java

@@ -47,6 +47,12 @@ public FuncDoTaskBuilder listen(String name, Consumer<FuncListenTaskBuilder> ite
     return this;
   }
 
+  @Override
+  public FuncDoTaskBuilder raise(String name, Consumer<FuncRaiseTaskBuilder> itemsConfigurer) {
+    this.listBuilder().raise(name, itemsConfigurer);
+    return this;
+  }
+
   @Override
   public FuncDoTaskBuilder forEach(String name, Consumer<FuncForTaskBuilder> itemsConfigurer) {
     this.listBuilder().forEach(name, itemsConfigurer);
@@ -96,4 +102,10 @@ public FuncDoTaskBuilder openapi(
     this.listBuilder().openapi(name, itemsConfigurer);
     return this;
   }
+
+  @Override
+  public FuncDoTaskBuilder tryCatch(String name, Consumer<FuncTryTaskBuilder> itemsConfigurer) {
+    this.listBuilder().tryCatch(name, itemsConfigurer);
+    return this;
+  }
 }

experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/FuncRaiseTaskBuilder.java

@@ -0,0 +1,102 @@
+/*
+ * 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.fluent.func;
+
+import io.serverlessworkflow.api.types.ErrorDetails;
+import io.serverlessworkflow.api.types.ErrorTitle;
+import io.serverlessworkflow.api.types.ErrorType;
+import io.serverlessworkflow.api.types.RaiseTask;
+import io.serverlessworkflow.api.types.RaiseTaskConfiguration;
+import io.serverlessworkflow.api.types.RaiseTaskError;
+import io.serverlessworkflow.api.types.UriTemplate;
+import io.serverlessworkflow.fluent.func.spi.ConditionalTaskBuilder;
+import io.serverlessworkflow.fluent.func.spi.FuncTaskTransformations;
+import io.serverlessworkflow.fluent.spec.TaskBaseBuilder;
+import java.net.URI;
+import java.util.function.Consumer;
+
+public class FuncRaiseTaskBuilder extends TaskBaseBuilder<FuncRaiseTaskBuilder>
+    implements FuncTaskTransformations<FuncRaiseTaskBuilder>,
+        ConditionalTaskBuilder<FuncRaiseTaskBuilder> {
+
+  private final RaiseTask raiseTask;
+
+  FuncRaiseTaskBuilder() {
+    this.raiseTask = new RaiseTask();
+    setTask(this.raiseTask);
+  }
+
+  @Override
+  protected FuncRaiseTaskBuilder self() {
+    return this;
+  }
+
+  public FuncRaiseTaskBuilder error(Consumer<RaiseTaskErrorBuilder> consumer) {
+    final RaiseTaskErrorBuilder raiseTaskErrorBuilder = new RaiseTaskErrorBuilder();
+    consumer.accept(raiseTaskErrorBuilder);
+    this.raiseTask.setRaise(new RaiseTaskConfiguration().withError(raiseTaskErrorBuilder.build()));
+    return this;
+  }
+
+  public FuncRaiseTaskBuilder error(String errorReference) {
+    this.raiseTask.setRaise(
+        new RaiseTaskConfiguration()
+            .withError(new RaiseTaskError().withRaiseErrorReference(errorReference)));
+    return this;
+  }
+
+  public RaiseTask build() {
+    return this.raiseTask;
+  }
+
+  public static final class RaiseTaskErrorBuilder {
+    private final io.serverlessworkflow.api.types.Error error;
+
+    private RaiseTaskErrorBuilder() {
+      this.error = new io.serverlessworkflow.api.types.Error();
+    }
+
+    public RaiseTaskErrorBuilder type(String expression) {
+      this.error.setType(new ErrorType().withExpressionErrorType(expression));
+      return this;
+    }
+
+    public RaiseTaskErrorBuilder type(URI errorType) {
+      this.error.setType(
+          new ErrorType().withLiteralErrorType(new UriTemplate().withLiteralUri(errorType)));
+      return this;
+    }
+
+    public RaiseTaskErrorBuilder status(int status) {
+      this.error.setStatus(status);
+      return this;
+    }
+
+    public RaiseTaskErrorBuilder title(String expression) {
+      this.error.setTitle(new ErrorTitle().withExpressionErrorTitle(expression));
+      return this;
+    }
+
+    public RaiseTaskErrorBuilder detail(String expression) {
+      this.error.setDetail(new ErrorDetails().withExpressionErrorDetails(expression));
+      return this;
+    }
+
+    public RaiseTaskError build() {
+      return new RaiseTaskError().withRaiseErrorDefinition(this.error);
+    }
+  }
+}

experimental/fluent/func/src/main/java/io/serverlessworkflow/fluent/func/FuncTaskItemListBuilder.java

@@ -93,6 +93,16 @@ public FuncTaskItemListBuilder listen(
         new TaskItem(name, new Task().withListenTask(listenTaskJavaBuilder.build())));
   }
 
+  @Override
+  public FuncTaskItemListBuilder raise(
+      String name, Consumer<FuncRaiseTaskBuilder> itemsConfigurer) {
+    name = this.defaultNameAndRequireConfig(name, itemsConfigurer, TYPE_RAISE);
+    final FuncRaiseTaskBuilder raiseTaskJavaBuilder = new FuncRaiseTaskBuilder();
+    itemsConfigurer.accept(raiseTaskJavaBuilder);
+    return this.addTaskItem(
+        new TaskItem(name, new Task().withRaiseTask(raiseTaskJavaBuilder.build())));
+  }
+
   @Override
   public FuncTaskItemListBuilder forEach(
       String name, Consumer<FuncForTaskBuilder> itemsConfigurer) {
@@ -154,4 +164,13 @@ public FuncTaskItemListBuilder openapi(
 
     return this.addTaskItem(new TaskItem(name, task));
   }
+
+  @Override
+  public FuncTaskItemListBuilder tryCatch(
+      String name, Consumer<FuncTryTaskBuilder> itemsConfigurer) {
+    name = this.defaultNameAndRequireConfig(name, itemsConfigurer, TYPE_TRY);
+    final FuncTryTaskBuilder tryTaskBuilder = new FuncTryTaskBuilder();
+    itemsConfigurer.accept(tryTaskBuilder);
+    return this.addTaskItem(new TaskItem(name, new Task().withTryTask(tryTaskBuilder.build())));
+  }
 }