rename create into setup and drop into teardown

docs/pages/getting_started.md

@@ -156,8 +156,8 @@ Each projector is then responsible for a specific projection and version.
 
 ```php
 use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Attribute\Create;
-use Patchlevel\EventSourcing\Attribute\Drop;
+use Patchlevel\EventSourcing\Attribute\Setup;
+use Patchlevel\EventSourcing\Attribute\Teardown;
 use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\Attribute\Projector;
 use Patchlevel\EventSourcing\EventBus\Message;
@@ -215,13 +215,13 @@ final class HotelProjector
         );
     }
 
-    #[Create]
+    #[Setup]
     public function create(): void
     {
         $this->db->executeStatement("CREATE TABLE IF NOT EXISTS ${this->table()} (id VARCHAR PRIMARY KEY, name VARCHAR, guests INTEGER);");
     }
 
-    #[Drop]
+    #[Teardown]
     public function drop(): void
     {
         $this->db->executeStatement("DROP TABLE IF EXISTS ${this->table()};");

docs/pages/projection.md

@@ -15,8 +15,8 @@ In this example we always create a new data set in a relational database when a
 
 ```php
 use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Attribute\Create;
-use Patchlevel\EventSourcing\Attribute\Drop;
+use Patchlevel\EventSourcing\Attribute\Setup;
+use Patchlevel\EventSourcing\Attribute\Teardown;
 use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\Attribute\Projector;
 use Patchlevel\EventSourcing\EventBus\Message;
@@ -40,15 +40,15 @@ final class ProfileProjector
         return $this->connection->fetchAllAssociative("SELECT id, name FROM ${this->table()};");
     }
 
-    #[Create]
+    #[Setup]
     public function create(): void
     {
         $this->connection->executeStatement(
             "CREATE TABLE IF NOT EXISTS ${this->table()} (id VARCHAR PRIMARY KEY, name VARCHAR NOT NULL);"
         );
     }
 
