load the internal header automatically

patchlevel · Mar 14, 2024 · 8b7d8ee · 8b7d8ee
1 parent 05c96b0
commit 8b7d8ee
Show file tree

Hide file tree

Showing 19 changed files with 51 additions and 84 deletions.
diff --git a/docs/pages/getting_started.md b/docs/pages/getting_started.md
@@ -297,12 +297,10 @@ $projectionConnection = DriverManager::getConnection([
 $mailer = /* your own mailer */;
 
 $serializer = DefaultEventSerializer::createFromPaths(['src/Domain/Hotel/Event']);
-$aggregateRegistry = (new AttributeAggregateRootRegistryFactory)->create(['src/Domain/Hotel']);
 
 $eventStore = new DoctrineDbalStore(
     $connection,
     $serializer,
-    $aggregateRegistry,
 );
 
 $hotelProjector = new HotelProjector($projectionConnection);

diff --git a/src/Aggregate/AggregateHeader.php b/src/Aggregate/AggregateHeader.php
@@ -5,11 +5,9 @@
 namespace Patchlevel\EventSourcing\Aggregate;
 
 use DateTimeImmutable;
-use Patchlevel\EventSourcing\Attribute\Header;
 use Patchlevel\Hydrator\Normalizer\DateTimeImmutableNormalizer;
 
 /** @psalm-immutable */
-#[Header('aggregate')]
 final class AggregateHeader
 {
     /** @param positive-int $playhead */

diff --git a/src/Debug/Trace/TraceHeader.php b/src/Debug/Trace/TraceHeader.php
@@ -4,10 +4,7 @@
 
 namespace Patchlevel\EventSourcing\Debug\Trace;
 
-use Patchlevel\EventSourcing\Attribute\Header;
-
 /** @experimental */
-#[Header('trace')]
 final class TraceHeader
 {
     /** @param list<array{name: string, category: string}> $traces */

diff --git a/src/Message/Serializer/DefaultHeadersSerializer.php b/src/Message/Serializer/DefaultHeadersSerializer.php
@@ -52,12 +52,21 @@ public function deserialize(array $serializedHeaders): array
     }
 
     /** @param list<string> $paths */
-    public static function createFromPaths(array $paths): static
+    public static function createFromPaths(array $paths = []): static
     {
         return new self(
             (new AttributeMessageHeaderRegistryFactory())->create($paths),
             new MetadataHydrator(),
             new JsonEncoder(),
         );
     }
+
+    public static function createDefault(): static
+    {
+        return new self(
+            MessageHeaderRegistry::createWithInternalHeaders(),
+            new MetadataHydrator(),
+            new JsonEncoder(),
+        );
+    }
 }
diff --git a/src/Metadata/Message/AttributeMessageHeaderRegistryFactory.php b/src/Metadata/Message/AttributeMessageHeaderRegistryFactory.php
@@ -31,6 +31,6 @@ public function create(array $paths): MessageHeaderRegistry
             $result[$aggregateName] = $class;
         }
 
-        return new MessageHeaderRegistry($result);
+        return MessageHeaderRegistry::createWithInternalHeaders($result);
     }
 }
diff --git a/src/Metadata/Message/MessageHeaderRegistry.php b/src/Metadata/Message/MessageHeaderRegistry.php
@@ -4,6 +4,11 @@
 
 namespace Patchlevel\EventSourcing\Metadata\Message;
 
+use Patchlevel\EventSourcing\Aggregate\AggregateHeader;
+use Patchlevel\EventSourcing\Debug\Trace\TraceHeader;
+use Patchlevel\EventSourcing\Store\ArchivedHeader;
+use Patchlevel\EventSourcing\Store\NewStreamStartHeader;
+
 use function array_flip;
 use function array_key_exists;
 
@@ -63,4 +68,17 @@ public function headerNames(): array
     {
         return $this->classToNameMap;
     }
+
+    /** @param array<string, class-string> $headerNameToClassMap */
+    public static function createWithInternalHeaders(array $headerNameToClassMap = []): self
+    {
+        $internalHeaders = [
+            'aggregate' => AggregateHeader::class,
+            'trace' => TraceHeader::class,
+            'archived' => ArchivedHeader::class,
+            'newStreamStart' => NewStreamStartHeader::class,
+        ];
+
+        return new self($headerNameToClassMap + $internalHeaders);
+    }
 }
diff --git a/src/Store/ArchivedHeader.php b/src/Store/ArchivedHeader.php
@@ -4,10 +4,7 @@
 
 namespace Patchlevel\EventSourcing\Store;
 
-use Patchlevel\EventSourcing\Attribute\Header;
-
 /** @psalm-immutable */
