load the internal header automatically

deptrac.yaml

@@ -128,8 +128,11 @@ deptrac:
       - Attribute
       - Metadata
     MetadataMessage:
+      - Aggregate
       - Attribute
+      - Debug
       - Metadata
+      - Store
     MetadataSubscriber:
       - Attribute
       - Metadata

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 */

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 */

src/Message/Serializer/DefaultHeadersSerializer.php

@@ -60,4 +60,13 @@ public static function createFromPaths(array $paths): static
             new JsonEncoder(),
         );
     }
+
+    public static function createDefault(): static
+    {
+        return new self(
+            MessageHeaderRegistry::createWithInternalHeaders(),
+            new MetadataHydrator(),
+            new JsonEncoder(),
+        );
+    }
 }

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);
     }
 }

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);
+    }
 }

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(

src/Store/DoctrineDbalStore.php

@@ -15,6 +15,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;
@@ -40,12 +41,15 @@ final class DoctrineDbalStore implements Store, ArchivableStore, SubscriptionSto
      */
     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(

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(

tests/Benchmark/SimpleSetupBench.php

@@ -5,7 +5,6 @@
 namespace Patchlevel\EventSourcing\Tests\Benchmark;
 
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
@@ -32,11 +31,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../src',
-                __DIR__ . '/BasicImplementation/Events',
-            ]),
-            'eventstore',
         );
 
         $this->repository = new DefaultRepository($this->store, Profile::metadata());

tests/Benchmark/SnapshotsBench.php

@@ -5,7 +5,6 @@
 namespace Patchlevel\EventSourcing\Tests\Benchmark;
 
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
@@ -38,11 +37,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../src',
-                __DIR__ . '/BasicImplementation/Events',
-            ]),
-            'eventstore',
         );
 
         $this->adapter = new InMemorySnapshotAdapter();

tests/Benchmark/SplitStreamBench.php

@@ -5,7 +5,6 @@
 namespace Patchlevel\EventSourcing\Tests\Benchmark;
 
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\MessageDecorator\SplitStreamDecorator;
@@ -36,11 +35,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../src',
-                __DIR__ . '/BasicImplementation/Events',
-            ]),
-            'eventstore',
         );
 
         $this->repository = new DefaultRepository(

tests/Benchmark/SubscriptionEngineBench.php

@@ -5,7 +5,6 @@
 namespace Patchlevel\EventSourcing\Tests\Benchmark;
 
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\ChainDoctrineSchemaConfigurator;
@@ -41,13 +40,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            DefaultHeadersSerializer::createFromPaths(
-                [
-                    __DIR__ . '/BasicImplementation/Events',
-                    __DIR__ . '/../../src',
-                ],
-            ),
-            'eventstore',
         );
 
         $this->repository = new DefaultRepository($this->store, Profile::metadata());

tests/Integration/BankAccountSplitStream/IntegrationTest.php

@@ -5,7 +5,6 @@
 namespace Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream;
 
 use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepositoryManager;
@@ -47,11 +46,6 @@ public function testSuccessful(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
-            'eventstore',
         );
 
         $bankAccountProjector = new BankAccountProjector($this->connection);

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',
         );

tests/Integration/Pipeline/PipelineChangeStoreTest.php

@@ -5,7 +5,6 @@
 namespace Patchlevel\EventSourcing\Tests\Integration\Pipeline;
 
 use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeEventMiddleware;
 use Patchlevel\EventSourcing\Pipeline\Middleware\RecalculatePlayheadMiddleware;
 use Patchlevel\EventSourcing\Pipeline\Middleware\ReplaceEventMiddleware;
@@ -44,16 +43,10 @@ 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,
-            'eventstore',
         );
 
         $oldSchemaDirector = new DoctrineSchemaDirector(
@@ -66,8 +59,6 @@ public function testSuccessful(): void
         $newStore = new DoctrineDbalStore(
             $this->connectionNew,
             $eventSerializer,
-            $headersSerializer,
-            'eventstore',
         );
 
         $newSchemaDirector = new DoctrineSchemaDirector(

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',
         );
 

tests/Integration/Subscription/SubscriptionTest.php

@@ -12,7 +12,6 @@
 use Patchlevel\EventSourcing\Debug\Trace\TraceHeader;
 use Patchlevel\EventSourcing\Debug\Trace\TraceStack;
 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;
@@ -63,10 +62,7 @@ public function testHappyPath(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -183,10 +179,7 @@ public function testErrorHandling(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -315,10 +308,7 @@ public function testProcessor(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -430,10 +420,7 @@ public function testBlueGreenDeployment(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 
@@ -591,10 +578,7 @@ public function testBlueGreenDeploymentRollback(): void
         $store = new DoctrineDbalStore(
             $this->connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
-            DefaultHeadersSerializer::createFromPaths([
-                __DIR__ . '/../../../src',
-                __DIR__,
-            ]),
+            null,
             'eventstore',
         );
 

tests/Unit/Message/Serializer/HeadersSerializerTest.php

@@ -22,8 +22,7 @@ final class HeadersSerializerTest extends TestCase
     public function testSerialize(): void
     {
         $serializer = DefaultHeadersSerializer::createFromPaths([
-            __DIR__ . '/../../../../src', // add our headers
-            __DIR__ . '/../../Fixture', // add user headers
+            __DIR__ . '/../../Fixture',
         ]);
 
         $content = $serializer->serialize([
@@ -44,8 +43,7 @@ public function testDeserialize(): void
     {
         $serializer = new DefaultHeadersSerializer(
             (new AttributeMessageHeaderRegistryFactory())->create([
-                __DIR__ . '/../../../../src', // add our headers
-                __DIR__ . '/../../Fixture', // add user headers
+                __DIR__ . '/../../Fixture',
             ]),
             new MetadataHydrator(),
             new JsonEncoder(),