Skip to content

Commit c754c57

Browse files
committed
refactor: RaiseTask and TryTask builders to extend base builder classes
Signed-off-by: Matheus André <matheusandr2@gmail.com>
1 parent 9204603 commit c754c57

8 files changed

Lines changed: 505 additions & 913 deletions

File tree

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

Lines changed: 3 additions & 71 deletions
Original file line numberDiff line numberDiff line change
@@ -15,88 +15,20 @@
1515
*/
1616
package io.serverlessworkflow.fluent.func;
1717

18-
import io.serverlessworkflow.api.types.ErrorDetails;
19-
import io.serverlessworkflow.api.types.ErrorTitle;
20-
import io.serverlessworkflow.api.types.ErrorType;
21-
import io.serverlessworkflow.api.types.RaiseTask;
22-
import io.serverlessworkflow.api.types.RaiseTaskConfiguration;
23-
import io.serverlessworkflow.api.types.RaiseTaskError;
24-
import io.serverlessworkflow.api.types.UriTemplate;
2518
import io.serverlessworkflow.fluent.func.spi.ConditionalTaskBuilder;
2619
import io.serverlessworkflow.fluent.func.spi.FuncTaskTransformations;
27-
import io.serverlessworkflow.fluent.spec.TaskBaseBuilder;
28-
import java.net.URI;
29-
import java.util.function.Consumer;
20+
import io.serverlessworkflow.fluent.spec.BaseRaiseTaskBuilder;
3021

31-
public class FuncRaiseTaskBuilder extends TaskBaseBuilder<FuncRaiseTaskBuilder>
22+
public class FuncRaiseTaskBuilder extends BaseRaiseTaskBuilder<FuncRaiseTaskBuilder>
3223
implements FuncTaskTransformations<FuncRaiseTaskBuilder>,
3324
ConditionalTaskBuilder<FuncRaiseTaskBuilder> {
3425

35-
private final RaiseTask raiseTask;
36-
3726
FuncRaiseTaskBuilder() {
38-
this.raiseTask = new RaiseTask();
39-
setTask(this.raiseTask);
27+
super();
4028
}
4129

4230
@Override
4331
protected FuncRaiseTaskBuilder self() {
4432
return this;
4533
}
46-
47-
public FuncRaiseTaskBuilder error(Consumer<RaiseTaskErrorBuilder> consumer) {
48-
final RaiseTaskErrorBuilder raiseTaskErrorBuilder = new RaiseTaskErrorBuilder();
49-
consumer.accept(raiseTaskErrorBuilder);
50-
this.raiseTask.setRaise(new RaiseTaskConfiguration().withError(raiseTaskErrorBuilder.build()));
51-
return this;
52-
}
53-
54-
public FuncRaiseTaskBuilder error(String errorReference) {
55-
this.raiseTask.setRaise(
56-
new RaiseTaskConfiguration()
57-
.withError(new RaiseTaskError().withRaiseErrorReference(errorReference)));
58-
return this;
59-
}
60-
61-
public RaiseTask build() {
62-
return this.raiseTask;
63-
}
64-
65-
public static final class RaiseTaskErrorBuilder {
66-
private final io.serverlessworkflow.api.types.Error error;
67-
68-
private RaiseTaskErrorBuilder() {
69-
this.error = new io.serverlessworkflow.api.types.Error();
70-
}
71-
72-
public RaiseTaskErrorBuilder type(String expression) {
73-
this.error.setType(new ErrorType().withExpressionErrorType(expression));
74-
return this;
75-
}
76-
77-
public RaiseTaskErrorBuilder type(URI errorType) {
78-
this.error.setType(
79-
new ErrorType().withLiteralErrorType(new UriTemplate().withLiteralUri(errorType)));
80-
return this;
81-
}
82-
83-
public RaiseTaskErrorBuilder status(int status) {
84-
this.error.setStatus(status);
85-
return this;
86-
}
87-
88-
public RaiseTaskErrorBuilder title(String expression) {
89-
this.error.setTitle(new ErrorTitle().withExpressionErrorTitle(expression));
90-
return this;
91-
}
92-
93-
public RaiseTaskErrorBuilder detail(String expression) {
94-
this.error.setDetail(new ErrorDetails().withExpressionErrorDetails(expression));
95-
return this;
96-
}
97-
98-
public RaiseTaskError build() {
99-
return new RaiseTaskError().withRaiseErrorDefinition(this.error);
100-
}
101-
}
10234
}

0 commit comments

Comments
 (0)