TreeHouse\QueueBundle\DependencyInjection\Compiler\RegisterFlushersPass::process()

Complexity

Conditions	5
Paths	7

Size

Total Lines	24
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	14
CRAP Score	5

Importance

Changes

0

<?php
    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)]);
        }
    }
}