Added performance tests

composer.json

@@ -36,6 +36,7 @@
   },
   "require-dev": {
     "nunomaduro/phpinsights": "^2.11",
+    "petrknap/profiler": "^2.2",
     "petrknap/shorts": "^3.0",
     "phpstan/phpstan": "^1.12",
     "squizlabs/php_codesniffer": "^3.7",

tests/FilterTest.php

@@ -1,12 +1,18 @@
 <?php
 
 declare(strict_types=1);
 
 namespace PetrKnap\ExternalFilter;
 
+use PetrKnap\Profiler\ProfileInterface;
+use PetrKnap\Profiler\Profiler;
+use PetrKnap\Profiler\ProfilerInterface;
 use PHPUnit\Framework\Attributes\DataProvider;
+use PHPUnit\Framework\Attributes\Depends;
+use PHPUnit\Framework\ExpectationFailedException;
 use PHPUnit\Framework\TestCase;
 use stdClass;
+use Symfony\Component\Process\Process;
 
 final class FilterTest extends TestCase
 {
@@ -19,7 +25,7 @@
         );
     }
 
     public static function dataFiltersInput(): iterable
     {
         $helloWorldPhpStdOut = 'Hello, World!';
         $helloWorldPhpFile = __DIR__ . '/Some/hello-world.php';
@@ -33,17 +39,17 @@
         $inMemoryStream = fopen('php://memory', 'w+');
         fwrite($inMemoryStream, $fileContent);
         rewind($inMemoryStream);
         yield 'resource(in-memory stream)' => [$inMemoryStream, $helloWorldPhpStdOut];
     }
 
     #[DataProvider('dataWritesToStreamsAndReturnsExpectedValue')]
     public function testWritesToStreamsAndReturnsExpectedValue(bool $useOutput, bool $useError): void
     {
         $outputStream = fopen('php://memory', 'w+');
         $errorStream = fopen('php://memory', 'w+');
 
         $returned = (new Filter('php'))->filter(
             input: '<?php fwrite(fopen("php://stdout", "w"), "output"); fwrite(fopen("php://stderr", "w"), "error");',
             output: $useOutput ? $outputStream : null,
             error: $useError ? $errorStream : null,
         );
@@ -61,7 +67,7 @@
         ]);
     }
 
     public static function dataWritesToStreamsAndReturnsExpectedValue(): array
     {
         return [
             'no stream' => [false, false],
@@ -71,26 +77,65 @@
         ];
     }
 
-    public function testBuildsAndExecutesPipeline(): void
+    public function testBuildsAndExecutesPipeline(): ProfileInterface
     {
-        $pipeline = (new Filter('gzip'))->pipe(new Filter('base64'))->pipe(new Filter('base64', ['--decode']));
-        $filter = new Filter('gzip', ['--decompress']);
+        $reference = Process::fromShellCommandline(
+            'php | base64 --decode | wc --bytes',
+        );
+        $pipeline = (new Filter('php'))
+            ->pipe(new Filter('base64', ['--decode']))
+            ->pipe(new Filter('wc', ['--bytes']));
 
-        self::assertSame(
-            'test',
-            (new Filter('cat'))->pipe($pipeline)->pipe($filter)->filter('test'),
+        $input = '<?php for ($i = 0; $i < 16; $i++) echo base64_encode(random_bytes(512 * 1024)) . PHP_EOL;';
+        $output = (16 * 512 * 1024) . PHP_EOL;
+
+        return (new Profiler())->profile(static fn (ProfilerInterface $profiler) => self::assertSame([
+            'reference' => $output,
+            'pipeline' => $output,
+        ], [
+            'reference' => $profiler->profile(static fn (): string => $reference->setInput($input)->mustRun()->getOutput())->getOutput(),
+            'pipeline' => $profiler->profile(static fn (): string => $pipeline->filter($input))->getOutput(),
+        ]));
+    }
+
+    #[Depends('testBuildsAndExecutesPipeline')]
+    public function testPipelineDoesNotHaveMemoryLeak(ProfileInterface $profile): void
+    {
+        [$referenceProfile, $pipelineProfile] = $profile->getChildren();
+
+        self::assertLessThanOrEqual(
+            $referenceProfile->getMemoryUsageChange() * 1.05,  # allow 5% overhead
+            $pipelineProfile->getMemoryUsageChange(),
         );
+
+        if ($referenceProfile->getMemoryUsageChange() !== 0) {
+            self::markTestIncomplete('Memory leak detected in reference.');
+        }
+    }
+
+    #[Depends('testBuildsAndExecutesPipeline')]
+    public function testPipelinePerformanceIsOk(ProfileInterface $profile): void
+    {
+        [$referenceProfile, $pipelineProfile] = $profile->getChildren();
+        try {  # @todo fix performance and remove try / catch
+            self::assertLessThanOrEqual(
+                $referenceProfile->getDuration() * 1.05,  # allow 5% overhead
+                $pipelineProfile->getDuration(),
+            );
+        } catch (ExpectationFailedException $expectationFailed) {
+            self::markTestIncomplete($expectationFailed->getMessage());
+        }
     }
 
     #[DataProvider('dataThrows')]
     public function testThrows(string $command, array $options, mixed $input, mixed $output, mixed $error): void
     {
         self::expectException(Exception\FilterException::class);
 
         (new Filter($command, $options))->filter($input, $output, $error);
     }
 
     public static function dataThrows(): array
     {
         $closedStream = fopen('php://memory', 'w');
         fclose($closedStream);