move the BuilderTestCase from akeneo-plugin to phpunit-extension

Author: clemzarch

composer.json

@@ -12,7 +12,7 @@
         "php-http/mock-client": "^1.4@dev",
         "fakerphp/faker": "^1.19",
         "laminas/laminas-diactoros": "^2.6",
-        "akeneo/api-php-client": "^9.0"
+        "mikey179/vfsstream": "^1.6"
     },
     "license": "MIT",
     "authors": [

composer.lock

@@ -0,0 +1,74 @@
+<?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 PhpParser\Builder as DefaultBuilder;
+use PhpParser\Node;
+use PhpParser\PrettyPrinter;
+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();
+    }
+
+    protected function assertNodeIsInstanceOf(string $expected, DefaultBuilder $builder, string $message = '')
+    {
+        $printer = new PrettyPrinter\Standard();
+
+        try {
+            $filename = sha1(random_bytes(128)) .'.php';
+            file_put_contents($this->fs->url() . '/' . $filename, $printer->prettyPrintFile([
+                new Node\Stmt\Return_($builder->getNode()),
+            ]));
+
+            $actual = include $this->fs->url().'/'.$filename;
+        } catch (\ParseError $exception) {
+            echo $printer->prettyPrintFile([$builder->getNode()]);
+            $this->fail($exception->getMessage());
+        }
+
+        $this->assertInstanceOf($expected, $actual, $message);
+    }
+
+    protected function assertNodeIsNotInstanceOf(string $expected, DefaultBuilder $builder, string $message = '')
+    {
+        $printer = new PrettyPrinter\Standard();
+
+        try {
+            $filename = sha1(random_bytes(128)) .'.php';
+            file_put_contents($this->fs->url() . '/' . $filename, $printer->prettyPrintFile([
+                new Node\Stmt\Return_($builder->getNode()),
+            ]));
+
+            $actual = include $this->fs->url().'/'.$filename;
+        } catch (\ParseError $exception) {
+            echo $printer->prettyPrintFile([$builder->getNode()]);
+            $this->fail($exception->getMessage());
+        }
+
+        $this->assertNotInstanceOf($expected, $actual, $message);
+    }
+}

src/BuilderTestCase.php

@@ -23,7 +23,7 @@ class: new Node\Name\FullyQualified($this->mockedClientBuilder),
                     new Node\Scalar\String_('https://akeneo.'.$faker->safeEmailDomain()),
                 ),
             ],
-        );;
+        );
     }
 
     public function withHttpClient(Mock\HttpClientBuilder $httpClient): self

src/Mock/ApiClientMockBuilder.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();
+    }
+}