allow subscribe all

src/Attribute/Subscribe.php

@@ -9,7 +9,9 @@
 #[Attribute(Attribute::TARGET_METHOD | Attribute::IS_REPEATABLE)]
 final class Subscribe
 {
-    /** @param class-string $eventClass */
+    public const ALL = '*';
+
+    /** @param class-string|'*' $eventClass */
     public function __construct(
         public readonly string $eventClass,
     ) {

src/EventBus/AttributeListenerProvider.php

@@ -7,6 +7,8 @@
 use Patchlevel\EventSourcing\Attribute\Subscribe;
 use ReflectionClass;
 
+use function array_merge;
+
 final class AttributeListenerProvider implements ListenerProvider
 {
     /** @var array<string, list<ListenerDescriptor>>|null */
@@ -22,7 +24,10 @@ public function __construct(
     public function listenersForEvent(object $event): iterable
     {
         if ($this->subscribeMethods !== null) {
-            return $this->subscribeMethods[$event::class] ?? [];
+            return array_merge(
+                $this->subscribeMethods[$event::class] ?? [],
+                $this->subscribeMethods['*'] ?? [],
+            );
         }
 
         $this->subscribeMethods = [];
@@ -45,6 +50,9 @@ public function listenersForEvent(object $event): iterable
             }
         }
 
-        return $this->subscribeMethods[$event::class] ?? [];
+        return array_merge(
+            $this->subscribeMethods[$event::class] ?? [],
+            $this->subscribeMethods['*'] ?? [],
+        );
     }
 }

src/Metadata/Projector/AttributeProjectorMetadataFactory.php

@@ -47,6 +47,13 @@ public function metadata(string $projector): ProjectorMetadata
                 $instance = $attribute->newInstance();
                 $eventClass = $instance->eventClass;
 
+                if ($eventClass === '*') {
+                    throw new SubscribeAllNotSupported(
+                        $projector,
+                        $method->getName(),
+                    );
+                }
+
                 if (array_key_exists($eventClass, $subscribeMethods)) {
                     throw new DuplicateSubscribeMethod(
                         $projector,

src/Metadata/Projector/SubscribeAllNotSupported.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Metadata\Projector;
+
+use Patchlevel\EventSourcing\Metadata\MetadataException;
+
+use function sprintf;
+
+final class SubscribeAllNotSupported extends MetadataException
+{
+    /** @param class-string $projector */
+    public function __construct(string $projector, string $method)
+    {
+        parent::__construct(
+            sprintf(
+                'subscribe all (*) not supported in projector "%s" method "%s"',
+                $projector,
+                $method,
+            ),
+        );
+    }
+}

src/WatchServer/WatchListener.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\WatchServer;
+
+use Patchlevel\EventSourcing\Attribute\Subscribe;
+use Patchlevel\EventSourcing\EventBus\Message;
+
+final class WatchListener
+{
+    public function __construct(
+        private readonly WatchServerClient $client,
+    ) {
+    }
+
+    #[Subscribe('*')]
+    public function __invoke(Message $message): void
+    {
+        try {
+            $this->client->send($message);
+        } catch (SendingFailed) {
+            // to nothing
+        }
+    }
+}

tests/Unit/EventBus/AttributeListenerProviderTest.php

@@ -112,4 +112,54 @@ public function __invoke(Message $message): void
             new ListenerDescriptor($listener2->__invoke(...)),
         ], $listeners);
     }
+
+    public function testSubscribeAll(): void
+    {
+        $listener = new class {
+            #[Subscribe('*')]
+            public function __invoke(Message $message): void
+            {
+            }
+        };
+
+        $event = new ProfileCreated(
+            ProfileId::fromString('1'),
+            Email::fromString('[email protected]'),
+        );
+
+        $eventBus = new AttributeListenerProvider([$listener]);
+        $listeners = $eventBus->listenersForEvent($event);
+
+        self::assertEquals([
+            new ListenerDescriptor($listener->__invoke(...)),
+        ], $listeners);
+    }
+
+    public function testMixedSubscribeTypes(): void
+    {
+        $listener = new class {
+            #[Subscribe('*')]
+            public function foo(Message $message): void
+            {
+            }
+
+            #[Subscribe(ProfileCreated::class)]
+            public function bar(Message $message): void
+            {
+            }
+        };
+
+        $event = new ProfileCreated(
+            ProfileId::fromString('1'),
+            Email::fromString('[email protected]'),
+        );
+
+        $eventBus = new AttributeListenerProvider([$listener]);
+        $listeners = $eventBus->listenersForEvent($event);
+
+        self::assertEquals([
+            new ListenerDescriptor($listener->bar(...)),
+            new ListenerDescriptor($listener->foo(...)),
+        ], $listeners);
+    }
 }

tests/Unit/WatchServer/WatchEventBusWrapperTest.php → tests/Unit/WatchServer/WatchListenerTest.php

@@ -4,54 +4,39 @@
 
 namespace Patchlevel\EventSourcing\Tests\Unit\WatchServer;
 
-use Patchlevel\EventSourcing\EventBus\EventBus;
 use Patchlevel\EventSourcing\EventBus\Message;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
 use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileVisited;
 use Patchlevel\EventSourcing\WatchServer\SendingFailed;
-use Patchlevel\EventSourcing\WatchServer\WatchEventBusWrapper;
+use Patchlevel\EventSourcing\WatchServer\WatchListener;
 use Patchlevel\EventSourcing\WatchServer\WatchServerClient;
 use PHPUnit\Framework\TestCase;
 use Prophecy\PhpUnit\ProphecyTrait;
 
-/** @covers \Patchlevel\EventSourcing\WatchServer\WatchEventBusWrapper */
-final class WatchEventBusWrapperTest extends TestCase
+/** @covers \Patchlevel\EventSourcing\WatchServer\WatchListener */
+final class WatchListenerTest extends TestCase
 {
     use ProphecyTrait;
 
-    public function testWrapper(): void
+    public function testListener(): void
     {
         $message = new Message(new ProfileVisited(ProfileId::fromString('1')));
 
-        $eventBus = $this->prophesize(EventBus::class);
-        $eventBus->dispatch($message)->shouldBeCalled();
-
         $client = $this->prophesize(WatchServerClient::class);
         $client->send($message)->shouldBeCalled();
 
-        $wrapper = new WatchEventBusWrapper(
-            $eventBus->reveal(),
-            $client->reveal(),
-        );
-
-        $wrapper->dispatch($message);
+        $listener = new WatchListener($client->reveal());
+        $listener->__invoke($message);
     }
 
     public function testIgnoreErrors(): void
     {
         $message = new Message(new ProfileVisited(ProfileId::fromString('1')));
 
-        $eventBus = $this->prophesize(EventBus::class);
-        $eventBus->dispatch($message)->shouldBeCalled();
-
         $client = $this->prophesize(WatchServerClient::class);
         $client->send($message)->shouldBeCalled()->willThrow(SendingFailed::class);
 
-        $wrapper = new WatchEventBusWrapper(
-            $eventBus->reveal(),
-            $client->reveal(),
-        );
-
-        $wrapper->dispatch($message);
+        $listener = new WatchListener($client->reveal());
+        $listener->__invoke($message);
     }
 }