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

Indentation +3 added lines, -3 removed lines

@@ -121,9 +121,9 @@
             $app->bind(EventStore::class,
                 function (Application $application) {
                     return new LaravelEventStore($application->make(DatabaseManager::class),
-                                                 $application->make(Serializer::class),
-                                                 $application['config']->get('cqrses.eventstore_connection'),
-                                                 $application['config']->get('cqrses.eventstore_table')
+                                                    $application->make(Serializer::class),
+                                                    $application['config']->get('cqrses.eventstore_connection'),
+                                                    $application['config']->get('cqrses.eventstore_table')
                     );
                 }
             );

Spacing +4 added lines, -4 removed lines

@@ -95,7 +95,7 @@ 
     {
         if ($app['config']->get('cqrses.command_bus_enabled')) {
             $this->app->singleton(CommandBus::class,
-                function (Application $application) {
+                function(Application $application) {
                     return new SimpleCommandBus(
                         new SimpleCommandTranslator(),
                         $application->make(LaravelCommandBusHandlerResolver::class));
@@ -119,7 +119,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),
                                                  $application['config']->get('cqrses.eventstore_connection'),
@@ -136,7 +136,7 @@ 
     protected function registerEventBus(Application $app)
     {
         $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) {
@@ -154,7 +154,7 @@ 
     protected function registerEventDispatcher(Application $app)
     {
         $app->singleton(EventDispatcher::class,
-            function (Application $application) {
+            function(Application $application) {
                 return $application->make($application['config']->get('cqrses.event_dispatcher'), [false]);
             }
         );

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

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

Spacing +2 added lines, -2 removed lines

@@ -79,14 +79,14 @@
      */
     public function handle()
     {
-        foreach($this->config->get('cqrses.pre_rebuild_commands') as $preRebuildCommand)
+        foreach ($this->config->get('cqrses.pre_rebuild_commands') as $preRebuildCommand)
         {
             $this->call($preRebuildCommand);
         }
 
         $this->replayEvents();
 
-        foreach($this->config->get('cqrses.post_rebuild_commands') as $postRebuildCommand)
+        foreach ($this->config->get('cqrses.post_rebuild_commands') as $postRebuildCommand)
         {
             $this->call($postRebuildCommand);
         }

src/Console/BuildLaravelEventStore.php

Indentation +11 added lines, -11 removed lines

@@ -57,16 +57,16 @@
         }
 
         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

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