SmoothPhp / CQRS-ES-Framework-Laravel

src/EventStore/LaravelEventStore.php

Indentation +12 added lines, -12 removed lines

@@ -55,10 +55,10 @@ 
     public function load(string $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) {
@@ -152,12 +152,12 @@ 
             $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);
@@ -190,7 +190,7 @@ 
     public function deleteStream(string $streamId) : void
     {
         $this->db->table($this->eventStoreTableName)
-                 ->where('uuid', $streamId)
-                 ->delete();
+                    ->where('uuid', $streamId)
+                    ->delete();
     }
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -107,7 +107,7 @@ 
         try {
             $this->db->table($this->eventStoreTableName)->insert($eventRow);
         } catch (\PDOException $ex) {
-            if ((string)$ex->getCode() === '23000') {
+            if ((string) $ex->getCode() === '23000') {
                 throw new DuplicateAggregatePlayhead($eventRow['uuid'], $eventRow['playhead'], $ex);
             }
             throw $ex;
@@ -175,7 +175,7 @@ 
     private function domainMessageToArray(DomainMessage $domainMessage) : array
     {
         return [
-            '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())),

src/Console/RunProjectionCommand.php

Spacing +13 added lines, -13 removed lines

@@ -76,7 +76,7 @@ 
         $projectionRequest = collect(explode(',', $this->argument('projections')));
 
         $projectionsServiceProviders = $projectionRequest->each(
-            function ($projectionName) {
+            function($projectionName) {
                 if (!isset($this->config->get('cqrses.projections_service_providers')[$projectionName])) {
                     $this->error("{$projectionName} Does not exist, check cqrses config");
 
@@ -84,26 +84,26 @@ 
                 }
             }
         )->map(
-            function ($projectionName) {
+            function($projectionName) {
                 return $this->application->make(
                     $this->config->get('cqrses.projections_service_providers')[$projectionName]
                 );
             }
         )->each(
-            function (ProjectionServiceProvider $projectionClass) {
+            function(ProjectionServiceProvider $projectionClass) {
                 $this->downMigration($projectionClass);
             }
         )->each(
-            function (ProjectionServiceProvider $projectionClass) {
+            function(ProjectionServiceProvider $projectionClass) {
                 $this->upMigration($projectionClass);
             }
         );
 
         /** @var Collection|Subscriber[] $projections */
         $projections = $projectionsServiceProviders->map(
-            function (ProjectionServiceProvider $projectServiceProvider) {
+            function(ProjectionServiceProvider $projectServiceProvider) {
                 return collect($projectServiceProvider->getProjections())->map(
-                    function ($projection) {
+                    function($projection) {
                         return $this->application->make($projection);
                     }
                 );
@@ -111,11 +111,11 @@ 
         )->collapse();
 
         $events = $projections->map(
-            function (Subscriber $subscriber) {
+            function(Subscriber $subscriber) {
                 return array_keys($subscriber->getSubscribedEvents());
             }
         )->collapse()->map(
-            function ($eventClassName) {
+            function($eventClassName) {
                 return str_replace('\\', '.', $eventClassName);
             }
         );
@@ -129,7 +129,7 @@ 
     public function downMigration(ProjectionServiceProvider $projectionServiceProvider)
     {
         $response = $projectionServiceProvider->down();
-        $this->line($response ?? 'Migrated Down: ' . \get_class($projectionServiceProvider));
+        $this->line($response ?? 'Migrated Down: '.\get_class($projectionServiceProvider));
     }
 
     /**
@@ -138,7 +138,7 @@ 
     public function upMigration(ProjectionServiceProvider $projectionServiceProvider)
     {
         $response = $projectionServiceProvider->up();
-        $this->line($response ?? 'Migrated Up: ' . \get_class($projectionServiceProvider));
+        $this->line($response ?? 'Migrated Up: '.\get_class($projectionServiceProvider));
     }
 
     /**
@@ -150,7 +150,7 @@ 
     protected function replayEvents($projections, $events)
     {
         $eventCount = $this->eventStore->getEventCountByTypes($events);
-        $take = (int)$this->config->get('cqrses.rebuild_transaction_size', 1000);
+        $take = (int) $this->config->get('cqrses.rebuild_transaction_size', 1000);
 
         $this->output->progressStart($eventCount);
         $dispatcher = $this->buildAndRegisterDispatcher($projections);
@@ -170,7 +170,7 @@ 
         }
 
         $this->output->progressFinish();
-        $this->line((memory_get_peak_usage(true) / 1024 / 1024) . "mb Peak Usage", false);
+        $this->line((memory_get_peak_usage(true) / 1024 / 1024)."mb Peak Usage", false);
     }
 
     /**
@@ -203,7 +203,7 @@ 
         );
 
         $projections->each(
-            function ($projection) use ($dispatcher) {
+            function($projection) use ($dispatcher) {
                 $dispatcher->addSubscriber($projection);
             }
         );