cubiche / event-sourcing

Tests/Units/Migrations/MigratorTests.php

Spacing +2 added lines, -2 removed lines

@@ -61,7 +61,7 @@ 
                 ->boolean(file_exists($this->getMigratorFileName(\BlogEventSourced::class, $version)))
                     ->isTrue()
                 ->and()
-                ->exception(function () use ($migrator, $version) {
+                ->exception(function() use ($migrator, $version) {
                     $migrator->generate($version);
                 })->isInstanceOf(\RuntimeException::class)
         ;
@@ -216,7 +216,7 @@ 
                 ->boolean($result)
                     ->isTrue()
                 ->and()
-                    ->exception(function () use ($migrator) {
+                    ->exception(function() use ($migrator) {
                         // because the V1_0_0\BlogEventSourcedMigration class return an invalid stream
                         $migrator->migrate();
                     })->isInstanceOf(\RuntimeException::class)

Tests/Units/EventStore/EventStreamTests.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
         $this
             ->given($postId = PostId::fromNative(md5(rand())))
             ->then()
-                ->exception(function () use ($postId) {
+                ->exception(function() use ($postId) {
                     new EventStream('posts', $postId, ['bar']);
                 })->isInstanceOf(\InvalidArgumentException::class)
         ;
@@ -81,7 +81,7 @@ 
         $this
             ->given($postId = PostId::fromNative(md5(rand())))
             ->then()
-                ->exception(function () use ($postId) {
+                ->exception(function() use ($postId) {
                     new EventStream(
                         'posts',
                         $postId,

Tests/Units/EventStore/EventStoreTestCase.php

Spacing +14 added lines, -14 removed lines

@@ -92,19 +92,19 @@ 
             ->and($applicationVersion = new Version())
             ->when($store->persist($eventStream, $aggregateVersion, $applicationVersion))
             ->then()
-                ->exception(function () use ($store, $postId, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $postId, $aggregateVersion, $applicationVersion) {
                     $store->load('blogs', $postId, $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
-                ->exception(function () use ($store, $postId, $applicationVersion) {
+                ->exception(function() use ($store, $postId, $applicationVersion) {
                     $store->load('posts', $postId, new Version(0, 10, 456), $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
-                ->exception(function () use ($store, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $aggregateVersion, $applicationVersion) {
                     $store->load('posts', PostId::fromNative(md5(rand())), $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
                 ->and()
                 ->when($applicationVersion = Version::fromString('2.1.0'))
                 ->then()
-                    ->exception(function () use ($store, $postId, $aggregateVersion, $applicationVersion) {
+                    ->exception(function() use ($store, $postId, $aggregateVersion, $applicationVersion) {
                         $store->load('posts', $postId, $aggregateVersion, $applicationVersion);
                     })->isInstanceOf(\RuntimeException::class)
         ;
@@ -121,7 +121,7 @@ 
             ->and($aggregateVersion = new Version())
             ->and($applicationVersion = new Version())
             ->then()
-                ->exception(function () use ($store, $postId, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $postId, $aggregateVersion, $applicationVersion) {
                     $store->remove('posts', $postId, $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
         ;
@@ -135,13 +135,13 @@ 
             ->when($store->persist($eventStream, $aggregateVersion, $applicationVersion))
             ->and($store->remove('posts', $postId, $aggregateVersion, $applicationVersion))
             ->then()
-                ->exception(function () use ($store, $postId, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $postId, $aggregateVersion, $applicationVersion) {
                     $store->load('posts', $postId, $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
-                ->exception(function () use ($store, $postId, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $postId, $aggregateVersion, $applicationVersion) {
                     $store->remove('blogs', $postId, $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
-                ->exception(function () use ($store, $postId, $applicationVersion) {
+                ->exception(function() use ($store, $postId, $applicationVersion) {
                     $store->remove('posts', $postId, new Version(0, 10, 456), $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
         ;
@@ -163,10 +163,10 @@ 
             ->when($store->persist($eventStream, $aggregateVersion, $applicationVersion))
             ->and($store->persist($eventStream1, $aggregateVersion, $applicationVersion))
             ->then()
-                ->exception(function () use ($store, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $aggregateVersion, $applicationVersion) {
                     $store->loadAll('blogs', $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
-                ->exception(function () use ($store, $applicationVersion) {
+                ->exception(function() use ($store, $applicationVersion) {
                     $store->loadAll('posts', new Version(0, 10, 456), $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
                 ->array($store->loadAll('posts', $aggregateVersion, $applicationVersion))
@@ -174,7 +174,7 @@ 
                 ->and()
                 ->when($applicationVersion = Version::fromString('2.1.0'))
                 ->then()
-                    ->exception(function () use ($store, $aggregateVersion, $applicationVersion) {
+                    ->exception(function() use ($store, $aggregateVersion, $applicationVersion) {
                         $store->loadAll('posts', $aggregateVersion, $applicationVersion);
                     })->isInstanceOf(\RuntimeException::class)
         ;
@@ -191,7 +191,7 @@ 
             ->and($aggregateVersion = new Version())
             ->and($applicationVersion = new Version())
             ->then()
-                ->exception(function () use ($store, $aggregateVersion, $applicationVersion) {
+                ->exception(function() use ($store, $aggregateVersion, $applicationVersion) {
                     $store->removeAll('posts', $aggregateVersion, $applicationVersion);
                 })->isInstanceOf(\RuntimeException::class)
         ;
@@ -212,14 +212,14 @@ 
                 ->and()
                 ->when($store->removeAll('posts', $aggregateVersion, $applicationVersion))
                 ->then()
-                    ->exception(function () use ($store, $aggregateVersion, $applicationVersion) {
+                    ->exception(function() use ($store, $aggregateVersion, $applicationVersion) {
                         // because there is no stream entry in the current application store
                         $store->loadAll('posts', $aggregateVersion, $applicationVersion);
                     })->isInstanceOf(\RuntimeException::class)
                 ->and()
                 ->when($applicationVersion = Version::fromString('2.1.0'))
                 ->then()
-                    ->exception(function () use ($store, $aggregateVersion, $applicationVersion) {
+                    ->exception(function() use ($store, $aggregateVersion, $applicationVersion) {
                         // because there is application entry in the store
                         $store->removeAll('posts', $aggregateVersion, $applicationVersion);
                     })->isInstanceOf(\RuntimeException::class)

Tests/Units/Snapshot/Policy/CompositeSnapshottingPolicyTests.php

Spacing +1 added lines, -1 removed lines

@@ -64,7 +64,7 @@
         ;
 
         $this
-            ->exception(function () {
+            ->exception(function() {
                 new CompositeSnapshottingPolicy(
                     [new AllwaysSnapshottingPolicy(), 'foo']
                 );

Tests/Units/AggregateRepositoryTests.php

Spacing +4 added lines, -4 removed lines

@@ -68,7 +68,7 @@ 
             ->and($post->clearEvents())
             ->when($repository->persist($post))
             ->then()
-                ->exception(function () use ($repository, $post) {
+                ->exception(function() use ($repository, $post) {
                     $repository->get($post->id());
                 })
                 ->isInstanceOf(\RuntimeException::class)
@@ -84,7 +84,7 @@ 
                 )
             )
             ->then()
-                ->exception(function () use ($repository, $post) {
+                ->exception(function() use ($repository, $post) {
                     $repository->persist($post);
                 })
                 ->isInstanceOf(\InvalidArgumentException::class)
@@ -162,7 +162,7 @@ 
                 ->and()
                 ->when($repository->remove($post))
                 ->then()
-                    ->exception(function () use ($repository, $post) {
+                    ->exception(function() use ($repository, $post) {
                         $repository->get($post->id());
                     })->isInstanceOf(\RuntimeException::class)
         ;
@@ -177,7 +177,7 @@ 
                 )
             )
             ->then()
-                ->exception(function () use ($repository, $post) {
+                ->exception(function() use ($repository, $post) {
                     $repository->remove($post);
                 })
                 ->isInstanceOf(\InvalidArgumentException::class)

Tests/Units/EventSourcedAggregateRootTests.php

Spacing +4 added lines, -4 removed lines

@@ -57,7 +57,7 @@ 
                 )
             )
             ->then()
-                ->exception(function () use ($post) {
+                ->exception(function() use ($post) {
                     $post->remove();
                 })->isInstanceOf(\BadMethodCallException::class)
         ;
@@ -175,16 +175,16 @@ 
                 ->array($post->recordedEvents())
                     ->hasSize(2)
             ->and()
-            ->exception(function () use ($post) {
+            ->exception(function() use ($post) {
                 $post->changeTitle('');
             })->isInstanceOf(ValidationException::class)
-            ->exception(function () use ($post) {
+            ->exception(function() use ($post) {
                 $post->changeTitle(10);
             })->isInstanceOf(ValidationException::class)
         ;
 
         $this
-            ->exception(function () {
+            ->exception(function() {
                 PostEventSourcedFactory::create('', $this->faker->paragraph);
             })->isInstanceOf(ValidationException::class)
         ;

Tests/Units/DomainEventTests.php

Spacing +2 added lines, -2 removed lines

@@ -107,14 +107,14 @@
                     ->isEqualTo($eventId)
                 ->string['eventType']
                     ->isEqualTo(PostWasCreated::class)
-                ->child['metadata'](function ($metadata) use ($postId) {
+                ->child['metadata'](function($metadata) use ($postId) {
                     $metadata
                         ->hasKey('occurredOn')
                         ->object['aggregateId']
                             ->isEqualTo($postId)
                     ;
                 })
-                ->child['payload'](function ($payload) use ($title, $content) {
+                ->child['payload'](function($payload) use ($title, $content) {
                     $payload
                         ->isEqualTo(array(
                             'title' => $title,