Itmedia\CommandBusBundle\CommandBus\CommandBus

Complexity

Total Complexity

4

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addMiddleware()	0	4	1
A	handle()	0	9	2

<?php

/**
 * (c) itmedia.by <info@itmedia.by>
 */

namespace Itmedia\CommandBusBundle\CommandBus;

use Itmedia\CommandBusBundle\Command\Command;
use Itmedia\CommandBusBundle\Handler\ContainerCommandHandlerMapper;
use Itmedia\CommandBusBundle\Middleware\Middleware;

class CommandBus
{

    /**
     * @var ContainerCommandHandlerMapper
     */
    private $handlerMapper;

    /**
     * @var Middleware[]
     */
    private $middleware = [];


    /**
     * CommandBus constructor.
     *
     * @param ContainerCommandHandlerMapper $handlerMapper
     */
    public function __construct(ContainerCommandHandlerMapper $handlerMapper)
    {
        $this->handlerMapper = $handlerMapper;
    }


    /**
     * Добавить доп. обработчик команды (Middleware)
     *
     * @param Middleware $middleware
     */
    public function addMiddleware(Middleware $middleware)
    {
        $this->middleware[] = $middleware;
    }


    /**
     * Handle command
     *
     * @param Command $command
     * @throws \Itmedia\CommandBusBundle\Exception\HandlerNotFoundException
     * @throws \Symfony\Component\DependencyInjection\Exception\ServiceCircularReferenceException
     * @throws \Symfony\Component\DependencyInjection\Exception\ServiceNotFoundException
     */
    public function handle(Command $command)
    {
        foreach ($this->middleware as $middleware) {
            $middleware->handle($command);
        }

        $handler = $this->handlerMapper->get($command->commandName());
        call_user_func($handler, $command);
    }
}