EventSaucePHP / EventSauce

src/TestUtilities/MessageConsumerTestCase.php

Spacing +1 added lines, -1 removed lines

@@ -103,7 +103,7 @@
      */
     private function ensureEventsAreMessages(array $events): array
     {
-        return array_map(function (object $event) {
+        return array_map(function(object $event) {
             return $event instanceof Message ? $event : new Message($event);
         }, $events);
     }

src/InMemoryMessageRepository.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
         $lastMessage = null;
 
         foreach ($this->messages as $message) {
-            if ($id->toString() === $message->aggregateRootId()?->toString()) {
+            if ($id->toString() === $message->aggregateRootId() ? ->toString()) {
                 yield $message;
                 $lastMessage = $message;
             }
@@ -61,7 +61,7 @@ 
         $lastMessage = null;
 
         foreach ($this->messages as $message) {
-            if ($id->toString() === $message->aggregateRootId()?->toString()
+            if ($id->toString() === $message->aggregateRootId() ? ->toString()
                 && $message->header(Header::AGGREGATE_ROOT_VERSION) > $aggregateRootVersion) {
                 yield $message;
                 $lastMessage = $message;

src/Message.php

Spacing +2 added lines, -2 removed lines

@@ -17,7 +17,7 @@ 
     {
     }
 
-    public function withHeader(string $key, int|string|null|AggregateRootId $value): Message
+    public function withHeader(string $key, int | string | null | AggregateRootId $value): Message
     {
         $clone = clone $this;
         $clone->headers[$key] = $value;
@@ -71,7 +71,7 @@ 
         return $timeOfRecording;
     }
 
-    public function header(string $key): int|string|array|AggregateRootId|null
+    public function header(string $key): int | string | array | AggregateRootId | null
     {
         return $this->headers[$key] ?? null;
     }

src/AggregateRootWithAggregates.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
     protected function eventRecorder(): EventRecorder
     {
         if (null === $this->eventRecorder) {
-            $this->eventRecorder = new EventRecorder(fn (object $event) => $this->recordThat($event));
+            $this->eventRecorder = new EventRecorder(fn(object $event) => $this->recordThat($event));
         }
 
         return $this->eventRecorder;

src/DecoratingMessageDispatcher.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
     public function dispatch(Message ...$messages): void
     {
         $this->dispatcher->dispatch(
-            ...array_map(fn (Message $message) => $this->decorator->decorate($message), $messages)
+            ...array_map(fn(Message $message) => $this->decorator->decorate($message), $messages)
         );
     }
 }

src/EventSourcedAggregateRootRepository.php

Spacing +1 added lines, -1 removed lines

@@ -80,7 +80,7 @@
         // of recording.
         $aggregateRootVersion = $aggregateRootVersion - count($events);
         $metadata = [Header::AGGREGATE_ROOT_ID => $aggregateRootId];
-        $messages = array_map(fn (object $event) => $this->decorator->decorate(new Message(
+        $messages = array_map(fn(object $event) => $this->decorator->decorate(new Message(
             $event,
             $metadata + [Header::AGGREGATE_ROOT_VERSION => ++$aggregateRootVersion]
         )), $events);