SmoothPhp / CQRS-ES-Framework-Laravel

src/StrongConsistency/StrongConsistencyCommandBusMiddleware.php

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\StrongConsistency;
 
@@ -23,7 +23,7 @@ 
      */
     public function execute(Command $command, callable $next)
     {
-        $this->lastCommandId = (string)$command;
+        $this->lastCommandId = (string) $command;
         $next($command);
     }
 

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

src/Console/BuildLaravelEventStore.php

Indentation +14 added lines, -14 removed lines

@@ -71,20 +71,20 @@
     protected function buildEventStoreTable()
     {
         Schema::connection($this->config->get('cqrses.eventstore_connection'))
-              ->create(
-                  $this->config->get('cqrses.eventstore_table'),
-                  function (Blueprint $table) {
-                      $table->increments('id');
-                      $table->string('uuid', 56);
-                      $table->integer('playhead')->unsigned();
-                      $table->text('metadata');
-                      $table->longText('payload');
-                      $table->timestamp('recorded_on')->nullable()->index();
-                      $table->string('type', 255)->index();
-                      $table->unique(['uuid', 'playhead']);
+                ->create(
+                    $this->config->get('cqrses.eventstore_table'),
+                    function (Blueprint $table) {
+                        $table->increments('id');
+                        $table->string('uuid', 56);
+                        $table->integer('playhead')->unsigned();
+                        $table->text('metadata');
+                        $table->longText('payload');
+                        $table->timestamp('recorded_on')->nullable()->index();
+                        $table->string('type', 255)->index();
+                        $table->unique(['uuid', 'playhead']);
 
-                      $table->index(['id', 'type']);
-                  }
-              );
+                        $table->index(['id', 'type']);
+                    }
+                );
     }
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\Console;
 
@@ -73,7 +73,7 @@ 
         Schema::connection($this->config->get('cqrses.eventstore_connection'))
               ->create(
                   $this->config->get('cqrses.eventstore_table'),
-                  function (Blueprint $table) {
+                  function(Blueprint $table) {
                       $table->increments('id');
                       $table->string('uuid', 56);
                       $table->integer('playhead')->unsigned();

src/Console/ExportEventStore.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/Console/RunProjectionCommand.php

Spacing +12 added lines, -12 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\Console;
 
@@ -75,7 +75,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");
 
@@ -83,26 +83,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);
                     }
                 );
@@ -110,11 +110,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);
             }
         );
@@ -145,7 +145,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);
@@ -161,7 +161,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);
     }
 
     /**
@@ -194,7 +194,7 @@ 
         );
 
         $projections->each(
-            function ($projection) use ($dispatcher) {
+            function($projection) use ($dispatcher) {
                 $dispatcher->addSubscriber($projection);
             }
         );

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/Console/ImportEventStore.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/EventBus/PushEventsThroughQueue.php

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\EventBus;
 
@@ -45,7 +45,7 @@ 
         $this->queue->push(
             QueueToEventDispatcher::class,
             [
-                '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/EventBus/EventBusLogger.php

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\EventBus;
 
@@ -34,6 +34,6 @@ 
         $name = explode('.', $domainMessage->getType());
 
         $name = preg_replace('/(?!^)[A-Z]{2,}(?=[A-Z][a-z])|[A-Z][a-z]/', ' $0', end($name));
-        $this->log->debug(trim(ucwords($name)) . " ({$domainMessage->getType()})");
+        $this->log->debug(trim(ucwords($name))." ({$domainMessage->getType()})");
     }
 }
\ No newline at end of file