DDDominio / event-sourcing

src/EventSourcing/EventStore/AbstractEventStore.php

Doc Comments +1 added lines, -1 removed lines

@@ -115,7 +115,7 @@
     /**
      * @param string $streamId
      * @param DomainEvent[] $events
-     * @return array
+     * @return StoredEvent[]
      */
     private function storedEventsFromEvents($streamId, $events)
     {

Spacing +2 added lines, -2 removed lines

@@ -69,7 +69,7 @@ 
      */
     protected function domainEventStreamFromStoredEvents($storedEvents)
     {
-        $domainEvents = array_map(function (StoredEvent $storedEvent) {
+        $domainEvents = array_map(function(StoredEvent $storedEvent) {
             $this->eventUpgrader->migrate($storedEvent);
             return new DomainEvent(
                 $this->serializer->deserialize(
@@ -119,7 +119,7 @@ 
      */
     private function storedEventsFromEvents($streamId, $events)
     {
-        $storedEvents = array_map(function (DomainEvent $event) use ($streamId) {
+        $storedEvents = array_map(function(DomainEvent $event) use ($streamId) {
             return new StoredEvent(
                 $this->nextStoredEventId(),
                 $streamId,

src/EventSourcing/Common/EventSourcedAggregateRepository.php

Spacing +1 added lines, -1 removed lines

@@ -171,7 +171,7 @@
             }
         }
         if (is_null($aggregateIdMethodName)) {
-            throw new \RuntimeException('No method "id", "getId" or with "@AggregateId" annotation found in '. get_class($aggregate));
+            throw new \RuntimeException('No method "id", "getId" or with "@AggregateId" annotation found in ' . get_class($aggregate));
         }
         return (string) $aggregate->{$aggregateIdMethodName}();
     }

src/EventSourcing/Versioning/Version.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
         if (preg_match($versionPattern, $version, $matches) !== 1) {
             throw new \InvalidArgumentException('Invalid version format.');
         }
-        return new self((int)$matches[1], (int)$matches[2]);
+        return new self((int) $matches[1], (int) $matches[2]);
     }
 
     /**

src/EventSourcing/Versioning/JsonTransformer/JsonTransformer.php

Spacing +3 added lines, -3 removed lines

@@ -39,7 +39,7 @@ 
             } else {
                 if ($currentToken instanceof ArrayAccessToken) {
                     $currentNode = &$currentNode[$currentToken->index()];
-                }  else if ($currentToken instanceof ObjectAccessToken) {
+                } else if ($currentToken instanceof ObjectAccessToken) {
                     $currentNode = &$currentNode->{$currentToken->fieldName()};
                 }
             }
@@ -63,7 +63,7 @@ 
             } else {
                 if ($currentToken instanceof ArrayAccessToken) {
                     $currentNode = &$currentNode[$currentToken->index()];
-                }  else if ($currentToken instanceof ObjectAccessToken) {
+                } else if ($currentToken instanceof ObjectAccessToken) {
                     $currentNode = &$currentNode->{$currentToken->fieldName()};
                 }
             }
@@ -86,7 +86,7 @@ 
             } else {
                 if ($currentToken instanceof ArrayAccessToken) {
                     $currentNode = &$currentNode[$currentToken->index()];
-                }  else if ($currentToken instanceof ObjectAccessToken) {
+                } else if ($currentToken instanceof ObjectAccessToken) {
                     $currentNode = &$currentNode->{$currentToken->fieldName()};
                 }
             }

src/EventSourcing/EventStore/Projection/ProjectionBuilder.php

Spacing +1 added lines, -2 removed lines

@@ -127,8 +127,7 @@
     private function executeStreamEventsQuery()
     {
         return empty($this->from) ?
-            $stream = $this->eventStore->readAllEvents() :
-            $stream = $this->eventStore->readFullStream($this->from);
+            $stream = $this->eventStore->readAllEvents() : $stream = $this->eventStore->readFullStream($this->from);
     }
 
     /**