added performance test for 50k rows

Author: transistive

src/protocol/V3.php

@@ -73,7 +73,7 @@ public function run(...$args): array
         $this->write($this->packer->pack(
             0x10,
             $args[0],
-            $args[1] ?? [],
+            (object)($args[1] ?? []),
             (object)($args[2] ?? [])
         ));
         $message = $this->read($signature);

tests/PackStream/v1/generators/RandomDataGenerator.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace Bolt\tests\PackStream\v1\generators;
+
+use Bolt\PackStream\IPackListGenerator;
+use function bin2hex;
+use function hex2bin;
+use function random_bytes;
+
+class RandomDataGenerator implements IPackListGenerator
+{
+    private int $rows;
+    private int $count = 0;
+
+    public function __construct(int $rows)
+    {
+        $this->rows = $rows;
+    }
+
+    public function current(): array
+    {
+        return [bin2hex(random_bytes(0x20)) => bin2hex(random_bytes(0x800))];
+    }
+
+    public function next(): void
+    {
+        ++$this->count;
+    }
+
+    public function key(): int
+    {
+        return $this->count;
+    }
+
+    public function valid(): bool
+    {
+        return $this->count < $this->rows;
+    }
+
+    public function rewind(): void
+    {
+        $this->count = 0;
+    }
+
+    public function count(): int
+    {
+        return $this->rows;
+    }
+}

tests/PerformanceTest.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Bolt\tests;
+
+use Bolt\Bolt;
+use Bolt\connection\StreamSocket;
+use Bolt\helpers\Auth;
+use Bolt\tests\PackStream\v1\generators\RandomDataGenerator;
+use PHPUnit\Framework\TestCase;
+
+class PerformanceTest extends TestCase
+{
+    public function test50KRecords(): void
+    {
+        $amount = 50000;
+
+        $conn = new StreamSocket($GLOBALS['NEO_HOST'] ?? 'localhost', $GLOBALS['NEO_PORT'] ?? 7687);
+        $protocol = (new Bolt($conn))->build();
+        $this->assertNotEmpty($protocol->init(Auth::basic($GLOBALS['NEO_USER'], $GLOBALS['NEO_PASS'])));
+
+        $generator = new RandomDataGenerator($amount);
+        $protocol->run('UNWIND $x as x RETURN x', ['x' => $generator]);
+
+        $count = 0;
+        while ($count < $amount) {
+            ++$count;
+            $protocol->pull(['n' => 1]);
+        }
+
+        $this->assertEquals($amount, $count);
+    }
+}