Use StreamStore and message loader, fix cs

Author: DanielBadura

tests/Benchmark/CommandToQueryBench.php

@@ -19,6 +19,7 @@
 use Patchlevel\EventSourcing\Snapshot\DefaultSnapshotStore;
 use Patchlevel\EventSourcing\Store\StreamDoctrineDbalStore;
 use Patchlevel\EventSourcing\Subscription\Engine\DefaultSubscriptionEngine;
+use Patchlevel\EventSourcing\Subscription\Engine\StoreMessageLoader;
 use Patchlevel\EventSourcing\Subscription\Repository\RunSubscriptionEngineRepositoryManager;
 use Patchlevel\EventSourcing\Subscription\Store\InMemorySubscriptionStore;
 use Patchlevel\EventSourcing\Subscription\Subscriber\MetadataSubscriberAccessorRepository;
@@ -64,7 +65,7 @@ public function setUp(): void
         $profileProjection = new ProfileProjector($projectionConnection);
 
         $engine = new DefaultSubscriptionEngine(
-            $store,
+            new StoreMessageLoader($store),
             new InMemorySubscriptionStore(),
             new MetadataSubscriberAccessorRepository([
                 $profileProjection,

tests/Integration/BasicImplementation/BasicIntegrationTest.php

@@ -329,7 +329,7 @@ public function testCommandBus(): void
 
     public function testQueryBus(): void
     {
-        $store = new DoctrineDbalStore(
+        $store = new StreamDoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
             DefaultHeadersSerializer::createFromPaths([
@@ -350,7 +350,7 @@ public function testQueryBus(): void
         $profileProjection = new ProfileProjector($this->connection);
 
         $engine = new DefaultSubscriptionEngine(
-            $store,
+            new StoreMessageLoader($store),
             new InMemorySubscriptionStore(),
             new MetadataSubscriberAccessorRepository([
                 $profileProjection,

tests/Integration/BasicImplementation/Projection/ProfileProjector.php

@@ -13,7 +13,6 @@
 use Patchlevel\EventSourcing\Attribute\Teardown;
 use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Events\NameChanged;
 use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Events\ProfileCreated;
-use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\ProfileId;
 use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Query\QueryProfileName;
 
 #[Projector('profile-1')]