Add SymfonyEventBus implementation

jerowork · jerowork · commit c698b5d43d6b · 2024-10-07T20:04:11.000+02:00
diff --git a/src/SymfonyEventBus.php b/src/SymfonyEventBus.php
@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony;
+
+use Gember\EventSourcing\Util\Messaging\MessageBus\EventBus;
+use Gember\EventSourcing\Util\Messaging\MessageBus\HandlingMessageFailedException;
+use Symfony\Component\Messenger\Exception\ExceptionInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+final readonly class SymfonyEventBus implements EventBus
+{
+    public function __construct(
+        private MessageBusInterface $eventBus,
+    ) {}
+
+    public function handle(object $event): void
+    {
+        try {
+            $this->eventBus->dispatch($event);
+        } catch (ExceptionInterface $exception) {
+            throw HandlingMessageFailedException::withException($exception);
+        }
+    }
+}
diff --git a/tests/SymfonyEventBusTest.php b/tests/SymfonyEventBusTest.php
@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test;
+
+use Gember\EventSourcing\Util\Messaging\MessageBus\HandlingMessageFailedException;
+use Gember\MessageBusSymfony\SymfonyEventBus;
+use Gember\MessageBusSymfony\Test\TestDoubles\TestEvent;
+use Gember\MessageBusSymfony\Test\TestDoubles\TestEventThrowingException;
+use Gember\MessageBusSymfony\Test\TestDoubles\TestSymfonyEventBus;
+use PHPUnit\Framework\Attributes\Test;
+use PHPUnit\Framework\TestCase;
+
+/**
+ * @internal
+ */
+final class SymfonyEventBusTest extends TestCase
+{
+    private SymfonyEventBus $eventBus;
+    private TestSymfonyEventBus $symfonyEventBus;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->eventBus = new SymfonyEventBus(
+            $this->symfonyEventBus = new TestSymfonyEventBus(),
+        );
+    }
+
+    #[Test]
+    public function itShouldHandleEvent(): void
+    {
+        $this->eventBus->handle(new TestEvent());
+
+        self::assertTrue($this->symfonyEventBus->isCalled);
+    }
+
+    #[Test]
+    public function itShouldThrowExceptionWhenHandlingEventFailed(): void
+    {
+        self::expectException(HandlingMessageFailedException::class);
+
+        $this->eventBus->handle(new TestEventThrowingException());
+    }
+}
diff --git a/tests/TestDoubles/TestEvent.php b/tests/TestDoubles/TestEvent.php
@@ -0,0 +1,7 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test\TestDoubles;
+
+final readonly class TestEvent {}
diff --git a/tests/TestDoubles/TestEventThrowingException.php b/tests/TestDoubles/TestEventThrowingException.php
@@ -0,0 +1,7 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test\TestDoubles;
+
+final readonly class TestEventThrowingException {}
diff --git a/tests/TestDoubles/TestSymfonyEventBus.php b/tests/TestDoubles/TestSymfonyEventBus.php
@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test\TestDoubles;
+
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Exception\ExceptionInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+use Exception;
+
+final class TestSymfonyEventBus implements MessageBusInterface
+{
+    public bool $isCalled;
+
+    public function dispatch(object $message, array $stamps = []): Envelope
+    {
+        $this->isCalled = true;
+
+        if ($message instanceof TestEventThrowingException) {
+            throw new class extends Exception implements ExceptionInterface {};
+        }
+
+        return new Envelope($message);
+    }
+}
