TreeHouse\QueueBundle\DependencyInjection\Compiler\RegisterFlushersPass

Complexity

Total Complexity

5

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	process()	0	24	5

<?php

namespace TreeHouse\QueueBundle\DependencyInjection\Compiler;

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

class RegisterFlushersPass implements CompilerPassInterface
{
    /**
     * @inheritdoc
     */
    public function process(ContainerBuilder $container)
    {
        if (!$container->hasDefinition('tree_house.queue.event_listener.flush')) {
            return;
        }

        $listener = $container->getDefinition('tree_house.queue.event_listener.flush');

        foreach (['doctrine', 'doctrine_mongodb'] as $id) {
            if ($container->hasDefinition($id)) {
                $flusherId = sprintf('tree_house.queue.flusher.%s', $id);

                $definition = new DefinitionDecorator('tree_house.queue.flusher.doctrine_abstract');
                $definition->addArgument(new Reference($id));
                $container->setDefinition($flusherId, $definition);

                $listener->addMethodCall('addFlusher', [new Reference($flusherId)]);
            }
        }

        foreach ($container->findTaggedServiceIds('tree_house.queue.flusher') as $id => list($tag)) {
            $listener->addMethodCall('addFlusher', [new Reference($id)]);
        }
    }
}