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\EventStore\EventStreamNotFound;
 use SmoothPhp\Contracts\Serialization\Serializer;

Indentation +14 added lines, -14 removed lines

@@ -53,10 +53,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) {
@@ -103,16 +103,16 @@ 
     private function insertEvent(DomainMessage $domainMessage)
     {
         $this->db->table($this->eventStoreTableName)
-           ->insert(
-               [
-                   '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(),
-                   'type'        => $domainMessage->getType(),
-               ]
-           );
+            ->insert(
+                [
+                    '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(),
+                    'type'        => $domainMessage->getType(),
+                ]
+            );
     }
 
     /**

Spacing +4 added lines, -4 removed lines

@@ -80,13 +80,13 @@ 
      */
     public function append($id, DomainEventStream $eventStream)
     {
-        $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->beginTransaction();
 
         try {
             foreach ($eventStream as $domainMessage) {
-                $this->insertEvent( $domainMessage);
+                $this->insertEvent($domainMessage);
             }
 
             $this->db->commit();
@@ -105,11 +105,11 @@ 
         $this->db->table($this->eventStoreTableName)
            ->insert(
                [
-                   '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/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/EventBus/PushEventsThroughQueue.php

Indentation +8 added lines, -8 removed lines

@@ -37,13 +37,13 @@
     public function handle(DomainMessage $domainMessage)
     {
         $this->queue->push(QueueToEventDispatcher::class,
-                           [
-                               '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(),
-                               'type'        => $domainMessage->getType(),
-                           ]);
+                            [
+                                '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(),
+                                'type'        => $domainMessage->getType(),
+                            ]);
     }
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -38,11 +38,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(),
                            ]);
     }

src/Console/BuildLaravelEventStore.php

Spacing +1 added lines, -1 removed lines

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

Indentation +13 added lines, -13 removed lines

@@ -48,8 +48,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?")
         ) {
             return $this->buildEventStoreTable();
         }
@@ -62,16 +62,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->text('payload');
-                      $table->string('recorded_on', 32);
-                      $table->text('type');
-                      $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->text('payload');
+                        $table->string('recorded_on', 32);
+                        $table->text('type');
+                        $table->unique(['uuid', 'playhead']);
+                    });
     }
 }
\ No newline at end of file

src/Console/Generators/StubConvertingCommand.php

Indentation +3 added lines, -3 removed lines

@@ -96,11 +96,11 @@
         $stub = file_get_contents($this->getStub());
 
         $namespace = rtrim($this->config->get('cqrses.namespace') . $this->argument('aggregate') . '\\' . $this->getFolder(),
-                           '\\');
+                            '\\');
 
         $stub = $this->replaceStubVariable('namespace',
-                                           $namespace,
-                                           $stub);
+                                            $namespace,
+                                            $stub);
 
         foreach ($this->replacementVariables() as $variableName => $variableValue) {
             $stub = $this->replaceStubVariable($variableName, $variableValue, $stub);

Spacing +5 added lines, -5 removed lines

@@ -53,16 +53,16 @@ 
     public function handle()
     {
 
-        $path = base_path() . '/' . $this->config->get('cqrses.path') . '/' . $this->argument('aggregate') . '/' . $this->getFolder() . '/';
+        $path = base_path().'/'.$this->config->get('cqrses.path').'/'.$this->argument('aggregate').'/'.$this->getFolder().'/';
 
         if (!file_exists($path)) {
             $this->makeDirectory($path);
         }
 
-        $fullPath = $path . $this->getClassName() . '.php';
+        $fullPath = $path.$this->getClassName().'.php';
 
         if (file_exists($fullPath)) {
-            $this->error($fullPath . ' Already Exists');
+            $this->error($fullPath.' Already Exists');
 
             return;
         }
@@ -95,7 +95,7 @@ 
     {
         $stub = file_get_contents($this->getStub());
 
-        $namespace = rtrim($this->config->get('cqrses.namespace') . $this->argument('aggregate') . '\\' . $this->getFolder(),
+        $namespace = rtrim($this->config->get('cqrses.namespace').$this->argument('aggregate').'\\'.$this->getFolder(),
                            '\\');
 
         $stub = $this->replaceStubVariable('namespace',
@@ -116,7 +116,7 @@ 
      */
     protected function replaceStubVariable($variableName, $variableValue, $stub)
     {
-        $stub = str_replace('{{' . $variableName . '}}', $variableValue, $stub);
+        $stub = str_replace('{{'.$variableName.'}}', $variableValue, $stub);
 
         return $stub;
     }

Doc Comments +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
     }
 
     /**
-     * @return bool
+     * @return boolean|null
      */
     public function handle()
     {

src/Console/RebuildProjectionsCommand.php

Unused Use Statements -1 removed lines

@@ -7,7 +7,6 @@
 use Illuminate\Database\DatabaseManager;
 use SmoothPhp\Contracts\EventDispatcher\EventDispatcher;
 use SmoothPhp\Contracts\Serialization\Serializer;
-use SmoothPhp\Serialization\Exception\SerializedClassDoesNotExist;
 
 /**
  * Class RebuildProjectionsCommand

Doc Comments +2 added lines, -2 removed lines

@@ -118,8 +118,8 @@
     }
 
     /**
-     * @param $start
-     * @param $take
+     * @param integer $start
+     * @param integer $take
      * @return \stdClass
      */
     private function getFromEventStore($start, $take)

Spacing +1 added lines, -1 removed lines

@@ -114,7 +114,7 @@
         }
         $this->output->progressFinish();
 
-        $this->output->write((memory_get_peak_usage(true) / 1024 / 1024) . " MiB", false);
+        $this->output->write((memory_get_peak_usage(true) / 1024 / 1024)." MiB", false);
     }
 
     /**

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

Spacing +2 added lines, -2 removed lines

@@ -46,11 +46,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(),
             ]

Doc Comments +1 added lines, -1 removed lines

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

src/helpers.php

Spacing +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
         }
 
         foreach ($commands as $command) {
-            while (!Cache::has((string)$command)) {
+            while (!Cache::has((string) $command)) {
                 usleep(1000);
 
                 if ($i > 8000) {
@@ -33,6 +33,6 @@ 
      */
     function uuid()
     {
-        return (string)\Ramsey\Uuid\Uuid::uuid4();
+        return (string) \Ramsey\Uuid\Uuid::uuid4();
     }
 }