rename handle to subscribe

docs/pages/event_bus.md

@@ -163,16 +163,16 @@ final class WelcomeListener implements Listener
 ## Subscriber
 
 A `Subscriber` is a listener, except that it has implemented the invoke method itself. 
-Instead, you can define your own and multiple methods and listen for specific events with the attribute `Handle`.
+Instead, you can define your own and multiple methods and listen for specific events with the attribute `Subscribe`.
 
 ```php
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Listener;
 use Patchlevel\EventSourcing\EventBus\Message;
 
 final class WelcomeSubscriber extends Subscriber 
 {
-    #[Handle(ProfileCreated::class)]
+    #[Subscribe(ProfileCreated::class)]
     public function onProfileCreated(Message $message): void
     {
         echo 'Welcome!';

docs/pages/getting_started.md

@@ -156,7 +156,7 @@ Each projector is then responsible for a specific projection and version.
 use Doctrine\DBAL\Connection;
 use Patchlevel\EventSourcing\Attribute\Create;
 use Patchlevel\EventSourcing\Attribute\Drop;
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Projection\Projection\ProjectionId;
 use Patchlevel\EventSourcing\Projection\Projector\Projector;
@@ -181,7 +181,7 @@ final class HotelProjection implements Projector
         return $this->db->fetchAllAssociative('SELECT id, name, guests FROM hotel;')
     }
 
-    #[Handle(HotelCreated::class)]
+    #[Subscribe(HotelCreated::class)]
     public function handleHotelCreated(Message $message): void
     {
         $event = $message->event();
@@ -196,7 +196,7 @@ final class HotelProjection implements Projector
         );
     }
 
-    #[Handle(GuestIsCheckedIn::class)]
+    #[Subscribe(GuestIsCheckedIn::class)]
     public function handleGuestIsCheckedIn(Message $message): void
     {
         $this->db->executeStatement(
@@ -205,7 +205,7 @@ final class HotelProjection implements Projector
         );
     }
 
-    #[Handle(GuestIsCheckedOut::class)]
+    #[Subscribe(GuestIsCheckedOut::class)]
     public function handleGuestIsCheckedOut(Message $message): void
     {
         $this->db->executeStatement(
@@ -237,7 +237,7 @@ final class HotelProjection implements Projector
 In our example we also want to send an email to the head office as soon as a guest is checked in.
 
 ```php
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\EventBus\Subscriber;
 
@@ -248,7 +248,7 @@ final class SendCheckInEmailProcessor extends Subscriber
     ) {
     }
 