-    #[Drop]
+    #[Teardown]
     public function drop(): void
     {
         $this->connection->executeStatement("DROP TABLE IF EXISTS ${this->table()};");
@@ -87,8 +87,8 @@ So that there is no problems with existing projection,
 both the name of the projection and the version should be part of the table/collection name.
 In our example, we build a `table` helper method, what creates the following string: "projection_profile_0".
 
-Projectors can have one `create` and `drop` method that is executed when the projection is created or deleted.
-For this there are the attributes `Create` and `Drop`. The method name itself doesn't matter.
+Projectors can have one `setup` and `teardown` method that is executed when the projection is created or deleted.
+For this there are the attributes `Setup` and `Teardown`. The method name itself doesn't matter.
 In some cases it may be that no schema has to be created for the projection, 
 as the target does it automatically, so you can skip this.
 
@@ -118,8 +118,8 @@ To do this, you have to change the version in the `Projector` attribute.
 
 ```php
 use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Attribute\Create;
-use Patchlevel\EventSourcing\Attribute\Drop;
+use Patchlevel\EventSourcing\Attribute\Setup;
+use Patchlevel\EventSourcing\Attribute\Teardown;
 use Patchlevel\EventSourcing\Attribute\Handle;
 use Patchlevel\EventSourcing\Attribute\Projector;
 use Patchlevel\EventSourcing\EventBus\Message;

src/Attribute/Drop.php → src/Attribute/Setup.php

@@ -7,6 +7,6 @@
 use Attribute;
 
 #[Attribute(Attribute::TARGET_METHOD)]
-final class Drop
+final class Setup
 {
 }

src/Attribute/Create.php → src/Attribute/Teardown.php

@@ -7,6 +7,6 @@
 use Attribute;
 
 #[Attribute(Attribute::TARGET_METHOD)]
-final class Create
+final class Teardown
 {
 }

src/Metadata/Projector/AttributeProjectorMetadataFactory.php

@@ -4,10 +4,10 @@
 
 namespace Patchlevel\EventSourcing\Metadata\Projector;
 
-use Patchlevel\EventSourcing\Attribute\Create;
-use Patchlevel\EventSourcing\Attribute\Drop;
 use Patchlevel\EventSourcing\Attribute\Projector;
+use Patchlevel\EventSourcing\Attribute\Setup;
 use Patchlevel\EventSourcing\Attribute\Subscribe;
+use Patchlevel\EventSourcing\Attribute\Teardown;
 use ReflectionClass;
 
 use function array_key_exists;
@@ -59,9 +59,9 @@ public function metadata(string $projector): ProjectorMetadata
                 $subscribeMethods[$eventClass] = $method->getName();
             }
 
-            if ($method->getAttributes(Create::class)) {
+            if ($method->getAttributes(Setup::class)) {
                 if ($createMethod) {
-                    throw new DuplicateCreateMethod(
+                    throw new DuplicateSetupMethod(
                         $projector,
                         $createMethod,
                         $method->getName(),
@@ -71,12 +71,12 @@ public function metadata(string $projector): ProjectorMetadata
                 $createMethod = $method->getName();
             }
 
-            if (!$method->getAttributes(Drop::class)) {
+            if (!$method->getAttributes(Teardown::class)) {
                 continue;
             }
 
             if ($dropMethod) {
-                throw new DuplicateDropMethod(
+                throw new DuplicateTeardownMethod(
                     $projector,
                     $dropMethod,
                     $method->getName(),

src/Metadata/Projector/DuplicateDropMethod.php → src/Metadata/Projector/DuplicateSetupMethod.php

@@ -8,14 +8,14 @@
 
 use function sprintf;
 
-final class DuplicateDropMethod extends MetadataException
+final class DuplicateSetupMethod extends MetadataException
 {
     /** @param class-string $projector */
     public function __construct(string $projector, string $fistMethod, string $secondMethod)
     {
         parent::__construct(
             sprintf(
-                'Two methods "%s" and "%s" on the projector "%s" have been marked as "create" methods. Only one method can be defined like this.',
+                'Two methods "%s" and "%s" on the projector "%s" have been marked as "setup" methods. Only one method can be defined like this.',
                 $fistMethod,
                 $secondMethod,
                 $projector,

src/Metadata/Projector/DuplicateCreateMethod.php → src/Metadata/Projector/DuplicateTeardownMethod.php

@@ -8,14 +8,14 @@
 
 use function sprintf;
 
-final class DuplicateCreateMethod extends MetadataException
+final class DuplicateTeardownMethod extends MetadataException
 {
     /** @param class-string $projector */
     public function __construct(string $projector, string $fistMethod, string $secondMethod)
     {
         parent::__construct(
             sprintf(
-                'Two methods "%s" and "%s" on the projector "%s" have been marked as "create" methods. Only one method can be defined like this.',
+                'Two methods "%s" and "%s" on the projector "%s" have been marked as "teardown" methods. Only one method can be defined like this.',
                 $fistMethod,
                 $secondMethod,
                 $projector,

src/Metadata/Projector/ProjectorMetadata.php

@@ -11,8 +11,8 @@ public function __construct(
         public readonly int $version,
         /** @var array<class-string, string> */
         public readonly array $subscribeMethods = [],
-        public readonly string|null $createMethod = null,
-        public readonly string|null $dropMethod = null,
+        public readonly string|null $setupMethod = null,
+        public readonly string|null $teardownMethod = null,
     ) {
     }
 }

src/Projection/Projectionist/DefaultProjectionist.php

@@ -63,11 +63,11 @@ public function boot(
                 $projection->id()->toString(),
             ));
 
-            $createMethod = $this->projectorResolver->resolveCreateMethod($projector);
+            $setupMethod = $this->projectorResolver->resolveSetupMethod($projector);
 
-            if (!$createMethod) {
+            if (!$setupMethod) {
                 $this->logger?->info(sprintf(
-                    'projector "%s" for "%s" has no create method',
+                    'projector "%s" for "%s" has no "setup" method',
                     $projector::class,
                     $projection->id()->toString(),
                 ));
@@ -76,7 +76,7 @@ public function boot(
             }
 
             try {
-                $createMethod();
+                $setupMethod();
                 $this->logger?->info(sprintf(
                     'projector "%s" for "%s" prepared',
                     $projector::class,
@@ -242,11 +242,11 @@ public function teardown(ProjectionCriteria $criteria = new ProjectionCriteria()
                 continue;
             }
 
-            $dropMethod = $this->projectorResolver->resolveDropMethod($projector);
+            $teardownMethod = $this->projectorResolver->resolveTeardownMethod($projector);
 
-            if ($dropMethod) {
+            if ($teardownMethod) {
                 try {
-                    $dropMethod();
+                    $teardownMethod();
                 } catch (Throwable $e) {
                     $this->logger?->error(
                         sprintf('projection for "%s" could not be removed, skipped', $projection->id()->toString()),
@@ -281,9 +281,9 @@ public function remove(ProjectionCriteria $criteria = new ProjectionCriteria()):
                 continue;
             }
 
-            $dropMethod = $this->projectorResolver->resolveDropMethod($projector);
+            $teardownMethod = $this->projectorResolver->resolveTeardownMethod($projector);
 
-            if (!$dropMethod) {
+            if (!$teardownMethod) {
                 $this->projectionStore->remove($projection->id());
 
                 $this->logger?->info(
@@ -294,11 +294,11 @@ public function remove(ProjectionCriteria $criteria = new ProjectionCriteria()):
             }
 
             try {
-                $dropMethod();
+                $teardownMethod();
             } catch (Throwable $e) {
                 $this->logger?->error(
                     sprintf(
-                        'projector "%s" drop method could not be executed:',
+                        'projector "%s" teardown method could not be executed:',
                         $projector::class,
                     ),
                 );

src/Projection/Projector/MetadataProjectorResolver.php

@@ -19,10 +19,10 @@ public function __construct(
     ) {
     }
 
-    public function resolveCreateMethod(object $projector): Closure|null
+    public function resolveSetupMethod(object $projector): Closure|null
     {
         $metadata = $this->metadataFactory->metadata($projector::class);
-        $method = $metadata->createMethod;
+        $method = $metadata->setupMethod;
 
         if (!$method) {
             return null;
@@ -31,10 +31,10 @@ public function resolveCreateMethod(object $projector): Closure|null
         return $projector->$method(...);
     }
 
-    public function resolveDropMethod(object $projector): Closure|null
+    public function resolveTeardownMethod(object $projector): Closure|null
     {
         $metadata = $this->metadataFactory->metadata($projector::class);
-        $method = $metadata->dropMethod;
+        $method = $metadata->teardownMethod;
 
         if (!$method) {
             return null;

src/Projection/Projector/ProjectorResolver.php

@@ -10,9 +10,9 @@
 
 interface ProjectorResolver
 {
-    public function resolveCreateMethod(object $projector): Closure|null;
+    public function resolveSetupMethod(object $projector): Closure|null;
 
-    public function resolveDropMethod(object $projector): Closure|null;
+    public function resolveTeardownMethod(object $projector): Closure|null;
 
     public function resolveSubscribeMethod(object $projector, Message $message): Closure|null;
 

tests/Benchmark/BasicImplementation/Projection/ProfileProjector.php

@@ -5,10 +5,10 @@
 namespace Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Projection;
 
 use Doctrine\DBAL\Connection;
-use Patchlevel\EventSourcing\Attribute\Create;
-use Patchlevel\EventSourcing\Attribute\Drop;
 use Patchlevel\EventSourcing\Attribute\Projector;
+use Patchlevel\EventSourcing\Attribute\Setup;
 use Patchlevel\EventSourcing\Attribute\Subscribe;
+use Patchlevel\EventSourcing\Attribute\Teardown;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events\ProfileCreated;
 
@@ -22,13 +22,13 @@ public function __construct(
     ) {
     }
 
-    #[Create]
+    #[Setup]
     public function create(): void
     {
         $this->connection->executeStatement('CREATE TABLE IF NOT EXISTS projection_profile (id VARCHAR PRIMARY KEY, name VARCHAR);');
     }
 
-    #[Drop]
+    #[Teardown]
     public function drop(): void
     {
         $this->connection->executeStatement('DROP TABLE IF EXISTS projection_profile;');

tests/Integration/BankAccountSplitStream/IntegrationTest.php

@@ -23,7 +23,7 @@
 use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Events\BalanceAdded;
 use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Events\BankAccountCreated;
 use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Events\MonthPassed;
-use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Projection\BankAccountProjection;
+use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Projection\BankAccountProjector;
 use Patchlevel\EventSourcing\Tests\Integration\DbalManager;
 use PHPUnit\Framework\TestCase;
 use Symfony\Component\Lock\LockFactory;
@@ -55,8 +55,8 @@ public function testSuccessful(): void
             'eventstore',
         );
 
-        $bankAccountProjection = new BankAccountProjection($this->connection);
-        $projectionRepository = new InMemoryProjectorRepository([$bankAccountProjection]);
+        $bankAccountProjector = new BankAccountProjector($this->connection);
+        $projectionRepository = new InMemoryProjectorRepository([$bankAccountProjector]);
 
         $projectionist = new DefaultProjectionist(
             $store,

tests/Integration/BankAccountSplitStream/Projection/BankAccountProjection.php → tests/Integration/BankAccountSplitStream/Projection/BankAccountProjector.php

@@ -6,23 +6,25 @@
 
 use Doctrine\DBAL\Connection;
 use Doctrine\DBAL\Schema\Table;
-use Patchlevel\EventSourcing\Attribute\Create;
-use Patchlevel\EventSourcing\Attribute\Drop;
 use Patchlevel\EventSourcing\Attribute\Projector;
+use Patchlevel\EventSourcing\Attribute\Setup;
 use Patchlevel\EventSourcing\Attribute\Subscribe;
+use Patchlevel\EventSourcing\Attribute\Teardown;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Events\BalanceAdded;
 use Patchlevel\EventSourcing\Tests\Integration\BankAccountSplitStream\Events\BankAccountCreated;
 
+use function assert;
+
 #[Projector('dummy', 1)]
-final class BankAccountProjection
+final class BankAccountProjector
 {
     public function __construct(
         private Connection $connection,
     ) {
     }
 
-    #[Create]
+    #[Setup]
     public function create(): void
     {
         $table = new Table('projection_bank_account');
@@ -34,7 +36,7 @@ public function create(): void
         $this->connection->createSchemaManager()->createTable($table);
     }
 
-    #[Drop]
+    #[Teardown]
     public function drop(): void
     {
         $this->connection->createSchemaManager()->dropTable('projection_bank_account');
@@ -45,6 +47,8 @@ public function handleBankAccountCreated(Message $message): void
     {
         $event = $message->event();
 
+        assert($event instanceof BankAccountCreated);
+
         $this->connection->executeStatement(
             'INSERT INTO projection_bank_account (id, name, balance_in_cents) VALUES(:id, :name, 0);',
             [
@@ -59,6 +63,8 @@ public function handleBalanceAdded(Message $message): void
     {
         $event = $message->event();
 
+        assert($event instanceof BalanceAdded);
+
         $this->connection->executeStatement(
             'UPDATE projection_bank_account SET balance_in_cents = balance_in_cents + :balance WHERE id = :id;',
             [