Add MissingHeader, it will be created in the HeaderSerializer, if the Registry cannot find the header

Author: DanielBadura

src/Message/MissingHeader.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Message;
+
+/**
+ * Represents a header whose name could not be resolved to a registered class
+ */
+final class MissingHeader
+{
+    /** @param array<string, mixed> $payload */
+    public function __construct(
+        public readonly string $name,
+        public readonly array $payload,
+    ) {
+    }
+}

src/Message/Serializer/DefaultHeadersSerializer.php

@@ -4,7 +4,9 @@
 
 namespace Patchlevel\EventSourcing\Message\Serializer;
 
+use Patchlevel\EventSourcing\Message\MissingHeader;
 use Patchlevel\EventSourcing\Metadata\Message\AttributeMessageHeaderRegistryFactory;
+use Patchlevel\EventSourcing\Metadata\Message\HeaderNameNotRegistered;
 use Patchlevel\EventSourcing\Metadata\Message\MessageHeaderRegistry;
 use Patchlevel\EventSourcing\Serializer\Encoder\Encoder;
 use Patchlevel\EventSourcing\Serializer\Encoder\JsonEncoder;
@@ -30,6 +32,12 @@ public function serialize(array $headers, array $options = []): string
     {
         $serializedHeaders = [];
         foreach ($headers as $header) {
+            if ($header instanceof MissingHeader) {
+                $serializedHeaders[$header->name] = $header->payload;
+
+                continue;
+            }
+
             $serializedHeaders[$this->messageHeaderRegistry->headerName($header::class)] = $this->hydrator->extract($header);
         }
 
@@ -51,10 +59,14 @@ public function deserialize(string $string, array $options = []): array
                 throw new InvalidArgument('header payload must be an array');
             }
 
-            $headers[] = $this->hydrator->hydrate(
-                $this->messageHeaderRegistry->headerClass($headerName),
-                $headerPayload,
-            );
+            try {
+                $headers[] = $this->hydrator->hydrate(
+                    $this->messageHeaderRegistry->headerClass($headerName),
+                    $headerPayload,
+                );
+            } catch (HeaderNameNotRegistered) {
+                $headers[] = new MissingHeader($headerName, $headerPayload);
+            }
         }
 
         return $headers;

tests/Unit/Message/Serializer/DefaultHeadersSerializerTest.php

@@ -5,6 +5,7 @@
 namespace Patchlevel\EventSourcing\Tests\Unit\Message\Serializer;
 
 use DateTimeImmutable;
+use Patchlevel\EventSourcing\Message\MissingHeader;
 use Patchlevel\EventSourcing\Message\Serializer\DefaultHeadersSerializer;
 use Patchlevel\EventSourcing\Metadata\Message\AttributeMessageHeaderRegistryFactory;
 use Patchlevel\EventSourcing\Serializer\Encoder\JsonEncoder;
@@ -60,4 +61,46 @@ public function testDeserialize(): void
             $deserializedMessage,
         );
     }
+
+    public function testDeserializeUnknownHeaderAsMissingHeader(): void
+    {
+        $serializer = new DefaultHeadersSerializer(
+            (new AttributeMessageHeaderRegistryFactory())->create([
+                __DIR__ . '/../../Fixture',
+            ]),
+            new MetadataHydrator(),
+            new JsonEncoder(),
+        );
+
+        $deserializedMessage = $serializer->deserialize('{"streamName":{"streamName":"profile-1"},"removed":{"foo":"bar"}}');
+
+        self::assertEquals(
+            [
+                new StreamNameHeader('profile-1'),
+                new MissingHeader('removed', ['foo' => 'bar']),
+            ],
+            $deserializedMessage,
+        );
+    }
+
+    public function testSerializeMissingHeaderRoundTrip(): void
+    {
+        $serializer = new DefaultHeadersSerializer(
+            (new AttributeMessageHeaderRegistryFactory())->create([
+                __DIR__ . '/../../Fixture',
+            ]),
+            new MetadataHydrator(),
+            new JsonEncoder(),
+        );
+
+        $content = $serializer->serialize([
+            new StreamNameHeader('profile-1'),
+            new MissingHeader('removed', ['foo' => 'bar']),
+        ]);
+
+        self::assertEquals(
+            '{"streamName":{"streamName":"profile-1"},"removed":{"foo":"bar"}}',
+            $content,
+        );
+    }
 }