header keys fix to adhere with globals

evdobe · Feb 12, 2022 · 98575b2 · 98575b2
1 parent 820800e
commit 98575b2
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/dev/Infrastructure/Event/Adapter/Pdo/Mapper.php b/dev/Infrastructure/Event/Adapter/Pdo/Mapper.php
@@ -13,8 +13,8 @@ public function map(Message $message, string $channel): array
             ':name' => $message->getHeader('name'),
             ':channel' => $channel,
             ':correlation_id' => $message->getPropery('id'),
-            ':aggregate_id' => $message->getHeader('aggregateId'),
-            ':aggregate_version' => $message->getHeader('aggregateVersion'),
+            ':aggregate_id' => $message->getHeader('aggregate_id'),
+            ':aggregate_version' => $message->getHeader('aggregate_version'),
             ':data' => $message->getBody(),
             ':timestamp' => $message->getPropery('timestamp')
         ];

diff --git a/dev/tests/features/bootstrap/ValidMessageContext.php b/dev/tests/features/bootstrap/ValidMessageContext.php
@@ -89,8 +89,8 @@ public function listenerEncountersAnValidMessage()
             'timestamp' => '2022-01-28 12:23:56'
         ],[
             'name' => 'eventName',
-            'aggregateId' => 23,
-            'aggregateVersion' => 7
+            'aggregate_id' => 23,
+            'aggregate_version' => 7
         ]));
     }
 

diff --git a/dev/tests/unit/Infrastructure/Event/Adapter/Pdo/MapperTest.php b/dev/tests/unit/Infrastructure/Event/Adapter/Pdo/MapperTest.php
@@ -12,8 +12,8 @@ class MapperTest extends TestCase
     protected function enqueueRdkafkaMessage(){
         return (new Message(delegate: new RdKafkaMessage()))
             ->withHeader(name: 'name', value: 'eventName')
-            ->withHeader(name: 'aggregateId', value: 12)
-            ->withHeader(name: 'aggregateVersion', value: 13)
+            ->withHeader(name: 'aggregate_id', value: 12)
+            ->withHeader(name: 'aggregate_version', value: 13)
             ->withProperty(name: 'timestamp', value: '2022-01-27 12:03:23 Z')
             ->withProperty(name: 'id', value: 27)
             ->withBody(body: 'a test body')