SmoothPhp / CQRS-ES-Framework-Laravel

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

src/EventStore/LaravelEventStore.php

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

src/Console/BuildLaravelEventStore.php

Indentation +14 added lines, -14 removed lines

@@ -71,20 +71,20 @@
     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')->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')->nullable()->index();
+                        $table->string('type', 255)->index();
+                        $table->unique(['uuid', 'playhead']);
 
-                      $table->index(['id', 'type']);
-                  }
-              );
+                        $table->index(['id', 'type']);
+                    }
+                );
     }
 }
\ No newline at end of file