Merge pull request serverlessworkflow#997 from neuroglia-io/feat-listen-any-events-until

Added a new `until` property to `any` event consumption strategies

Author: cdavernas

.ci/validation/test/fixtures/invalid/listen-any-empty-no-until.yaml

@@ -0,0 +1,10 @@
+document:
+  dsl: '1.0.0-alpha1'
+  namespace: test
+  name: listen-to-any
+  version: '0.1.0'
+do:
+  - callDoctor:
+      listen:
+        to:
+          any: []

.ci/validation/test/fixtures/invalid/listen-any-until-any-until.yaml

@@ -0,0 +1,14 @@
+document:
+  dsl: '1.0.0-alpha1'
+  namespace: test
+  name: listen-to-any
+  version: '0.1.0'
+do:
+do:
+  - callDoctor:
+      listen:
+        to:
+          any: []
+          until:
+            any: []
+            until: ${ ($context.events | length) == 3 }

dsl-reference.md

@@ -1580,8 +1580,9 @@ Represents the configuration of an event consumption strategy.
 | Property | Type | Required | Description |
 |----------|:----:|:--------:|-------------|
 | all | [`eventFilter[]`](#event-filter) | `no` | Configures the workflow to wait for all defined events before resuming execution.<br>*Required if `any` and `one` have not been set.* |
-| any | [`eventFilter[]`](#event-filter) | `no` | Configures the workflow to wait for any of the defined events before resuming execution.<br>*Required if `all` and `one` have not been set.* |
+| any | [`eventFilter[]`](#event-filter) | `no` | Configures the workflow to wait for any of the defined events before resuming execution.<br>*Required if `all` and `one` have not been set.*<br>*If empty, listens to all incoming events, and requires `until` to be set.* |
 | one | [`eventFilter`](#event-filter) | `no` | Configures the workflow to wait for the defined event before resuming execution.<br>*Required if `all` and `any` have not been set.* |
+| until | `string`<br>[`eventConsumptionStrategy`](#event-consumption-strategy) | `no` | Configures the [runtime expression](dsl.md#runtime-expressions) condition or the events that must be consumed to stop listening.<br>*Only applies if `any` has been set, otherwise ignored.* |
 
 ### Event Properties
 

examples/listen-to-any-until-condition.yaml

@@ -0,0 +1,11 @@
+document:
+  dsl: '1.0.0-alpha1'
+  namespace: test
+  name: listen-to-any
+  version: '0.1.0'
+do:
+  - callDoctor:
+      listen:
+        to:
+          any: []
+          until: ( . | length ) > 3 #wait until 3 events have been consumed

examples/listen-to-any-until-consumed.yaml

@@ -0,0 +1,20 @@
+document:
+  dsl: '1.0.0-alpha1'
+  namespace: test
+  name: listen-to-any
+  version: '0.1.0'
+do:
+  - callDoctor:
+      listen:
+        to:
+          any:
+            - with:
+                type: com.fake-hospital.vitals.measurements.temperature
+                data: ${ .temperature > 38 }
+            - with:
+                type: com.fake-hospital.vitals.measurements.bpm
+                data: ${ .bpm < 60 or .bpm > 100 }
+          until:
+            one:
+              with:
+                type: com.fake-hospital.patient.checked-out

schema/workflow.yaml

@@ -1309,14 +1309,47 @@ $defs:
               $ref: '#/$defs/eventFilter'
         required: [ all ]
       - title: AnyEventConsumptionStrategy
-        properties:
-          any:
-            type: array
-            title: AnyEventConsumptionStrategyConfiguration
-            description: A list containing any of the events to consume.
-            items:
-              $ref: '#/$defs/eventFilter'
-        required: [ any ]
+        oneOf:
+          - properties:
+              any:
+                type: array
+                title: AnyEventConsumptionStrategyConfiguration
+                description: A list containing any of the events to consume.
+                items:
+                  $ref: '#/$defs/eventFilter'
+                minItems: 1
+              until:
+                oneOf:
+                  - type: string
+                    title: AnyEventUntilCondition
+                    description: A runtime expression condition evaluated after consuming an event and which determines whether or not to continue listening.
+                  - allOf:
+                      - $ref: '#/$defs/eventConsumptionStrategy'
+                        title: AnyEventUntilConsumed
+                        description: The strategy that defines the event(s) to consume to stop listening.
+                      - properties:
+                          until: false
+            required: [ any ]
+          - properties:
+              any:
+                type: array
+                title: AnyEventConsumptionStrategyConfiguration
+                description: A list containing any of the events to consume.
+                items:
+                  $ref: '#/$defs/eventFilter'
+                maxItems: 0
+              until:
+                oneOf:
+                  - type: string
+                    title: AnyEventUntilCondition
+                    description: A runtime expression condition evaluated after consuming an event and which determines whether or not to continue listening.
+                  - allOf:
+                      - $ref: '#/$defs/eventConsumptionStrategy'
+                        title: AnyEventUntilConsumed
+                        description: The strategy that defines the event(s) to consume to stop listening.
+                      - properties:
+                          until: false
+            required: [ any, until ]
       - title: OneEventConsumptionStrategy
         properties:
           one: