Added Tactician CommandBus Tests and Exception wrapping.

Author: boekkooi-fresh

composer.json

@@ -23,7 +23,8 @@
     "jms/serializer": "^1.1",
     "predis/predis": "^1.0",
     "mongodb/mongodb": "^1.0.0",
-    "doctrine/dbal": "^2.5"
+    "doctrine/dbal": "^2.5",
+    "league/tactician": "^1.0"
   },
   "autoload": {
     "psr-4": {

src/CommandBus/TacticianCommandBus.php

@@ -2,7 +2,10 @@
 
 namespace HelloFresh\Engine\CommandBus;
 
+use HelloFresh\Engine\CommandBus\Exception\CanNotInvokeHandlerException;
+use HelloFresh\Engine\CommandBus\Exception\MissingHandlerException;
 use League\Tactician\CommandBus;
+use League\Tactician\Exception as TacticianException;
 
 class TacticianCommandBus implements CommandBusInterface
 {
@@ -25,6 +28,12 @@ public function __construct(CommandBus $commandBus)
      */
     public function execute($command)
     {
-        $this->commandBus->handle($command);
+        try {
+            $this->commandBus->handle($command);
+        } catch (TacticianException\MissingHandlerException $e) {
+            throw new MissingHandlerException($e->getMessage(), $e->getCode(), $e);
+        } catch (TacticianException\CanNotInvokeHandlerException $e) {
+            throw new CanNotInvokeHandlerException($e->getMessage(), $e->getCode(), $e);
+        }
     }
 }

tests/CommandBus/TacticianCommandBusTest.php

@@ -0,0 +1,99 @@
+<?php
+
+namespace HelloFresh\Tests\Engine\CommandBus;
+
+use HelloFresh\Engine\CommandBus\TacticianCommandBus;
+use HelloFresh\Tests\Engine\Mock\InvalidHandler;
+use HelloFresh\Tests\Engine\Mock\TestCommand;
+use HelloFresh\Tests\Engine\Mock\TestHandler;
+use League\Tactician\CommandBus;
+use League\Tactician\Handler\CommandHandlerMiddleware;
+use League\Tactician\Handler\CommandNameExtractor\ClassNameExtractor;
+use League\Tactician\Handler\Locator\HandlerLocator;
+use League\Tactician\Handler\Locator\InMemoryLocator;
+use League\Tactician\Handler\MethodNameInflector\HandleInflector;
+use League\Tactician\Plugins\LockingMiddleware;
+
+class TacticianCommandBusTest extends \PHPUnit_Framework_TestCase
+{
+    /**
+     * @var InMemoryLocator
+     */
+    private $locator;
+    /**
+     * @var CommandBus
+     */
+    private $internalCommandBus;
+    /**
+     * @var TacticianCommandBus
+     */
+    private $commandBus;
+
+    protected function setUp()
+    {
+        $this->locator = new InMemoryLocator();
+        $this->internalCommandBus = self::createASimpleBus($this->locator);
+
+        $this->commandBus = new TacticianCommandBus($this->internalCommandBus);
+    }
+
+    /**
+     * @test
+     */
+    public function itExecutesAMessage()
+    {
+        $handler = new TestHandler();
+        $this->locator->addHandler($handler, TestCommand::class);
+
+        $command = new TestCommand("hey");
+        $this->commandBus->execute($command);
+        $this->commandBus->execute($command);
+        $this->commandBus->execute($command);
+
+        $this->assertSame(3, $handler->getCounter());
+    }
+
+    /**
+     * @test
+     * @expectedException \HelloFresh\Engine\CommandBus\Exception\MissingHandlerException
+     */
+    public function itFailsWhenThereIsNoHandlers()
+    {
+        $command = new TestCommand("hey");
+        $this->commandBus->execute($command);
+
+        $handler = new TestHandler();
+        $this->assertSame(0, $handler->getCounter());
+    }
+
+    /**
+     * @test
+     * @expectedException \HelloFresh\Engine\CommandBus\Exception\CanNotInvokeHandlerException
+     */
+    public function itFailsWhenHandlerHasAnInvalidHandleMethod()
+    {
+        $handler = new InvalidHandler();
+        $this->locator->addHandler($handler, TestCommand::class);
+
+        $command = new TestCommand("hey");
+        $this->commandBus->execute($command);
+    }
+
+    /**
+     * Create a tactician command bus that uses the same convention as SimpleCommandBus.
+     *
+     * @param HandlerLocator $commandLocator
+     * @return CommandBus
+     */
+    public static function createASimpleBus(HandlerLocator $commandLocator)
+    {
+        return new CommandBus([
+            new LockingMiddleware(),
+            new CommandHandlerMiddleware(
+                new ClassNameExtractor(),
+                $commandLocator,
+                new HandleInflector()
+            )
+        ]);
+    }
+}