Implement CommandBus

composer.json

@@ -22,7 +22,7 @@
     ],
     "require": {
         "php": "^8.3",
-        "gember/dependency-contracts": "^0.1",
+        "gember/dependency-contracts": "^0.2",
         "symfony/messenger": "^7.1"
     },
     "require-dev": {

src/SymfonyCommandBus.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony;
+
+use Gember\DependencyContracts\Util\Messaging\MessageBus\CommandBus;
+use Gember\DependencyContracts\Util\Messaging\MessageBus\HandlingMessageFailedException;
+use Symfony\Component\Messenger\Exception\ExceptionInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+use Override;
+
+final readonly class SymfonyCommandBus implements CommandBus
+{
+    public function __construct(
+        private MessageBusInterface $commandBus,
+    ) {}
+
+    #[Override]
+    public function handle(object $command): void
+    {
+        try {
+            $this->commandBus->dispatch($command);
+        } catch (ExceptionInterface $exception) {
+            throw HandlingMessageFailedException::withException($exception);
+        }
+    }
+}

tests/SymfonyCommandBusTest.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test;
+
+use Gember\DependencyContracts\Util\Messaging\MessageBus\HandlingMessageFailedException;
+use Gember\MessageBusSymfony\SymfonyCommandBus;
+use Gember\MessageBusSymfony\Test\TestDoubles\TestCommand;
+use Gember\MessageBusSymfony\Test\TestDoubles\TestCommandThrowingException;
+use Gember\MessageBusSymfony\Test\TestDoubles\TestSymfonyCommandBus;
+use PHPUnit\Framework\Attributes\Test;
+use PHPUnit\Framework\TestCase;
+
+/**
+ * @internal
+ */
+final class SymfonyCommandBusTest extends TestCase
+{
+    private SymfonyCommandBus $commandBus;
+    private TestSymfonyCommandBus $symfonyCommandBus;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->commandBus = new SymfonyCommandBus(
+            $this->symfonyCommandBus = new TestSymfonyCommandBus(),
+        );
+    }
+
+    #[Test]
+    public function itShouldHandleCommand(): void
+    {
+        $this->commandBus->handle(new TestCommand());
+
+        self::assertTrue($this->symfonyCommandBus->isCalled);
+    }
+
+    #[Test]
+    public function itShouldThrowExceptionWhenHandlingCommandFailed(): void
+    {
+        self::expectException(HandlingMessageFailedException::class);
+
+        $this->commandBus->handle(new TestCommandThrowingException());
+    }
+}

tests/TestDoubles/TestCommand.php

@@ -0,0 +1,7 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test\TestDoubles;
+
+final readonly class TestCommand {}

tests/TestDoubles/TestCommandThrowingException.php

@@ -0,0 +1,7 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\MessageBusSymfony\Test\TestDoubles;
+
+final readonly class TestCommandThrowingException {}

tests/TestDoubles/TestSymfonyCommandBus.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 TestSymfonyCommandBus implements MessageBusInterface
+{
+    public bool $isCalled;
+
+    public function dispatch(object $message, array $stamps = []): Envelope
+    {
+        $this->isCalled = true;
+
+        if ($message instanceof TestCommandThrowingException) {
+            throw new class extends Exception implements ExceptionInterface {};
+        }
+
+        return new Envelope($message);
+    }
+}