add function that will display as many SQL parameters as there are values under "$path"

Author: clemzarch

src/Console/Command/PipelineRunCommand.php

@@ -42,10 +42,10 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         $dotenv = new Dotenv();
         $dotenv->usePutenv();
 
-        if (file_exists($file = $cwd . '/.env')) {
+        if (file_exists($file = $cwd.'/.env')) {
             $dotenv->loadEnv($file);
         }
-        if (file_exists($file = $cwd . '/' . $input->getArgument('path') . '/.env')) {
+        if (file_exists($file = $cwd.'/'.$input->getArgument('path').'/.env')) {
             $dotenv->loadEnv($file);
         }
 

src/ExpressionLanguage/InSql.php

@@ -0,0 +1,39 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Kiboko\Component\Satellite\ExpressionLanguage;
+
+use Symfony\Component\ExpressionLanguage\ExpressionFunction;
+
+final class InSql extends ExpressionFunction
+{
+    public function __construct(string $name)
+    {
+        parent::__construct(
+            $name,
+            function (string $path, string $name): string {
+                $pattern = <<<'PHP'
+                    (function () use ($input) {
+                        $parameters = [];
+                        foreach (%s as $key => $value) {
+                            $parameters[] = ':' . %s . '_' . $key;
+                        } 
+                        
+                        return 'IN (' . implode(', ', $parameters) . ')';
+                    })()
+                    PHP;
+
+                return sprintf($pattern, $path, $name);
+            },
+            function (array $path, string $name) {
+                $parameters = [];
+                foreach ($path as $key => $value) {
+                    $parameters[] = ':'.$name.'_'.$key;
+                }
+
+                return 'IN ('.implode(', ', $parameters).')';
+            },
+        );
+    }
+}

src/ExpressionLanguage/Provider.php

@@ -16,6 +16,7 @@ public function getFunctions(): array
             new File('file'),
             new Base64Decode('base64Decode'),
             new TemporaryFile('temporaryFile'),
+            new InSql('inSql'),
         ];
     }
 }