League\Tactician\Bundle\Tests\DependencyInjection\Compiler\CommandHandlerPassTest

Complexity

Total Complexity

10

Size/Duplication

Total Lines	163
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	testProcess()	0	14	1
A	testProcessAbortsOnMissingCommandAttribute()	0	8	1
A	testProcessAbortsOnInvalidBus()	0	10	1
B	testProcessAddsLocatorAndHandlerDefinitionForTaggedBuses()	0	38	1
A	testProcessAddsHandlerDefinitionWithNonDefaultMethodNameInflector()	0	20	1
B	busShouldBeCorrectlyRegisteredInContainer()	0	40	3
A	getContainer()	0	16	2

<?php

namespace League\Tactician\Bundle\Tests\DependencyInjection\Compiler;

use League\Tactician\Bundle\DependencyInjection\Compiler\CommandHandlerPass;
use League\Tactician\Bundle\Handler\ContainerBasedHandlerLocator;
use League\Tactician\Container\ContainerLocator;
use PHPUnit\Framework\TestCase;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\ServiceLocator;

class CommandHandlerPassTest extends TestCase
{
    public function testProcess()
    {
        $container = $this->getContainer(['default'], 'default');
        $container->register('handler_1')->addTag('tactician.handler', ['command' => 'my_command']);
        $container->register('handler_2')->addTag('tactician.handler', ['command' => 'my_command']);

        (new CommandHandlerPass())->process($container);

        $this->busShouldBeCorrectlyRegisteredInContainer(
            $container,
            'default',
            'tactician.handler.method_name_inflector.handle'
        );
    }

    /**
     * @expectedException        \Exception
     * @expectedExceptionMessage The tactician.handler tag must always have a command attribute
     */
    public function testProcessAbortsOnMissingCommandAttribute()
    {
        $container = $this->getContainer(['default'], 'default');
        $container->register('handler_1')->addTag('tactician.handler', ['command' => 'my_command']);
        $container->register('handler_2')->addTag('tactician.handler', ['not_command' => 'my_command']);

        (new CommandHandlerPass())->process($container);
    }

    /**
     * @expectedException        \Exception
     * @expectedExceptionMessage Invalid bus id "bad_bus".
     */
    public function testProcessAbortsOnInvalidBus()
    {
        $container = $this->getContainer(['default'], 'default');

        $container
            ->register('handler_1')
            ->addTag('tactician.handler', ['command' => 'my_command', 'bus' => 'bad_bus']);

        (new CommandHandlerPass())->process($container);
    }

    public function testProcessAddsLocatorAndHandlerDefinitionForTaggedBuses()
    {
        $container = $this->getContainer(['default', 'custom_bus', 'other_bus'], 'custom_bus');
        $container->setParameter(
            'tactician.method_inflector.custom_bus',
            'tactician.handler.method_name_inflector.handle'
        );
        $container->setParameter(
            'tactician.method_inflector.other_bus',
            'tactician.handler.method_name_inflector.handle'
        );

        $container
            ->register('handler_1')
            ->addTag('tactician.handler', ['command' => 'my_command', 'bus' => 'custom_bus'])
            ->addTag('tactician.handler', ['command' => 'my_command', 'bus' => 'other_bus']);


        (new CommandHandlerPass())->process($container);

        $this->busShouldBeCorrectlyRegisteredInContainer(
            $container,
            'default',
            'tactician.handler.method_name_inflector.handle'
        );

        $this->busShouldBeCorrectlyRegisteredInContainer(
            $container,
            'custom_bus',
            'tactician.handler.method_name_inflector.handle'
        );

        $this->busShouldBeCorrectlyRegisteredInContainer(
            $container,
            'other_bus',
            'tactician.handler.method_name_inflector.handle'
        );
    }

    public function testProcessAddsHandlerDefinitionWithNonDefaultMethodNameInflector()
    {
        $container = $this->getContainer(['default', 'custom_bus'], 'custom_bus');
        $container->setParameter(
            'tactician.method_inflector.custom_bus',
            'tactician.handler.method_name_inflector.handle_class_name'
        );

        $container
            ->register('handler_1')
            ->addTag('tactician.handler', ['command' => 'my_command', 'bus' => 'custom_bus']);

        (new CommandHandlerPass())->process($container);

        $this->busShouldBeCorrectlyRegisteredInContainer(
            $container,
            'custom_bus',
            'tactician.handler.method_name_inflector.handle_class_name'
        );
    }

    private function busShouldBeCorrectlyRegisteredInContainer(ContainerBuilder $container, $busId, $methodInflector)
    {
        $handlerLocatorId = sprintf('tactician.commandbus.%s.handler.locator', $busId);
        $handlerId = sprintf('tactician.commandbus.%s.middleware.command_handler', $busId);
        $defaultHandlerId = sprintf('tactician.commandbus.%s.middleware.command_handler', $container->getParameter('tactician.commandbus.default'));
        $defaultHandlerLocatorId = sprintf('tactician.commandbus.%s.handler.locator', $container->getParameter('tactician.commandbus.default'));

        if (class_exists(ServiceLocator::class)) {
            $this->assertSame(
                ServiceLocator::class,
                $container ->getDefinition(
                    sprintf('tactician.commandbus.%s.handler.service_locator', $busId)
                )->getClass()
            );
        }

        $this->assertSame(
            class_exists(ServiceLocator::class)
                ? ContainerLocator::class
                : ContainerBasedHandlerLocator::class,
            $container->getDefinition($handlerLocatorId)->getClass()
        );

        $this->assertSame(
            $methodInflector,
            (string) $container
                ->getDefinition($handlerId)
                ->getArgument(2)
        );

        $this->assertSame(
            $defaultHandlerLocatorId,
            (string) $container->getAlias('tactician.handler.locator.symfony')
        );

        $this->assertSame(
            $defaultHandlerId,
            (string) $container->getAlias('tactician.middleware.command_handler')
        );
    }

    private function getContainer(array $busIds, $defaultBus)
    {
        $container = new ContainerBuilder();
        $container->setParameter('tactician.commandbus.ids', $busIds);
        $container->setParameter('tactician.commandbus.default', $defaultBus);
        $container->setParameter(
            'tactician.method_inflector.default',
            'tactician.handler.method_name_inflector.handle'
        );

        foreach ($busIds as $busId) {
            $container->register('tactician.commandbus.'.$busId)->addArgument(array());
        }

        return $container;
    }
}