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

@@ -68,7 +68,7 @@ 
      */
     protected function domainEventStreamFromStoredEvents($eventStream)
     {
-        return $eventStream->map(function (StoredEvent $storedEvent) {
+        return $eventStream->map(function(StoredEvent $storedEvent) {
             $this->eventUpgrader->migrate($storedEvent);
             return new DomainEvent(
                 $this->serializer->deserialize($storedEvent->data(), $storedEvent->type()),
@@ -114,7 +114,7 @@ 
      */
     private function storedEventsFromEvents($streamId, $events)
     {
-        return array_map(function (DomainEvent $event) use ($streamId) {
+        return array_map(function(DomainEvent $event) use ($streamId) {
             return new StoredEvent(
                 $this->nextStoredEventId(),
                 $streamId,

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

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

src/EventSourcing/EventStore/Vendor/MySqlJsonEventStore.php

Spacing +3 added lines, -3 removed lines

@@ -229,14 +229,14 @@ 
             $this->connection->beginTransaction();
 
             $this->connection->exec(
-                'CREATE TABLE `'.self::STREAMS_TABLE.'` (
+                'CREATE TABLE `' . self::STREAMS_TABLE . '` (
                     `id` varchar(255) NOT NULL,
                     PRIMARY KEY (`id`)
                 )'
             );
 
             $this->connection->exec(
-                'CREATE TABLE `'.self::EVENTS_TABLE.'` (
+                'CREATE TABLE `' . self::EVENTS_TABLE . '` (
                     `id` int(11) NOT NULL AUTO_INCREMENT,
                     `stream_id` varchar(255) NOT NULL,
                     `type` varchar(255) NOT NULL,
@@ -263,7 +263,7 @@ 
     public function initialized()
     {
         try {
-            $result = $this->connection->query('SELECT 1 FROM `'.self::STREAMS_TABLE.'` LIMIT 1');
+            $result = $this->connection->query('SELECT 1 FROM `' . self::STREAMS_TABLE . '` LIMIT 1');
         } catch (\Exception $e) {
             return false;
         }

src/EventSourcing/Snapshotting/Vendor/MySqlJsonSnapshotStore.php

Spacing +2 added lines, -2 removed lines

@@ -85,7 +85,7 @@ 
     public function initialize()
     {
         $this->connection->exec(
-            'CREATE TABLE `'.self::SNAPSHOTS_TABLE.'` (
+            'CREATE TABLE `' . self::SNAPSHOTS_TABLE . '` (
                 `id` int(11) NOT NULL AUTO_INCREMENT,
                 `aggregate_type` varchar(255) NOT NULL,
                 `aggregate_id` varchar(255) NOT NULL,
@@ -103,7 +103,7 @@ 
     public function initialized()
     {
         try {
-            $result = $this->connection->query('SELECT 1 FROM `'.self::SNAPSHOTS_TABLE.'` LIMIT 1');
+            $result = $this->connection->query('SELECT 1 FROM `' . self::SNAPSHOTS_TABLE . '` LIMIT 1');
         } catch (\Exception $e) {
             return false;
         }