add split stream benchmark

tests/Benchmark/BasicImplementation/Aggregate/Profile.php

@@ -10,6 +10,7 @@
 use Patchlevel\EventSourcing\Attribute\Snapshot;
 use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events\NameChanged;
 use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events\ProfileCreated;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events\Reborn;
 use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Normalizer\ProfileIdNormalizer;
 use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\ProfileId;
 
@@ -39,6 +40,14 @@ public function changeName(string $name): void
         $this->recordThat(new NameChanged($name));
     }
 
+    public function reborn(): void
+    {
+        $this->recordThat(new Reborn(
+            $this->id,
+            $this->name
+        ));
+    }
+
     #[Apply]
     protected function applyProfileCreated(ProfileCreated $event): void
     {
@@ -52,6 +61,13 @@ protected function applyNameChanged(NameChanged $event): void
         $this->name = $event->name;
     }
 
+    #[Apply]
+    protected function applyReborn(Reborn $event): void
+    {
+        $this->id = $event->profileId;
+        $this->name = $event->name;
+    }
+
     public function name(): string
     {
         return $this->name;

tests/Benchmark/BasicImplementation/Events/Reborn.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events;
+
+use Patchlevel\EventSourcing\Attribute\Event;
+use Patchlevel\EventSourcing\Attribute\SplitStream;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Normalizer\ProfileIdNormalizer;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\ProfileId;
+
+#[Event('profile.reborn')]
+#[SplitStream]
+final class Reborn
+{
+    public function __construct(
+        #[ProfileIdNormalizer]
+        public ProfileId $profileId,
+        public string $name,
+    ) {
+    }
+}

tests/Benchmark/LoadEventsWithSnapshotsBench.php → tests/Benchmark/SnapshotsBench.php

@@ -26,7 +26,7 @@
 use function unlink;
 
 #[Bench\BeforeMethods('setUp')]
-final class LoadEventsWithSnapshotsBench
+final class SnapshotsBench
 {
     private const DB_PATH = __DIR__ . '/BasicImplementation/data/db.sqlite3';
 

tests/Benchmark/SplitStreamBench.php

@@ -0,0 +1,115 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Benchmark;
+
+use Doctrine\DBAL\Driver\PDO\SQLite\Driver;
+use Doctrine\DBAL\DriverManager;
+use Patchlevel\EventSourcing\EventBus\Decorator\SplitStreamDecorator;
+use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
+use Patchlevel\EventSourcing\EventBus\EventBus;
+use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
+use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
+use Patchlevel\EventSourcing\Repository\DefaultRepository;
+use Patchlevel\EventSourcing\Repository\Repository;
+use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
+use Patchlevel\EventSourcing\Serializer\DefaultEventSerializer;
+use Patchlevel\EventSourcing\Snapshot\Adapter\InMemorySnapshotAdapter;
+use Patchlevel\EventSourcing\Snapshot\DefaultSnapshotStore;
+use Patchlevel\EventSourcing\Snapshot\SnapshotStore;
+use Patchlevel\EventSourcing\Store\DoctrineDbalStore;
+use Patchlevel\EventSourcing\Store\Store;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Aggregate\Profile;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\ProfileId;
+use PhpBench\Attributes as Bench;
+
+use function file_exists;
+use function unlink;
+
+#[Bench\BeforeMethods('setUp')]
+final class SplitStreamBench
+{
+    private const DB_PATH = __DIR__ . '/BasicImplementation/data/db.sqlite3';
+
+    private Store $store;
+    private EventBus $bus;
+    private SnapshotStore $snapshotStore;
+    private Repository $repository;
+
+    public function setUp(): void
+    {
+        if (file_exists(self::DB_PATH)) {
+            unlink(self::DB_PATH);
+        }
+
+        $connection = DriverManager::getConnection([
+            'driverClass' => Driver::class,
+            'path' => self::DB_PATH,
+        ]);
+
+        $this->bus = new DefaultEventBus();
+
+        $this->store = new DoctrineDbalStore(
+            $connection,
+            DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
+            (new AttributeAggregateRootRegistryFactory())->create([__DIR__ . '/BasicImplementation/Aggregate']),
+            'eventstore',
+        );
+
+        $this->repository = new DefaultRepository(
+            $this->store,
+            $this->bus,
+            Profile::metadata(),
+            null,
+            new SplitStreamDecorator(
+                new AttributeEventMetadataFactory()
+            )
+        );
+
+        $schemaDirector = new DoctrineSchemaDirector(
+            $connection,
+            $this->store,
+        );
+
+        $schemaDirector->create();
+    }
+
+    public function provideData(): void
+    {
+        $profile = Profile::create(ProfileId::fromString('1'), 'Peter');
+
+        for ($i = 0; $i < 10_000; $i++) {
+            $profile->changeName(sprintf('Peter %d', $i));
+
+            if ($i % 100 === 0) {
+                $profile->reborn();
+            }
+        }
+
+        $this->repository->save($profile);
+    }
+
+    #[Bench\Revs(20)]
+    #[Bench\BeforeMethods("provideData")]
+    public function benchLoad10000Events(): void
+    {
+        $this->repository->load('1');
+    }
+
+    #[Bench\Revs(20)]
+    public function benchWrite10000Events(): void
+    {
+        $profile = Profile::create(ProfileId::fromString('1'), 'Peter');
+
+        for ($i = 0; $i < 10_000; $i++) {
+            $profile->changeName(sprintf('Peter %d', $i));
+
+            if ($i % 100 === 0) {
+                $profile->reborn();
+            }
+        }
+
+        $this->repository->save($profile);
+    }
+}

tests/Benchmark/WriteEventsWithSyncProjectionistBench.php → tests/Benchmark/SyncProjectionistBench.php

@@ -33,7 +33,7 @@
 use function unlink;
 
 #[Bench\BeforeMethods('setUp')]
-final class WriteEventsWithSyncProjectionistBench
+final class SyncProjectionistBench
 {
     private const DB_PATH = __DIR__ . '/BasicImplementation/data/db.sqlite3';