fix tests

baseline.xml

@@ -192,7 +192,7 @@
     <InvalidArgument>
       <code><![CDATA[[
                 'foo' => 'bar',
-                'aggregateClass' => Profile::class,
+                'aggregateName' => 'profile',
                 'aggregateId' => '1',
                 'playhead' => 3,
                 'recordedOn' => $recordedAt,

src/Console/OutputStyle.php

@@ -24,14 +24,14 @@ public function message(EventSerializer $serializer, Message $message): void
 
         $this->horizontalTable([
             'eventClass',
-            'aggregateClass',
+            'aggregateName',
             'aggregateId',
             'playhead',
             'recordedOn',
         ], [
             [
                 $event::class,
-                $message->aggregateClass(),
+                $message->aggregateName(),
                 $message->aggregateId(),
                 $message->playhead(),
                 $message->recordedOn()->format(DateTimeInterface::ATOM),

tests/Benchmark/SimpleSetupBench.php

@@ -9,7 +9,6 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
@@ -50,7 +49,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            (new AttributeAggregateRootRegistryFactory())->create([__DIR__ . '/BasicImplementation/Aggregate']),
             'eventstore',
         );
 

tests/Benchmark/SnapshotsBench.php

@@ -9,7 +9,6 @@
 use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
@@ -56,7 +55,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            (new AttributeAggregateRootRegistryFactory())->create([__DIR__ . '/BasicImplementation/Aggregate']),
             'eventstore',
         );
 

tests/Benchmark/SplitStreamBench.php

@@ -10,7 +10,6 @@
 use Patchlevel\EventSourcing\EventBus\Decorator\SplitStreamDecorator;
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\Repository;
@@ -55,7 +54,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            (new AttributeAggregateRootRegistryFactory())->create([__DIR__ . '/BasicImplementation/Aggregate']),
             'eventstore',
         );
 

tests/Benchmark/SyncProjectionistBench.php

@@ -9,7 +9,6 @@
 use Patchlevel\EventSourcing\EventBus\DefaultEventBus;
 use Patchlevel\EventSourcing\EventBus\EventBus;
 use Patchlevel\EventSourcing\Lock\DoctrineDbalStoreSchemaAdapter;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
 use Patchlevel\EventSourcing\Projection\Projection\Store\InMemoryStore;
 use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
@@ -58,7 +57,6 @@ public function setUp(): void
         $this->store = new DoctrineDbalStore(
             $connection,
             DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-            (new AttributeAggregateRootRegistryFactory())->create([__DIR__ . '/BasicImplementation/Aggregate']),
             'eventstore',
         );
 

tests/Benchmark/blackfire.php

@@ -31,7 +31,6 @@
 $store = new DoctrineDbalStore(
     $connection,
     DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
-    (new AttributeAggregateRootRegistryFactory())->create([__DIR__ . '/BasicImplementation/Aggregate']),
     'eventstore',
 );
 

tests/Unit/Console/Command/OutboxInfoCommandTest.php

@@ -11,7 +11,6 @@
 use Patchlevel\EventSourcing\Serializer\Encoder\Encoder;
 use Patchlevel\EventSourcing\Serializer\EventSerializer;
 use Patchlevel\EventSourcing\Serializer\SerializedEvent;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileVisited;
 use PHPUnit\Framework\TestCase;
@@ -31,7 +30,7 @@ public function testSuccessful(): void
         $store = $this->prophesize(OutboxStore::class);
         $store->retrieveOutboxMessages(null)->willReturn([
             Message::create($event)
-                ->withAggregateClass(Profile::class)
+                ->withAggregateName('profile')
                 ->withAggregateId('1')
                 ->withPlayhead(1)
                 ->withRecordedOn(new DateTimeImmutable()),
@@ -69,7 +68,7 @@ public function testSuccessfulWithLimit(): void
         $store = $this->prophesize(OutboxStore::class);
         $store->retrieveOutboxMessages(100)->willReturn([
             Message::create($event)
-                ->withAggregateClass(Profile::class)
+                ->withAggregateName('profile')
                 ->withAggregateId('1')
                 ->withPlayhead(1)
                 ->withRecordedOn(new DateTimeImmutable()),

tests/Unit/Console/Command/ShowAggregateCommandTest.php

@@ -38,7 +38,7 @@ public function testSuccessful(): void
         $store->load(new Criteria(Profile::class, '1'))->willReturn(
             new ArrayStream([
                 Message::create($event)
-                    ->withAggregateClass(Profile::class)
+                    ->withAggregateName('profile')
                     ->withAggregateId('1')
                     ->withPlayhead(1)
                     ->withRecordedOn(new DateTimeImmutable()),
@@ -214,7 +214,7 @@ public function testInteractiveSuccessful(): void
         $store->load(new Criteria(Profile::class, '1'))->willReturn(
             new ArrayStream([
                 Message::create($event)
-                    ->withAggregateClass(Profile::class)
+                    ->withAggregateName('profile')
                     ->withAggregateId('1')
                     ->withPlayhead(1)
                     ->withRecordedOn(new DateTimeImmutable()),

tests/Unit/Console/OutputStyleTest.php

@@ -11,7 +11,6 @@
 use Patchlevel\EventSourcing\Serializer\EventSerializer;
 use Patchlevel\EventSourcing\Serializer\SerializedEvent;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
 use PHPUnit\Framework\TestCase;
@@ -41,7 +40,7 @@ public function testWrite(): void
         ));
 
         $message = Message::create($event)
-            ->withAggregateClass(Profile::class)
+            ->withAggregateName('profile')
             ->withAggregateId('1')
             ->withPlayhead(1)
             ->withRecordedOn(new DateTimeImmutable());

tests/Unit/EventBus/HeaderNotFoundTest.php

@@ -10,11 +10,11 @@
 /** @covers \Patchlevel\EventSourcing\EventBus\HeaderNotFound */
 final class HeaderNotFoundTest extends TestCase
 {
-    public function testAggregateClass(): void
+    public function testAggregateName(): void
     {
         self::assertSame(
-            'message header "aggregateClass" is not defined',
-            HeaderNotFound::aggregateClass()->getMessage(),
+            'message header "aggregateName" is not defined',
+            HeaderNotFound::aggregateName()->getMessage(),
         );
     }
 

tests/Unit/EventBus/MessageTest.php

@@ -9,7 +9,6 @@
 use Patchlevel\EventSourcing\EventBus\HeaderNotFound;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
 use PHPUnit\Framework\Attributes\DataProvider;
@@ -34,9 +33,9 @@ public function testCreateMessageWithAggregateHeader(): void
     {
         $message = Message::create(new class {
         })
-            ->withAggregateClass(Profile::class);
+            ->withAggregateName('profile');
 
-        self::assertSame(Profile::class, $message->aggregateClass());
+        self::assertSame('profile', $message->aggregateName());
     }
 
     public function testCreateMessageWithAggregateIdHeader(): void
@@ -143,7 +142,7 @@ public function testAllHeaders(): void
 
         $message = Message::create(new class {
         })
-            ->withAggregateClass(Profile::class)
+            ->withAggregateName('profile')
             ->withAggregateId('1')
             ->withPlayhead(3)
             ->withRecordedOn($recordedAt)
@@ -154,7 +153,7 @@ public function testAllHeaders(): void
         self::assertSame(
             [
                 'foo' => 'bar',
-                'aggregateClass' => Profile::class,
+                'aggregateName' => 'profile',
                 'aggregateId' => '1',
                 'playhead' => 3,
                 'recordedOn' => $recordedAt,
@@ -187,7 +186,7 @@ public function testCreateWithAllHeaders(): void
             },
             [
                 'foo' => 'bar',
-                'aggregateClass' => Profile::class,
+                'aggregateName' => 'profile',
                 'aggregateId' => '1',
                 'playhead' => 3,
                 'recordedOn' => $recordedAt,
@@ -199,7 +198,7 @@ public function testCreateWithAllHeaders(): void
         self::assertSame(
             [
                 'foo' => 'bar',
-                'aggregateClass' => Profile::class,
+                'aggregateName' => 'profile',
                 'aggregateId' => '1',
                 'playhead' => 3,
                 'recordedOn' => $recordedAt,
@@ -224,7 +223,7 @@ public function testHeaderNotFound(string $headerName): void
     /** @return Generator<string, array{string}> */
     public static function provideHeaderNotFound(): Generator
     {
-        yield 'aggregateClass' => ['aggregateClass'];
+        yield 'aggregateName' => ['aggregateName'];
         yield 'aggregateId' => ['aggregateId'];
         yield 'playhead' => ['playhead'];
         yield 'recordedOn' => ['recordedOn'];

tests/Unit/Outbox/DoctrineOutboxStoreTest.php

@@ -14,13 +14,11 @@
 use Doctrine\DBAL\Schema\Table;
 use Doctrine\DBAL\Types\Types;
 use Patchlevel\EventSourcing\EventBus\Message;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Outbox\DoctrineOutboxStore;
 use Patchlevel\EventSourcing\Serializer\EventSerializer;
 use Patchlevel\EventSourcing\Serializer\SerializedEvent;
 use Patchlevel\EventSourcing\Store\WrongQueryResult;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Profile;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
 use PHPUnit\Framework\TestCase;
@@ -36,7 +34,7 @@ public function testSaveOutboxMessage(): void
     {
         $recordedOn = new DateTimeImmutable();
         $message = Message::create(new ProfileCreated(ProfileId::fromString('1'), Email::fromString('s')))
-            ->withAggregateClass(Profile::class)
+            ->withAggregateName('profile')
             ->withAggregateId('1')
             ->withPlayhead(1)
             ->withRecordedOn($recordedOn)
@@ -73,7 +71,6 @@ public function testSaveOutboxMessage(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $mockedConnection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $doctrineOutboxStore->saveOutboxMessage($message);
@@ -83,7 +80,7 @@ public function testMarkOutboxMessageConsumed(): void
     {
         $recordedOn = new DateTimeImmutable();
         $message = Message::create(new ProfileCreated(ProfileId::fromString('1'), Email::fromString('s')))
-            ->withAggregateClass(Profile::class)
+            ->withAggregateName('profile')
             ->withAggregateId('1')
             ->withPlayhead(1)
             ->withRecordedOn($recordedOn)
@@ -110,7 +107,6 @@ public function testMarkOutboxMessageConsumed(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $mockedConnection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $doctrineOutboxStore->markOutboxMessageConsumed($message);
@@ -132,7 +128,6 @@ public function testCountOutboxMessages(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $connection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $result = $doctrineOutboxStore->countOutboxMessages();
@@ -155,7 +150,6 @@ public function testCountOutboxMessagesFailure(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $connection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $this->expectException(WrongQueryResult::class);
@@ -183,7 +177,6 @@ public function testRetrieveOutboxMessagesNoResult(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $connection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $messages = $doctrineOutboxStore->retrieveOutboxMessages();
@@ -195,7 +188,7 @@ public function testRetrieveOutboxMessages(): void
         $recordedOn = new DateTimeImmutable();
         $event = new ProfileCreated(ProfileId::fromString('1'), Email::fromString('s'));
         $message = Message::create($event)
-            ->withAggregateClass(Profile::class)
+            ->withAggregateName('profile')
             ->withAggregateId('1')
             ->withPlayhead(1)
             ->withRecordedOn($recordedOn)
@@ -233,7 +226,6 @@ public function testRetrieveOutboxMessages(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $connection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $messages = $doctrineOutboxStore->retrieveOutboxMessages();
@@ -248,7 +240,6 @@ public function testConfigureSchema(): void
         $doctrineOutboxStore = new DoctrineOutboxStore(
             $connection->reveal(),
             $serializer->reveal(),
-            new AggregateRootRegistry(['profile' => Profile::class]),
         );
 
         $table = $this->prophesize(Table::class);