League\Tactician\Bundle\DependencyInjection\Compiler\CommandHandlerPass

Complexity

Total Complexity

11

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	12
Bugs	0	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
B	process()	0	43	6
A	getDefaultBusId()	0	6	1
A	abortIfInvalidBusId()	0	8	2
A	buildLocatorDefinition()	0	10	1
A	buildCommandHandlerDefinition()	0	13	1

<?php
namespace League\Tactician\Bundle\DependencyInjection\Compiler;

use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Reference;

/**
 * This compiler pass maps Handler DI tags to specific commands
 */
class CommandHandlerPass implements CompilerPassInterface
{
    /**
     * You can modify the container here before it is dumped to PHP code.
     *
     * @param ContainerBuilder $container
     *
     * @throws \Exception
     * @api
     */
    public function process(ContainerBuilder $container)
    {
        $defaultBusId = $this->getDefaultBusId($container);
        $busIdToHandlerMapping = [];

        foreach ($container->findTaggedServiceIds('tactician.handler') as $id => $tags) {

            foreach ($tags as $attributes) {
                if (!isset($attributes['command'])) {
                    throw new \Exception('The tactician.handler tag must always have a command attribute');
                }

                $busId = array_key_exists('bus', $attributes) ? $attributes['bus'] : $defaultBusId;

                $this->abortIfInvalidBusId($busId, $container);

                $busIdToHandlerMapping[$busId][$attributes['command']] = $id;
            }
        }

        foreach ($busIdToHandlerMapping as $busId => $handlerMapping) {
            $locatorServiceId = 'tactician.commandbus.'.$busId.'.handler.locator';
            $container->setDefinition(
                $locatorServiceId,
                $this->buildLocatorDefinition($handlerMapping)
            );

            $container->setDefinition(
                'tactician.commandbus.'.$busId.'.middleware.command_handler',
                $this->buildCommandHandlerDefinition($locatorServiceId, $container)
            );
        }

        $container->setAlias(
            'tactician.handler.locator.symfony',
            'tactician.commandbus.'.$defaultBusId.'.handler.locator'
        );

        $container->setAlias(
            'tactician.middleware.command_handler',
            'tactician.commandbus.'.$defaultBusId.'.middleware.command_handler'
        );
    }

    protected function getDefaultBusId(ContainerBuilder $container)
    {
        $config = $container->getExtensionConfig('tactician');

        return $config['default_bus'];
    }

    /**
     * @param string $id
     * @param ContainerBuilder $container 
     * @throws Exception
     */
    protected function abortIfInvalidBusId($id, ContainerBuilder $container)
    {
        $config = $container->getExtensionConfig('tactician');

        if (!array_key_exists($id, $config['commandbus'])) {
            throw new \Exception('Invalid bus id "'.$id.'". Valid buses are: '.implode(', ', array_keys($config['commandbus'])));
        }
    }

    /**
     * @param array $handlerMapping 
     * @return Definition
     */
    protected function buildLocatorDefinition(array $handlerMapping)
    {
        return new Definition(
            'League\Tactician\Bundle\Handler\ContainerBasedHandlerLocator',
            [
                new Reference('service_container'),
                $handlerMapping,
            ]
        );
    }

    /**
     * @param string $locatorServiceId 
     * @return Definition
     */
    protected function buildCommandHandlerDefinition($locatorServiceId, ContainerBuilder $container)
    {
        $config = $container->getExtensionConfig('tactician');

        return new Definition(
            'League\Tactician\Handler\CommandHandlerMiddleware',
            [
                new Reference('tactician.handler.command_name_extractor.class_name'),
                new Reference($locatorServiceId),
                new Reference($config['method_inflector'])
            ]
        );
    }

}