Liip\MonitorBundle\DependencyInjection\Compiler\GroupRunnersCompilerPass

Complexity

Total Complexity

11

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

3 Methods

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

<?php

namespace Liip\MonitorBundle\DependencyInjection\Compiler;

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

class GroupRunnersCompilerPass implements CompilerPassInterface
{
    /**
     * @param ContainerBuilder $container
     */
    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($defaultGroup);
        $groups = array_merge($groups, $this->getGroups($checkServices));
        $groups = array_merge($groups, $this->getGroups($checkCollectionServices));
        $groups = array_merge($groups, $this->getGroupsFromParameter($container));
        $groups = array_unique($groups);

        $runners = array();
        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);
        $container->setParameter('liip_monitor.runners', $runners);
    }

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

        return array_keys($groups);
    }

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

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

        return $groups;
    }
}