Happyr\Mq2phpBundle\DependencyInjection\Compiler\RegisterConsumers

Complexity

Total Complexity

4

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

75%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	5	1
A	replaceArgumentWithReference()	0	15	3

<?php

namespace Happyr\Mq2phpBundle\DependencyInjection\Compiler;

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

/**
 * Register the message bus argument to our consumer.
 *
 * @author Tobias Nyholm <tobias.nyholm@gmail.com>
 */
class RegisterConsumers implements CompilerPassInterface
{
    /**
     * @param ContainerBuilder $container
     */
    public function process(ContainerBuilder $container)
    {
        $this->replaceArgumentWithReference($container, 'happyr.mq2php.extendable_command_envelope_consumer', 'simple_bus.asynchronous.command_bus');
        $this->replaceArgumentWithReference($container, 'happyr.mq2php.extendable_event_envelope_consumer', 'simple_bus.asynchronous.event_bus');
    }

    /**
     * @param ContainerBuilder $container
     * @param string           $serviceId
     * @param string           $referenceId
     */
    private function replaceArgumentWithReference(ContainerBuilder $container, $serviceId, $referenceId)
    {
        if (!$container->hasDefinition($serviceId)) {
            return;
        }

        // If there is not $referenceId the $service has no use
        if (!$container->hasDefinition($referenceId)) {
            $container->removeDefinition($serviceId);

            return;
        }

        $container->getDefinition($serviceId)->replaceArgument(1, new Reference($referenceId));
    }
}