SmoothPhp / CQRS-ES-Framework-Laravel

src/EventStore/LaravelEventStore.php

Indentation +20 added lines, -20 removed lines

@@ -54,10 +54,10 @@ 
     public function load($id)
     {
         $rows = $this->db->table($this->eventStoreTableName)
-                         ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
-                         ->where('uuid', $id)
-                         ->orderBy('playhead', 'asc')
-                         ->get();
+                            ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
+                            ->where('uuid', $id)
+                            ->orderBy('playhead', 'asc')
+                            ->get();
         $events = [];
 
         foreach ($rows as $row) {
@@ -101,16 +101,16 @@ 
     {
         try {
             $this->db->table($this->eventStoreTableName)
-                     ->insert(
-                         [
-                             'uuid'        => (string)$domainMessage->getId(),
-                             'playhead'    => $domainMessage->getPlayHead(),
-                             'metadata'    => json_encode($this->serializer->serialize($domainMessage->getMetadata())),
-                             'payload'     => json_encode($this->serializer->serialize($domainMessage->getPayload())),
-                             'recorded_on' => (string)$domainMessage->getRecordedOn(),
-                             'type'        => $domainMessage->getType(),
-                         ]
-                     );
+                        ->insert(
+                            [
+                                'uuid'        => (string)$domainMessage->getId(),
+                                'playhead'    => $domainMessage->getPlayHead(),
+                                'metadata'    => json_encode($this->serializer->serialize($domainMessage->getMetadata())),
+                                'payload'     => json_encode($this->serializer->serialize($domainMessage->getPayload())),
+                                'recorded_on' => (string)$domainMessage->getRecordedOn(),
+                                'type'        => $domainMessage->getType(),
+                            ]
+                        );
         } catch (\PDOException $ex) {
             if ($ex->getCode() == 23000) {
                 throw new DuplicateAggregatePlayhead((string)$domainMessage->getId(), $domainMessage->getPlayHead());
@@ -154,12 +154,12 @@ 
     public function getEventsByType($eventTypes, $skip, $take)
     {
         $rows = $this->db->table($this->eventStoreTableName)
-                         ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
-                         ->whereIn('type', $eventTypes)
-                         ->skip($skip)
-                         ->take($take)
-                         ->orderBy('recorded_on', 'asc')
-                         ->get();
+                            ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
+                            ->whereIn('type', $eventTypes)
+                            ->skip($skip)
+                            ->take($take)
+                            ->orderBy('recorded_on', 'asc')
+                            ->get();
         $events = [];
 
         foreach ($rows as $row) {

Spacing +4 added lines, -4 removed lines

@@ -77,7 +77,7 @@ 
      */
     public function append($id, DomainEventStream $eventStream)
     {
-        $id = (string)$id; //Used to thrown errors if ID will not cast to string
+        $id = (string) $id; //Used to thrown errors if ID will not cast to string
 
         $this->db->beginTransaction();
 
@@ -103,17 +103,17 @@ 
             $this->db->table($this->eventStoreTableName)
                      ->insert(
                          [
-                             'uuid'        => (string)$domainMessage->getId(),
+                             'uuid'        => (string) $domainMessage->getId(),
                              'playhead'    => $domainMessage->getPlayHead(),
                              'metadata'    => json_encode($this->serializer->serialize($domainMessage->getMetadata())),
                              'payload'     => json_encode($this->serializer->serialize($domainMessage->getPayload())),
-                             'recorded_on' => (string)$domainMessage->getRecordedOn(),
+                             'recorded_on' => (string) $domainMessage->getRecordedOn(),
                              'type'        => $domainMessage->getType(),
                          ]
                      );
         } catch (\PDOException $ex) {
             if ($ex->getCode() == 23000) {
-                throw new DuplicateAggregatePlayhead((string)$domainMessage->getId(), $domainMessage->getPlayHead());
+                throw new DuplicateAggregatePlayhead((string) $domainMessage->getId(), $domainMessage->getPlayHead());
             }
             throw  $ex;
         }