SmoothPhp / CQRS-ES-Framework-Laravel

src/EventStore/LaravelEventStore.php

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

Spacing +3 added lines, -3 removed lines

@@ -81,7 +81,7 @@ 
      */
     public function append($id, DomainEventStream $eventStream, bool $ignorePlayhead = false)
     {
-        $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();
@@ -111,7 +111,7 @@ 
         } catch (\PDOException $ex) {
             if ((string) $ex->getCode() === '23000') {
                 if ($ignorePlayhead) {
-                    $eventRow['playhead'] ++;
+                    $eventRow['playhead']++;
                     return $this->insertEvent($eventRow, true);
                 }
                 throw new DuplicateAggregatePlayhead($eventRow['uuid'], $eventRow['playhead']);
@@ -177,7 +177,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/BuildLaravelEventStore.php

Indentation +14 added lines, -14 removed lines

@@ -49,8 +49,8 @@ 
     public function handle()
     {
         if ($this->option('force') == 'true' || $this->confirm("Are you sure you want to make a new table '{$this->config->get('cqrses.eventstore_table')}'"
-                                                               . " on connection '{$this->config->get('cqrses.eventstore_connection')}'"
-                                                               . " Do you wish to continue?")
+                                                                . " on connection '{$this->config->get('cqrses.eventstore_connection')}'"
+                                                                . " Do you wish to continue?")
         ) {
             try {
                 return $this->buildEventStoreTable();
@@ -67,18 +67,18 @@ 
     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

@@ -68,7 +68,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();
@@ -78,7 +78,7 @@ 
                       $table->string('type', 255)->index();
                       $table->unique(['uuid', 'playhead']);
 
-                      $table->index(['id','type']);
+                      $table->index(['id', 'type']);
                   });
     }
 }
\ No newline at end of file

src/EventBus/PushEventsThroughQueue.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,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())),