-#[Header('archived')]
 final class ArchivedHeader
 {
     public function __construct(

diff --git a/src/Store/DoctrineDbalStore.php b/src/Store/DoctrineDbalStore.php
@@ -14,6 +14,7 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateHeader;
 use Patchlevel\EventSourcing\Message\HeaderNotFound;
 use Patchlevel\EventSourcing\Message\Message;
+use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Message\Serializer\HeadersSerializer;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaConfigurator;
 use Patchlevel\EventSourcing\Serializer\EventSerializer;
@@ -36,12 +37,15 @@ final class DoctrineDbalStore implements Store, ArchivableStore, DoctrineSchemaC
      */
     private const MAX_UNSIGNED_SMALL_INT = 65_535;
 
+    private readonly HeadersSerializer $headersSerializer;
+
     public function __construct(
         private readonly Connection $connection,
         private readonly EventSerializer $eventSerializer,
-        private readonly HeadersSerializer $headersSerializer,
+        HeadersSerializer|null $headersSerializer = null,
         private readonly string $storeTableName = 'eventstore',
     ) {
+        $this->headersSerializer = $headersSerializer ?? DefaultHeadersSerializer::createDefault();
     }
 
     public function load(

diff --git a/src/Store/NewStreamStartHeader.php b/src/Store/NewStreamStartHeader.php
@@ -4,10 +4,7 @@
 
 namespace Patchlevel\EventSourcing\Store;
 
-use Patchlevel\EventSourcing\Attribute\Header;
-
 /** @psalm-immutable */
-#[Header('newStreamStart')]
 final class NewStreamStartHeader
 {
     public function __construct(

diff --git a/tests/Benchmark/SimpleSetupBench.php b/tests/Benchmark/SimpleSetupBench.php
@@ -7,7 +7,6 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
@@ -37,10 +36,7 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../src',
-                __DIR__ . '/BasicImplementation/Events',
-            ]),
+            null,
             'eventstore',
         );
 

diff --git a/tests/Benchmark/SnapshotsBench.php b/tests/Benchmark/SnapshotsBench.php
@@ -7,7 +7,6 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
@@ -43,10 +42,7 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../src',
-                __DIR__ . '/BasicImplementation/Events',
-            ]),
+            null,
             'eventstore',
         );
 

diff --git a/tests/Benchmark/SplitStreamBench.php b/tests/Benchmark/SplitStreamBench.php
@@ -7,7 +7,6 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\MessageDecorator\SplitStreamDecorator;
@@ -41,10 +40,7 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../src',
-                __DIR__ . '/BasicImplementation/Events',
-            ]),
+            null,
             'eventstore',
         );
 

diff --git a/tests/Benchmark/SubscriptionEngineBench.php b/tests/Benchmark/SubscriptionEngineBench.php
@@ -7,7 +7,6 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\ChainDoctrineSchemaConfigurator;
@@ -46,12 +45,7 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths(
-                [
-                    __DIR__ . '/BasicImplementation/Events',
-                    __DIR__ . '/../../src',
-                ],
-            ),
+            null,
             'eventstore',
         );
 

diff --git a/tests/Integration/BankAccountSplitStream/IntegrationTest.php b/tests/Integration/BankAccountSplitStream/IntegrationTest.php
@@ -6,7 +6,6 @@
 
 use Doctrine\DBAL\Connection;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepositoryManager;
@@ -48,10 +47,7 @@ public function testSuccessful(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 

diff --git a/tests/Integration/BasicImplementation/BasicIntegrationTest.php b/tests/Integration/BasicImplementation/BasicIntegrationTest.php
@@ -46,8 +46,7 @@ public function testSuccessful(): void
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
             DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
+                __DIR__ . '/Header',
             ]),
             'eventstore',
         );
@@ -115,8 +114,7 @@ public function testSnapshot(): void
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
             DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
+                __DIR__ . '/Header',
             ]),
             'eventstore',
         );

diff --git a/tests/Integration/Pipeline/PipelineChangeStoreTest.php b/tests/Integration/Pipeline/PipelineChangeStoreTest.php
@@ -6,7 +6,6 @@
 
 use Doctrine\DBAL\Connection;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeEventMiddleware;
 use Patchlevel\EventSourcing\Pipeline\Middleware\RecalculatePlayheadMiddleware;
 use Patchlevel\EventSourcing\Pipeline\Middleware\ReplaceEventMiddleware;
@@ -45,15 +44,11 @@ public function tearDown(): void
     public function testSuccessful(): void
     {
         $eventSerializer = DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']);
-        $headersSerializer = DefaultHeadersSerializer::createFromPaths([
-            __DIR__ . '/../../../src',
-            __DIR__,
-        ]);
 
         $oldStore = new DoctrineDbalStore(
             $this->connectionOld,
             $eventSerializer,
-            $headersSerializer,
+            null,
             'eventstore',
         );
 
@@ -67,7 +62,7 @@ public function testSuccessful(): void
         $newStore = new DoctrineDbalStore(
             $this->connectionNew,
             $eventSerializer,
-            $headersSerializer,
+            null,
             'eventstore',
         );
 

diff --git a/tests/Integration/Store/StoreTest.php b/tests/Integration/Store/StoreTest.php
@@ -8,7 +8,6 @@
 use Doctrine\DBAL\Connection;
 use Patchlevel\EventSourcing\Aggregate\AggregateHeader;
 use Patchlevel\EventSourcing\Message\Message;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
 use Patchlevel\EventSourcing\Serializer\DefaultEventSerializer;
 use Patchlevel\EventSourcing\Store\DoctrineDbalStore;
@@ -32,10 +31,7 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 

diff --git a/tests/Integration/Subscription/SubscriptionTest.php b/tests/Integration/Subscription/SubscriptionTest.php
@@ -13,7 +13,6 @@
 use Patchlevel\EventSourcing\Debug\Trace\TraceStack;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\Message\Message;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Repository\DefaultRepositoryManager;
 use Patchlevel\EventSourcing\Schema\ChainDoctrineSchemaConfigurator;
@@ -64,10 +63,7 @@ public function testHappyPath(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -185,10 +181,7 @@ public function testErrorHandling(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -318,10 +311,7 @@ public function testProcessor(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -433,10 +423,7 @@ public function testBlueGreenDeployment(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -595,10 +582,7 @@ public function testBlueGreenDeploymentRollback(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );