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;

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

Doc Comments +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
      * PushEventsThroughQueue constructor.
      * @param Queue $queue
      * @param Serializer $serializer
-     * @param StrongConsistencyCommandBusMiddleware|CommandBus $notificationsCommandBus
+     * @param StrongConsistencyCommandBusMiddleware $notificationsCommandBus
      * @param Repository $config
      */
     public function __construct(

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

Spacing +2 added lines, -2 removed lines

@@ -17,7 +17,7 @@ 
 
         $limit = time() + $timeout;
         foreach ($commands as $command) {
-            while (!Cache::has((string)$command)) {
+            while (!Cache::has((string) $command)) {
                 usleep(1000);
 
                 if (time() > $limit) {
@@ -34,6 +34,6 @@ 
      */
     function uuid()
     {
-        return (string)\Ramsey\Uuid\Uuid::uuid4();
+        return (string) \Ramsey\Uuid\Uuid::uuid4();
     }
 }

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;
 

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;