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/EventBus/EventBusLogger.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
      */
     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()})");

src/EventBus/PushEventsThroughQueue.php

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

src/EventStore/LaravelEventStore.php

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/Console/EventStoreBranchSwap.php

Spacing +3 added lines, -3 removed lines

@@ -85,7 +85,7 @@ 
     {
         $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(),
             ]

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

src/StrongConsistency/StrongConsistencyCommandBusMiddleware.php

Spacing +1 added lines, -1 removed lines

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