Liip\MonitorBundle\DependencyInjection\Compiler\GroupRunnersCompilerPass

Complexity

Total Complexity

11

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

97.44%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getGroups()	0	13	4
A	getGroupsFromParameter()	0	13	3
A	process()	0	37	4

<?php

namespace Liip\MonitorBundle\DependencyInjection\Compiler;

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

class GroupRunnersCompilerPass implements CompilerPassInterface
{
    public function process(ContainerBuilder $container)
    {
        $noRunner = false === $container->hasDefinition('liip_monitor.runner');
        $noDefaultGroup = false === $container->hasParameter('liip_monitor.default_group');

        if ($noRunner || $noDefaultGroup) {
            return;
        }

        $definition = $container->getDefinition('liip_monitor.runner');
        $container->removeDefinition('liip_monitor.runner');

        $defaultGroup = $container->getParameter('liip_monitor.default_group');

        $checkServices = $container->findTaggedServiceIds('liip_monitor.check');
        $checkCollectionServices = $container->findTaggedServiceIds('liip_monitor.check_collection');

        $groups = array_merge(
            [$defaultGroup],
            $this->getGroups($checkServices),
            $this->getGroups($checkCollectionServices),
            $this->getGroupsFromParameter($container)
        );
        $groups = array_unique($groups);

        $runners = [];
        foreach ($groups as $group) {
            $container->setDefinition('liip_monitor.runner_'.$group, clone $definition);
            $runners[] = 'liip_monitor.runner_'.$group;
        }

        $container->setAlias('liip_monitor.runner', 'liip_monitor.runner_'.$defaultGroup);
        $runner = $container->getAlias('liip_monitor.runner');
        $runner->setPublic(true);

        $container->setParameter('liip_monitor.runners', $runners);
    }

    /**
     * @return array
     */
    private function getGroups(array $services)
    {
        $groups = [];
        foreach ($services as $serviceId => $tags) {
            foreach ($tags as $attributes) {
                if (!empty($attributes['group'])) {
                    $groups[$attributes['group']] = true;
                }
            }
        }

        return array_keys($groups);
    }

    /**
     * @return array
     */
    private function getGroupsFromParameter(ContainerBuilder $container)
    {
        $groups = [];

        if ($container->hasParameter('liip_monitor.checks')) {
            $checks = $container->getParameter('liip_monitor.checks');
            foreach (array_keys($checks['groups']) as $group) {
                $groups[] = $group;
            }
        }

        return $groups;
    }
}