[Fix Fast Cash BSN Credit Card] Adding test with fixed collection (Product Sale Template)

* [Fix What Is Blog Post Writing] Adding test with fixed collection Signed-off-by: Francisco Javier Tirado Sarti <ftirados@ibm.com> * [Fix Formal Insta Story Template] Update example after schema fix Signed-off-by: Francisco Javier Tirado Sarti <ftirados@ibm.com> --------- Signed-off-by: Francisco Javier Tirado Sarti <ftirados@ibm.com>

Author: Blogs To Read About Life

fluent/spec/src/main/java/io/serverlessworkflow/fluent/spec/ForEachTaskBuilder.java

@@ -15,9 +15,9 @@
  */
 package io.serverlessworkflow.fluent.spec;
 
+import io.serverlessworkflow.api.types.ForIn;
 import io.serverlessworkflow.api.types.ForTask;
 import io.serverlessworkflow.api.types.ForTaskConfiguration;
-import io.serverlessworkflow.api.types.In;
 import io.serverlessworkflow.api.types.TaskItem;
 import io.serverlessworkflow.fluent.spec.spi.ForEachTaskFluent;
 import java.util.List;
@@ -50,7 +50,7 @@ public ForEachTaskBuilder<T> each(String each) {
  }
 
  public ForEachTaskBuilder<T> in(String in) {
- this.forTaskConfiguration.setIn(new In().withForInExpression(in));
+ this.forTaskConfiguration.setIn(new ForIn().withForInExpression(in));
  return this;
  }
 

impl/core/src/main/java/io/serverlessworkflow/impl/executors/ForExecutor.java

@@ -15,8 +15,8 @@
  */
 package io.serverlessworkflow.impl.executors;
 
+import io.serverlessworkflow.api.types.ForIn;
 import io.serverlessworkflow.api.types.ForTask;
-import io.serverlessworkflow.api.types.In;
 import io.serverlessworkflow.impl.TaskContext;
 import io.serverlessworkflow.impl.WorkflowContext;
 import io.serverlessworkflow.impl.WorkflowDefinition;
@@ -51,7 +51,7 @@ protected Optional<WorkflowPredicate> buildWhileFilter() {
  }
 
  protected WorkflowValueResolver<Collection<?>> buildCollectionFilter() {
- In in = task.getFor().getIn();
+ ForIn in = task.getFor().getIn();
  return application
  .expressionFactory()
  .resolveCollection(

impl/test/src/test/java/io/serverlessworkflow/impl/test/WorkflowDefinitionTest.java

@@ -80,6 +80,11 @@ private static Stream<Arguments> provideParameters() {
  Map.of("input", Arrays.asList(1, 2, 3)),
  o -> assertThat(o).isEqualTo(6),
  c -> assertThat(c).isEqualTo(Map.of("incr", Arrays.asList(2, 3, 4)))),
+ args(
+ "workflows-samples/for-sum-fixed.yaml",
+ Map.of(),
+ o -> assertThat(o).isEqualTo(6),
+ c -> assertThat(c).isEqualTo(Map.of("incr", Arrays.asList(2, 3, 4)))),
  args(
  "workflows-samples/switch-then-loop.yaml",
  Map.of("count", 1),

impl/test/src/test/resources/workflows-samples/for-sum-fixed.yaml

@@ -0,0 +1,22 @@
+document:
+ dsl: '1.0.0-alpha5'
+ namespace: test
+ name: for-sum-fixed-example
+ version: '0.1.0'
+do:
+ - sumAll:
+ for:
+ each: number
+ in: 
+ - 1
+ - 2
+ - 3
+ do:
+ - accumulate:
+ set:
+ counter: ${.counter+$number}
+ export: 
+ as: if .incr==null then {incr:[$number+1]} else .incr+=[$number+1] end 
+ output:
+ as: .counter
+ 

types/src/main/resources/schema/workflow.yaml

@@ -711,9 +711,8 @@ $defs:
  description: A runtime expression used to get the collection to enumerate.
  - type: array
  title: ForInInlineArray
- description: An inline array of objects to enumerate.
+ description: An inline array to enumerate.
  items:
- type: object
  description: An item in the inline collection.
  at:
  type: string