Add new Any & All expressions (#521)

src/core/etl/src/Flow/ETL/DSL/functions.php

@@ -231,6 +231,16 @@ function array_sort(Expression $expression, \Closure $function = null) : Express
     return new Expression\ArraySort($expression, $function ?? \Closure::fromCallable('sort'));
 }
 
+function all(Expression ...$expressions) : Expression
+{
+    return new Expression\All(...$expressions);
+}
+
+function any(Expression ...$expressions) : Expression
+{
+    return new Expression\Any(...$expressions);
+}
+
 function not(Expression $expression) : Expression
 {
     return new Expression\Not($expression);

src/core/etl/src/Flow/ETL/Row/Reference/Expression/All.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Flow\ETL\Row\Reference\Expression;
+
+use Flow\ETL\Row;
+use Flow\ETL\Row\Reference\Expression;
+
+final class All implements Expression
+{
+    /**
+     * @var array<Expression>
+     */
+    private readonly array $refs;
+
+    public function __construct(
+        Expression ...$refs,
+    ) {
+        $this->refs = $refs;
+    }
+
+    public function eval(Row $row) : mixed
+    {
+        foreach ($this->refs as $ref) {
+            if (!$ref->eval($row)) {
+                return false;
+            }
+        }
+
+        return true;
+    }
+}

src/core/etl/src/Flow/ETL/Row/Reference/Expression/Any.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Flow\ETL\Row\Reference\Expression;
+
+use Flow\ETL\Row;
+use Flow\ETL\Row\Reference\Expression;
+
+final class Any implements Expression
+{
+    /**
+     * @var array<Expression>
+     */
+    private readonly array $refs;
+
+    public function __construct(
+        Expression ...$refs,
+    ) {
+        $this->refs = $refs;
+    }
+
+    public function eval(Row $row) : mixed
+    {
+        foreach ($this->refs as $ref) {
+            if ($ref->eval($row)) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+}

src/core/etl/tests/Flow/ETL/Tests/Unit/Row/Reference/Expression/AllTest.php

@@ -0,0 +1,50 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Flow\ETL\Tests\Unit\Row\Reference\Expression;
+
+use function Flow\ETL\DSL\all;
+use function Flow\ETL\DSL\lit;
+use function Flow\ETL\DSL\ref;
+use Flow\ETL\DSL\Entry;
+use Flow\ETL\Row;
+use PHPUnit\Framework\TestCase;
+
+final class AllTest extends TestCase
+{
+    public function test_all_expression_on_boolean_false_value() : void
+    {
+        $this->assertFalse(
+            all(lit(false))->eval(Row::create())
+        );
+    }
+
+    public function test_all_expression_on_boolean_true_value() : void
+    {
+        $this->assertTrue(
+            all(lit(true))->eval(Row::create())
+        );
+    }
+
+    public function test_all_expression_on_is_null_expression() : void
+    {
+        $this->assertTrue(
+            all(ref('value')->isNull())->eval(Row::create(Entry::null('value')))
+        );
+    }
+
+    public function test_all_expression_on_multiple_boolean_values() : void
+    {
+        $this->assertTrue(
+            all(lit(true), lit(true), lit(true))->eval(Row::create())
+        );
+    }
+
+    public function test_all_expression_on_multiple_random_boolean_values() : void
+    {
+        $this->assertFalse(
+            all(lit(true), lit(false), lit(true))->eval(Row::create())
+        );
+    }
+}

src/core/etl/tests/Flow/ETL/Tests/Unit/Row/Reference/Expression/AnyTest.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Flow\ETL\Tests\Unit\Row\Reference\Expression;
+
+use function Flow\ETL\DSL\any;
+use function Flow\ETL\DSL\lit;
+use function Flow\ETL\DSL\ref;
+use Flow\ETL\DSL\Entry;
+use Flow\ETL\Row;
+use PHPUnit\Framework\TestCase;
+
+final class AnyTest extends TestCase
+{
+    public function test_any_expression_on_boolean_false_value() : void
+    {
+        $this->assertFalse(
+            any(lit(false))->eval(Row::create())
+        );
+    }
+
+    public function test_any_expression_on_boolean_true_value() : void
+    {
+        $this->assertTrue(
+            any(lit(true))->eval(Row::create())
+        );
+    }
+
+    public function test_any_expression_on_is_null_expression() : void
+    {
+        $this->assertTrue(
+            any(ref('value')->isNull())->eval(Row::create(Entry::null('value')))
+        );
+    }
+
+    public function test_any_expression_on_multiple_boolean_values() : void
+    {
+        $this->assertTrue(
+            any(lit(false), lit(true), lit(false))->eval(Row::create())
+        );
+    }
+}