SmoothPhp / CQRS-ES-Framework-Laravel

src/EventBus/QueueToEventDispatcher.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
      */
     public function fire($job, $data)
     {
-        $payload = (json_decode($data['payload'],true));
+        $payload = (json_decode($data['payload'], true));
 
         $event = call_user_func([
                                     str_replace('.', '\\', $data['type']),

src/Console/EventStoreBranchSwap.php

Doc Comments +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
     }
 
     /**
-     * @param $branch
+     * @param string|null $branch
      */
     protected function replaceEnvConfig($branch)
     {

Spacing +5 added lines, -5 removed lines

@@ -68,7 +68,7 @@ 
     protected function getGitBranch()
     {
         $shellOutput = [];
-        exec('git branch | ' . "grep ' * '", $shellOutput);
+        exec('git branch | '."grep ' * '", $shellOutput);
         foreach ($shellOutput as $line) {
             if (strpos($line, '* ') !== false) {
                 return trim(strtolower(str_replace(['* ', '/'], ['', '-'], $line)));
@@ -83,9 +83,9 @@ 
      */
     protected function replaceEnvConfig($branch)
     {
-        $envFilePath = base_path() . '/.env';
+        $envFilePath = base_path().'/.env';
 
-        $rebuildFunction = function ($data) use ($branch) {
+        $rebuildFunction = function($data) use ($branch) {
             if (stristr($data, 'DB_TABLE_EVENTSTORE')) {
                 return "DB_TABLE_EVENTSTORE={$branch}\n";
             }
@@ -93,8 +93,8 @@ 
             return $data;
         };
 
-        $contentArray = array_map($rebuildFunction,file($envFilePath));
+        $contentArray = array_map($rebuildFunction, file($envFilePath));
 
-        file_put_contents($envFilePath, implode('',$contentArray));
+        file_put_contents($envFilePath, implode('', $contentArray));
     }
 }

src/EventBus/EventBusLogger.php

Spacing +2 added lines, -2 removed lines

@@ -29,9 +29,9 @@
      */
     public function handle(DomainMessage $domainMessage)
     {
-        $name = explode('.',$domainMessage->getType());
+        $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

src/ServiceProvider.php

Spacing +9 added lines, -9 removed lines

@@ -38,7 +38,7 @@ 
     public function register()
     {
 
-        $configPath = __DIR__ . '/../config/cqrses.php';
+        $configPath = __DIR__.'/../config/cqrses.php';
         $this->mergeConfigFrom($configPath, 'cqrses');
 
         $app = $this->app;
@@ -66,7 +66,7 @@ 
 
     public function boot()
     {
-        $configPath = __DIR__ . '/../config/cqrses.php';
+        $configPath = __DIR__.'/../config/cqrses.php';
         $this->publishes([$configPath => $this->getConfigPath()], 'config');
 
     }
@@ -112,7 +112,7 @@ 
 
             $this->app->singleton(
                 CommandBus::class,
-                function () use ($middlewareChain) {
+                function() use ($middlewareChain) {
                     return new \SmoothPhp\CommandBus\CommandBus($middlewareChain);
                 }
             );
@@ -135,7 +135,7 @@ 
         if ($app['config']->get('cqrses.laravel_eventstore_enabled')) {
             $app->bind(
                 EventStore::class,
-                function (Application $application) {
+                function(Application $application) {
                     return new LaravelEventStore(
                         $application->make(DatabaseManager::class),
                         $application->make(Serializer::class),
@@ -154,7 +154,7 @@ 
     {
         $app->singleton(
             EventBus::class,
-            function (Application $application) {
+            function(Application $application) {
                 $eventBus = $application->make($application['config']->get('cqrses.event_bus'));
 
                 foreach ($application['config']->get('cqrses.event_bus_listeners') as $listener) {
@@ -173,7 +173,7 @@ 
     {
         $app->singleton(
             EventDispatcher::class,
-            function (Application $application) {
+            function(Application $application) {
                 /** @var EventDispatcher $dispatcher */
                 $dispatcher = $application->make($application['config']->get('cqrses.event_dispatcher'));
 
@@ -193,13 +193,13 @@ 
     protected function getProjectionEventSubscribers(Application $app)
     {
         return collect($app['config']->get('cqrses.projections_service_providers'))->map(
-            function ($projectionsServiceProvider) use ($app) {
+            function($projectionsServiceProvider) use ($app) {
                 return $app->make($projectionsServiceProvider);
             }
         )->map(
-            function (ProjectionServiceProvider $projectServiceProvider) use ($app) {
+            function(ProjectionServiceProvider $projectServiceProvider) use ($app) {
                 return collect($projectServiceProvider->getProjections())->map(
-                    function ($projection) use ($app) {
+                    function($projection) use ($app) {
                         return $app->make($projection);
                     }
                 );

src/Console/BuildLaravelEventStore.php

Indentation +13 added lines, -13 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,16 +67,16 @@ 
     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', 32)->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', 32)->nullable()->index();
+                        $table->string('type', 255)->index();
+                        $table->unique(['uuid', 'playhead']);
+                    });
     }
 }
\ No newline at end of file

Spacing +1 added lines, -1 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();

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) {

Spacing +4 added lines, -4 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']);
@@ -178,11 +178,11 @@ 
     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())),
-            'recorded_on' => (string)$domainMessage->getRecordedOn(),
+            'recorded_on' => (string) $domainMessage->getRecordedOn(),
             'type'        => $domainMessage->getType(),
         ];
     }

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 +2 added lines, -2 removed lines

@@ -54,11 +54,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/StrongConsistencyCommandBusMiddleware.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
      */
     public function execute(Command $command, callable $next)
     {
-        $this->lastCommandId = (string)$command;
+        $this->lastCommandId = (string) $command;
         $next($command);
     }
 

src/EventBus/PushEventsThroughQueue.php

Spacing +2 added lines, -2 removed lines

@@ -44,11 +44,11 @@
         $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())),
-                'recorded_on' => (string)$domainMessage->getRecordedOn(),
+                'recorded_on' => (string) $domainMessage->getRecordedOn(),
                 'type'        => $domainMessage->getType(),
             ],
             $this->config->get('cqrses.queue_name', 'default')