Tactics\CommandBusBundle\CommandBus\SimpleCommandBus

Complexity

Total Complexity

9

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	registerHandler()	0	5	1
A	getHandlers()	0	4	1
A	handle()	0	10	2
A	guardAgainstDuplicateHandlers()	0	6	2
A	findHandler()	0	6	2

<?php

namespace Tactics\CommandBusBundle\CommandBus;

use Tactics\CommandBusBundle\Command\Command;
use Tactics\CommandBusBundle\CommandHandler\CommandHandler;
use Tactics\CommandBusBundle\Exception\DuplicateHandlerException;
use Tactics\CommandBusBundle\NamingStrategy\NamingStrategy;

/**
 * Class SimpleCommandBus
 * @package Tactics\CommandBusBundle\CommandBus
 */
class SimpleCommandBus implements CommandBus
{
    /**
     * @var array
     */
    private $handlers = [];

    /**
     * @var \Tactics\CommandBusBundle\NamingStrategy\NamingStrategy
     */
    private $namingStrategy;

    /**e
     * @param NamingStrategy $namingStrategy
     */
    public function __construct(NamingStrategy $namingStrategy)
    {
        $this->namingStrategy = $namingStrategy;
    }

    /**
     * @inheritDoc
     */
    public function registerHandler(CommandHandler $handler)
    {
        $this->guardAgainstDuplicateHandlers($handler);
        $this->handlers[$this->namingStrategy->getCommandHandlerName($handler)] = $handler;
    }

    /**
     * @inheritDoc
     */
    public function getHandlers()
    {
        return $this->handlers;
    }

    /**
     * @inheritDoc
     */
    public function handle(Command $command)
    {
        $handler = $this->findHandler($this->namingStrategy->getCommandName($command));

        if (! $handler) {
            return;
        }

        $handler->handle($command);
    }

    /**
     * @param CommandHandler $handler
     * @throws DuplicateHandlerException
     */
    private function guardAgainstDuplicateHandlers(CommandHandler $handler)
    {
        if ($this->findHandler($this->namingStrategy->getCommandHandlerName($handler))) {
            throw new DuplicateHandlerException($handler);
        }
    }

    /**
     * @param string $needle
     * @return CommandHandler
     */
    private function findHandler($needle)
    {
        return array_key_exists($needle, $this->handlers)
            ? $this->handlers[$needle]
            : null;
    }
}