move the BuilderTestCase from akeneo-plugin to phpunit-extension

Author: clemzarch

src/BuilderTestCase.php

@@ -0,0 +1,33 @@
+<?php declare(strict_types=1);
+
+namespace Kiboko\Component\PHPUnitExtension;
+
+use Kiboko\Contract\Pipeline\PipelineRunnerInterface;
+use org\bovigo\vfs\vfsStream;
+use org\bovigo\vfs\vfsStreamDirectory;
+use PHPUnit\Framework\TestCase;
+
+abstract class BuilderTestCase extends TestCase
+{
+    private ?vfsStreamDirectory $fs = null;
+
+    protected function setUp(): void
+    {
+        $this->fs = vfsStream::setup();
+    }
+
+    protected function tearDown(): void
+    {
+        $this->fs = null;
+    }
+
+    protected function getBuilderCompilePath(): string
+    {
+        return $this->fs->url();
+    }
+
+    public function pipelineRunner(): PipelineRunnerInterface
+    {
+        return new PipelineRunner();
+    }
+}

src/PipelineRunner.php

@@ -0,0 +1,45 @@
+<?php declare(strict_types=1);
+
+namespace Kiboko\Component\PHPUnitExtension;
+
+use Kiboko\Contract\Bucket\AcceptanceResultBucketInterface;
+use Kiboko\Contract\Bucket\RejectionResultBucketInterface;
+use Kiboko\Contract\Pipeline\PipelineRunnerInterface;
+use Kiboko\Contract\Pipeline\RejectionInterface;
+use Kiboko\Contract\Pipeline\StateInterface;
+
+final class PipelineRunner implements PipelineRunnerInterface
+{
+    public function run(
+        \Iterator $source,
+        \Generator $async,
+        RejectionInterface $rejection,
+        StateInterface $state,
+    ): \Iterator {
+        $state->initialize();
+        $rejection->initialize();
+
+        $source->rewind();
+        $async->rewind();
+
+        while ($source->valid() && $async->valid()) {
+            $bucket = $async->send($source->current());
+
+            if ($bucket instanceof RejectionResultBucketInterface) {
+                foreach ($bucket->walkRejection() as $line) {
+                    $rejection->reject($line);
+                    $state->reject();
+                }
+            }
+            if ($bucket instanceof AcceptanceResultBucketInterface) {
+                yield from $bucket->walkAcceptance();
+                $state->accept();
+            }
+
+            $source->next();
+        }
+
+        $rejection->teardown();
+        $state->teardown();
+    }
+}