SmoothPhp / CQRS-ES-Framework-Laravel

src/EventStore/LaravelEventStore.php

Unused Use Statements -1 removed lines

@@ -6,7 +6,6 @@
 use Illuminate\Database\QueryException;
 use SmoothPhp\Contracts\Domain\DomainEventStream;
 use SmoothPhp\Contracts\Domain\DomainMessage;
-use SmoothPhp\Contracts\EventStore\DomainEventStreamInterface;
 use SmoothPhp\Contracts\EventStore\EventStore;
 use SmoothPhp\Contracts\Serialization\Serializer;
 use SmoothPhp\Domain\DateTime;

Indentation +11 added lines, -11 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) {
@@ -154,13 +154,13 @@ 
     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')
-                         ->orderBy('playhead', 'asc')
-                         ->get();
+                            ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on'])
+                            ->whereIn('type', $eventTypes)
+                            ->skip($skip)
+                            ->take($take)
+                            ->orderBy('recorded_on', 'asc')
+                            ->orderBy('playhead', 'asc')
+                            ->get();
         $events = [];
 
         foreach ($rows as $row) {

src/Console/RunProjectionCommand.php

Spacing +11 added lines, -11 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare (strict_types=1);
+<?php declare (strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\Console;
 
@@ -68,7 +68,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");
 
@@ -76,26 +76,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);
                     }
                 );
@@ -103,11 +103,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);
             }
         );
@@ -154,7 +154,7 @@ 
             $this->output->progressAdvance($take > $eventCount ? $eventCount : $take);
         }
         $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);
     }
 
     /**
@@ -187,7 +187,7 @@ 
         );
 
         $projections->each(
-            function ($projection) use ($dispatcher) {
+            function($projection) use ($dispatcher) {
                 $dispatcher->addSubscriber($projection);
             }
         );

src/QueuedEventDispatcher/QueuedEventHandler.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\QueuedEventDispatcher;
 

src/QueuedEventDispatcher/QueuedEventDispatcher.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\QueuedEventDispatcher;
 

tests/EventDispatcher/Helpers/TestHandler.php

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare (strict_types=1);
+<?php declare (strict_types = 1);
 
 namespace Tests\EventDispatcher\Helpers;
 
@@ -28,6 +28,6 @@ 
      */
     public function getSubscribedEvents()
     {
-        return [TestEvent::class => ['whenTestEvent'],];
+        return [TestEvent::class => ['whenTestEvent'], ];
     }
 }

tests/EventDispatcher/Helpers/TestEvent.php

Spacing +1 added lines, -1 removed lines

@@ -1,4 +1,4 @@
-<?php declare (strict_types=1);
+<?php declare (strict_types = 1);
 
 namespace Tests\EventDispatcher\Helpers;
 

tests/EventDispatcher/PushEventThoughDispatcherQueueTest.php

Indentation +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
     public function test_pushing_event_to_queue()
     {
         $container = new Container();
-       // $container->bind(\Illuminate\Contracts\Container\Container::class, $container);
+        // $container->bind(\Illuminate\Contracts\Container\Container::class, $container);
         $queue = new Queue($container);
 
 

Spacing +1 added lines, -1 removed lines

@@ -1,4 +1,4 @@
-<?php declare (strict_types=1);
+<?php declare (strict_types = 1);
 
 namespace Tests\EventDispatcher;