SmoothPhp / CQRS-ES-Framework-Laravel

src/Console/RebuildProjectionsCommand.php

Spacing +1 added lines, -1 removed lines

@@ -1,4 +1,4 @@
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\Console;
 

src/EventStore/LaravelEventStore.php

Indentation +10 added lines, -10 removed lines

@@ -55,10 +55,10 @@ 
     public function load($id) : DomainEventStream
     {
         $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) {
@@ -153,12 +153,12 @@ 
         $lastId = 0;
         do {
             $rows = $this->db->table($this->db->raw("`{$this->eventStoreTableName}` FORCE INDEX (eventstore_type_index)"))
-                             ->select(['id', 'uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
-                             ->whereIn('type', $eventTypes)
-                             ->where('id', '>', $lastId)
-                             ->take($take)
-                             ->orderBy('id')
-                             ->get();
+                                ->select(['id', 'uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
+                                ->whereIn('type', $eventTypes)
+                                ->where('id', '>', $lastId)
+                                ->take($take)
+                                ->orderBy('id')
+                                ->get();
             $events = [];
             foreach ($rows as $row) {
                 $events[] = $this->deserializeEvent($row);