fix integration tests

patchlevel · Feb 4, 2024 · 5a9f10e · 5a9f10e
1 parent 1f52d9f
commit 5a9f10e
Show file tree

Hide file tree

Showing 8 changed files with 18 additions and 14 deletions.
diff --git a/tests/Integration/BankAccountSplitStream/IntegrationTest.php b/tests/Integration/BankAccountSplitStream/IntegrationTest.php
@@ -11,6 +11,7 @@
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
+use Patchlevel\EventSourcing\Projection\Projection\ProjectionCriteria;
 use Patchlevel\EventSourcing\Projection\Projection\Store\InMemoryStore;
 use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
@@ -89,7 +90,7 @@ public function testSuccessful(): void
         );
 
         $schemaDirector->create();
-        $projectionist->boot();
+        $projectionist->boot(new ProjectionCriteria(), null, true);
 
         $bankAccountId = AccountId::fromString('1');
         $bankAccount = BankAccount::create($bankAccountId, 'John');

diff --git a/tests/Integration/BankAccountSplitStream/Projection/BankAccountProjector.php b/tests/Integration/BankAccountSplitStream/Projection/BankAccountProjector.php
@@ -28,8 +28,8 @@ public function __construct(
     public function create(): void
     {
         $table = new Table('projection_bank_account');
-        $table->addColumn('id', 'string');
-        $table->addColumn('name', 'string');
+        $table->addColumn('id', 'string')->setLength(36);
+        $table->addColumn('name', 'string')->setLength(255);
         $table->addColumn('balance_in_cents', 'integer');
         $table->setPrimaryKey(['id']);
 

diff --git a/tests/Integration/BasicImplementation/BasicIntegrationTest.php b/tests/Integration/BasicImplementation/BasicIntegrationTest.php
@@ -8,6 +8,7 @@
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
+use Patchlevel\EventSourcing\Projection\Projection\ProjectionCriteria;
 use Patchlevel\EventSourcing\Projection\Projection\Store\InMemoryStore;
 use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
@@ -88,7 +89,7 @@ public function testSuccessful(): void
         );
 
         $schemaDirector->create();
-        $projectionist->boot();
+        $projectionist->boot(new ProjectionCriteria(), null, true);
 
         $profileId = ProfileId::fromString('1');
         $profile = Profile::create($profileId, 'John');
@@ -161,7 +162,7 @@ public function testSnapshot(): void
         );
 
         $schemaDirector->create();
-        $projectionist->boot();
+        $projectionist->boot(new ProjectionCriteria(), null, true);
 
         $profileId = ProfileId::fromString('1');
         $profile = Profile::create($profileId, 'John');

diff --git a/tests/Integration/BasicImplementation/Projection/ProfileProjector.php b/tests/Integration/BasicImplementation/Projection/ProfileProjector.php
@@ -27,8 +27,8 @@ public function __construct(
     public function create(): void
     {
         $table = new Table('projection_profile');
-        $table->addColumn('id', 'string');
-        $table->addColumn('name', 'string');
+        $table->addColumn('id', 'string')->setLength(36);
+        $table->addColumn('name', 'string')->setLength(255);
         $table->setPrimaryKey(['id']);
 
         $this->connection->createSchemaManager()->createTable($table);

diff --git a/tests/Integration/Outbox/OutboxTest.php b/tests/Integration/Outbox/OutboxTest.php
@@ -11,6 +11,7 @@
 use Patchlevel\EventSourcing\Outbox\EventBusPublisher;
 use Patchlevel\EventSourcing\Outbox\OutboxEventBus;
 use Patchlevel\EventSourcing\Outbox\StoreOutboxConsumer;
+use Patchlevel\EventSourcing\Projection\Projection\ProjectionCriteria;
 use Patchlevel\EventSourcing\Projection\Projection\Store\InMemoryStore;
 use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
@@ -100,7 +101,7 @@ public function testSuccessful(): void
         );
 
         $schemaDirector->create();
-        $projectionist->boot();
+        $projectionist->boot(new ProjectionCriteria(), null, true);
 
         $profile = Profile::create(ProfileId::fromString('1'), 'John');
         $repository->save($profile);

diff --git a/tests/Integration/Outbox/Projection/ProfileProjector.php b/tests/Integration/Outbox/Projection/ProfileProjector.php
@@ -27,8 +27,8 @@ public function __construct(
     public function create(): void
     {
         $table = new Table('projection_profile');
-        $table->addColumn('id', 'string');
-        $table->addColumn('name', 'string');
+        $table->addColumn('id', 'string')->setLength(36);
+        $table->addColumn('name', 'string')->setLength(255);
         $table->setPrimaryKey(['id']);
 
         $this->connection->createSchemaManager()->createTable($table);

diff --git a/tests/Integration/Projectionist/Projection/ProfileProjector.php b/tests/Integration/Projectionist/Projection/ProfileProjector.php
@@ -31,8 +31,8 @@ public function __construct(
     public function create(): void
     {
         $table = new Table($this->tableName());
-        $table->addColumn('id', 'string');
-        $table->addColumn('name', 'string');
+        $table->addColumn('id', 'string')->setLength(36);
+        $table->addColumn('name', 'string')->setLength(255);
         $table->setPrimaryKey(['id']);
 
         $this->connection->createSchemaManager()->createTable($table);

diff --git a/tests/Integration/Projectionist/ProjectionistTest.php b/tests/Integration/Projectionist/ProjectionistTest.php
@@ -9,6 +9,7 @@
 use Patchlevel\EventSourcing\Lock\DoctrineDbalStoreSchemaAdapter;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
+use Patchlevel\EventSourcing\Projection\Projection\ProjectionCriteria;
 use Patchlevel\EventSourcing\Projection\Projection\Store\DoctrineStore;
 use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
@@ -138,12 +139,12 @@ public function testSync(): void
 
         $schemaDirector->drop();
         $schemaDirector->create();
-        $projectionist->boot();
+        $projectionist->boot(new ProjectionCriteria(), null, true);
 
         $profile = Profile::create(ProfileId::fromString('1'), 'John');
         $repository->save($profile);
 
-        $projectionist->run();
+        $projectionist->run(new ProjectionCriteria(), null, true);
 
         $result = $this->connection->fetchAssociative('SELECT * FROM projection_profile_1 WHERE id = ?', ['1']);