-    #[Handle(GuestIsCheckedIn::class)]
+    #[Subscribe(GuestIsCheckedIn::class)]
     public function onGuestIsCheckedIn(Message $message): void
     {
         $this->mailer->send(

docs/pages/processor.md

@@ -50,7 +50,7 @@ final class SendEmailProcessor implements Listener
 You can also create the whole thing as a subscriber too.
 
 ```php
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\EventBus\Subscriber;
 
@@ -61,7 +61,7 @@ final class SendEmailProcessor extends Subscriber
     ) {
     }
 
-    #[Handle(ProfileCreated::class)]
+    #[Subscribe(ProfileCreated::class)]
     public function onProfileCreated(Message $message): void
     {
         $this->mailer->send(

docs/pages/projection.md

@@ -17,7 +17,7 @@ In this example we always create a new data set in a relational database when a
 use Doctrine\DBAL\Connection;
 use Patchlevel\EventSourcing\Attribute\Create;
 use Patchlevel\EventSourcing\Attribute\Drop;
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Projection\Projection\ProjectionId;
 use Patchlevel\EventSourcing\Projection\Projector\Projector;
@@ -63,7 +63,7 @@ final class ProfileProjection implements Projector
         );
     }
 
-    #[Handle(ProfileCreated::class)]
+    #[Subscribe(ProfileCreated::class)]
     public function handleProfileCreated(Message $message): void
     {
         $profileCreated = $message->event();
@@ -97,8 +97,8 @@ Projectors can have one `create` and `drop` method that is executed when the pro
 In some cases it may be that no schema has to be created for the projection, as the target does it automatically.
 To do this, you must add either the `Create` or `Drop` attribute to the method. The method name itself doesn't matter.
 
-Otherwise, a projector can have any number of handle methods that are called for certain defined events.
-In order to say which method is responsible for which event, you need the `Handle` attribute.
+Otherwise, a projector can subscribe any number of events.
+In order to say which method is responsible for which event, you need the `Subscribe` attribute.
 As the first parameter, you must pass the event class to which the reaction should then take place.
 The method itself must expect a `Message`, which then contains the event. The method name itself doesn't matter.
 

src/Attribute/Handle.php → src/Attribute/Subscribe.php

@@ -7,7 +7,7 @@
 use Attribute;
 
 #[Attribute(Attribute::TARGET_METHOD | Attribute::IS_REPEATABLE)]
-final class Handle
+final class Subscribe
 {
     /** @param class-string $eventClass */
     public function __construct(

src/EventBus/DuplicateHandleMethod.php → src/EventBus/DuplicateSubscribeMethod.php

@@ -6,7 +6,7 @@
 
 use function sprintf;
 
-final class DuplicateHandleMethod extends EventBusException
+final class DuplicateSubscribeMethod extends EventBusException
 {
     /**
      * @param class-string<Subscriber> $subscriber
@@ -16,7 +16,7 @@ public function __construct(string $subscriber, string $event, string $fistMetho
     {
         parent::__construct(
             sprintf(
-                'Two methods "%s" and "%s" on the subscriber "%s" want to handle the same event "%s". Only one method can handle an event.',
+                'Two methods "%s" and "%s" on the subscriber "%s" want to subscribe the same event "%s". Only one method can subscribe an event.',
                 $fistMethod,
                 $secondMethod,
                 $subscriber,

src/EventBus/Subscriber.php

@@ -4,23 +4,23 @@
 
 namespace Patchlevel\EventSourcing\EventBus;
 
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use ReflectionClass;
 
 use function array_key_exists;
 
 abstract class Subscriber implements Listener
 {
     /** @var array<class-string, string>|null */
-    private array|null $handleMethods = null;
+    private array|null $subscribeMethods = null;
 
     final public function __invoke(Message $message): void
     {
-        if ($this->handleMethods === null) {
+        if ($this->subscribeMethods === null) {
             $this->init();
         }
 
-        $method = $this->handleMethods[$message->event()::class] ?? null;
+        $method = $this->subscribeMethods[$message->event()::class] ?? null;
 
         if (!$method) {
             return;
@@ -34,25 +34,25 @@ private function init(): void
         $reflection = new ReflectionClass(static::class);
         $methods = $reflection->getMethods();
 
-        $this->handleMethods = [];
+        $this->subscribeMethods = [];
 
         foreach ($methods as $method) {
-            $attributes = $method->getAttributes(Handle::class);
+            $attributes = $method->getAttributes(Subscribe::class);
 
             foreach ($attributes as $attribute) {
                 $instance = $attribute->newInstance();
                 $eventClass = $instance->eventClass();
 
-                if (array_key_exists($eventClass, $this->handleMethods)) {
-                    throw new DuplicateHandleMethod(
+                if (array_key_exists($eventClass, $this->subscribeMethods)) {
+                    throw new DuplicateSubscribeMethod(
                         static::class,
                         $eventClass,
-                        $this->handleMethods[$eventClass],
+                        $this->subscribeMethods[$eventClass],
                         $method->getName(),
                     );
                 }
 
-                $this->handleMethods[$eventClass] = $method->getName();
+                $this->subscribeMethods[$eventClass] = $method->getName();
             }
         }
     }

src/Metadata/Projector/AttributeProjectorMetadataFactory.php

@@ -6,7 +6,7 @@
 
 use Patchlevel\EventSourcing\Attribute\Create;
 use Patchlevel\EventSourcing\Attribute\Drop;
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\Projection\Projector\Projector;
 use ReflectionClass;
 
@@ -28,27 +28,27 @@ public function metadata(string $projector): ProjectorMetadata
 
         $methods = $reflector->getMethods();
 
-        $handleMethods = [];
+        $subscribeMethods = [];
         $createMethod = null;
         $dropMethod = null;
 
         foreach ($methods as $method) {
-            $attributes = $method->getAttributes(Handle::class);
+            $attributes = $method->getAttributes(Subscribe::class);
 
             foreach ($attributes as $attribute) {
                 $instance = $attribute->newInstance();
                 $eventClass = $instance->eventClass();
 
-                if (array_key_exists($eventClass, $handleMethods)) {
-                    throw new DuplicateHandleMethod(
+                if (array_key_exists($eventClass, $subscribeMethods)) {
+                    throw new DuplicateSubscribeMethod(
                         $projector,
                         $eventClass,
-                        $handleMethods[$eventClass],
+                        $subscribeMethods[$eventClass],
                         $method->getName(),
                     );
                 }
 
-                $handleMethods[$eventClass] = $method->getName();
+                $subscribeMethods[$eventClass] = $method->getName();
             }
 
             if ($method->getAttributes(Create::class)) {
@@ -79,7 +79,7 @@ public function metadata(string $projector): ProjectorMetadata
         }
 
         $metadata = new ProjectorMetadata(
-            $handleMethods,
+            $subscribeMethods,
             $createMethod,
             $dropMethod,
         );

src/Metadata/Projector/DuplicateHandleMethod.php → src/Metadata/Projector/DuplicateSubscribeMethod.php

@@ -9,7 +9,7 @@
 
 use function sprintf;
 
-final class DuplicateHandleMethod extends MetadataException
+final class DuplicateSubscribeMethod extends MetadataException
 {
     /**
      * @param class-string<Projector> $projector
@@ -19,7 +19,7 @@ public function __construct(string $projector, string $event, string $fistMethod
     {
         parent::__construct(
             sprintf(
-                'Two methods "%s" and "%s" on the projection "%s" want to handle the same event "%s". Only one method can handle an event.',
+                'Two methods "%s" and "%s" on the projection "%s" want to subscribe the same event "%s". Only one method can subscribe an event.',
                 $fistMethod,
                 $secondMethod,
                 $projector,

src/Metadata/Projector/ProjectorMetadata.php

@@ -8,7 +8,7 @@ final class ProjectorMetadata
 {
     public function __construct(
         /** @var array<class-string, string> */
-        public readonly array $handleMethods = [],
+        public readonly array $subscribeMethods = [],
         public readonly string|null $createMethod = null,
         public readonly string|null $dropMethod = null,
     ) {

src/Projection/Projectionist/DefaultProjectionist.php

@@ -376,11 +376,11 @@ private function handleMessage(Message $message, Projection $projection, bool $t
             throw ProjectorNotFound::forProjectionId($projection->id());
         }
 
-        $handleMethod = $this->projectorResolver->resolveHandleMethod($projector, $message);
+        $subscribeMethod = $this->projectorResolver->resolveSubscribeMethod($projector, $message);
 
-        if ($handleMethod) {
+        if ($subscribeMethod) {
             try {
-                $handleMethod($message);
+                $subscribeMethod($message);
 
                 $this->logger?->debug(
                     sprintf(

src/Projection/Projector/MetadataProjectorResolver.php

@@ -42,17 +42,17 @@ public function resolveDropMethod(Projector $projector): Closure|null
         return $projector->$method(...);
     }
 
-    public function resolveHandleMethod(Projector $projector, Message $message): Closure|null
+    public function resolveSubscribeMethod(Projector $projector, Message $message): Closure|null
     {
         $event = $message->event();
         $metadata = $this->metadataFactory->metadata($projector::class);
 
-        if (!array_key_exists($event::class, $metadata->handleMethods)) {
+        if (!array_key_exists($event::class, $metadata->subscribeMethods)) {
             return null;
         }
 
-        $handleMethod = $metadata->handleMethods[$event::class];
+        $subscribeMethod = $metadata->subscribeMethods[$event::class];
 
-        return $projector->$handleMethod(...);
+        return $projector->$subscribeMethod(...);
     }
 }

src/Projection/Projector/ProjectorHelper.php

@@ -16,13 +16,13 @@ public function __construct(
     public function handleMessage(Message $message, Projector ...$projectors): void
     {
         foreach ($projectors as $projector) {
-            $handleMethod = $this->projectorResolver->resolveHandleMethod($projector, $message);
+            $subscribeMethod = $this->projectorResolver->resolveSubscribeMethod($projector, $message);
 
-            if (!$handleMethod) {
+            if (!$subscribeMethod) {
                 continue;
             }
 
-            $handleMethod($message);
+            $subscribeMethod($message);
         }
     }
 

src/Projection/Projector/ProjectorResolver.php

@@ -13,5 +13,5 @@ public function resolveCreateMethod(Projector $projector): Closure|null;
 
     public function resolveDropMethod(Projector $projector): Closure|null;
 
-    public function resolveHandleMethod(Projector $projector, Message $message): Closure|null;
+    public function resolveSubscribeMethod(Projector $projector, Message $message): Closure|null;
 }

tests/Benchmark/BasicImplementation/Processor/SendEmailProcessor.php

@@ -4,15 +4,15 @@
 
 namespace Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Processor;
 
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\EventBus\Subscriber;
 use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Events\ProfileCreated;
 use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\SendEmailMock;
 
 final class SendEmailProcessor extends Subscriber
 {
-    #[Handle(ProfileCreated::class)]
+    #[Subscribe(ProfileCreated::class)]
     public function onProfileCreated(Message $message): void
     {
         SendEmailMock::send();

tests/Benchmark/BasicImplementation/Projection/ProfileProjector.php

@@ -7,7 +7,7 @@
 use Doctrine\DBAL\Connection;
 use Patchlevel\EventSourcing\Attribute\Create;
 use Patchlevel\EventSourcing\Attribute\Drop;
-use Patchlevel\EventSourcing\Attribute\Handle;
+use Patchlevel\EventSourcing\Attribute\Subscribe;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Projection\Projection\ProjectionId;
 use Patchlevel\EventSourcing\Projection\Projector\Projector;
@@ -39,7 +39,7 @@ public function drop(): void
         $this->connection->executeStatement('DROP TABLE IF EXISTS projection_profile;');
     }
 
-    #[Handle(ProfileCreated::class)]
+    #[Subscribe(ProfileCreated::class)]
     public function handleProfileCreated(Message $message): void
     {
         $profileCreated = $message->event();