SmoothPhp / CQRS-ES-Framework-Laravel

src/EventStore/LaravelEventStore.php

Doc Comments -1 removed lines

@@ -101,7 +101,6 @@
 
     /**
      * @param array $eventRow
-     * @param bool $ignorePlayhead
      * @throws DuplicateAggregatePlayhead
      * @throws \PDOException
      */

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->eventStoreTableName)
-                             ->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);

Spacing +4 added lines, -4 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\EventStore;
 
@@ -81,7 +81,7 @@ 
      */
     public function append($id, DomainEventStream $eventStream) : void
     {
-        $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->reconnect();
         $this->db->beginTransaction();
@@ -110,7 +110,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;
@@ -176,7 +176,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/CommandBus/LaravelCommandBus.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\CommandBus;
 

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

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;

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/PushEventThroughQueueWithCommandId.php

Spacing +3 added lines, -3 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace SmoothPhp\LaravelAdapter\StrongConsistency;
 
@@ -55,11 +55,11 @@ 
         $this->queue->push(
             QueueToEventDispatcherWithCommandId::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())),
-                'recorded_on' => (string)$domainMessage->getRecordedOn(),
+                'recorded_on' => (string) $domainMessage->getRecordedOn(),
                 'type'        => $domainMessage->getType(),
                 'command_id'  => $this->notificationsCommandBus->getLastCommandId(),
             ],

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();