GBProd\ElasticaProviderBundle\DependencyInjection\Compiler\ProviderCompilerPass

Complexity

Total Complexity

15

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	13	3
A	processProvider()	0	9	2
A	validateIsAProvider()	0	11	2
A	isNotAProvider()	0	6	1
A	validateTag()	0	11	2
A	isTagIncorrect()	0	8	4
A	registerProvider()	0	13	1

<?php

namespace GBProd\ElasticaProviderBundle\DependencyInjection\Compiler;

use GBProd\ElasticaProviderBundle\Provider\Provider;
use GBProd\ElasticaProviderBundle\Provider\RegistryEntry;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Reference;

/**
 * Compiler path to register providers
 *
 * @author gbprod <contact@gb-prod.fr>
 */
class ProviderCompilerPass implements CompilerPassInterface
{
    /**
     * {@inheritdoc}
     */
    public function process(ContainerBuilder $container)
    {
        if (!$container->hasDefinition('gbprod.elastica_provider.registry')) {
            return;
        }

        $registry = $container->getDefinition('gbprod.elastica_provider.registry');
        $providers = $container->findTaggedServiceIds('elasticsearch.provider');

        foreach ($providers as $providerId => $tags) {
            $this->processProvider($container, $registry, $providerId, $tags);
        }
    }

    private function processProvider(ContainerBuilder $container, $registry, $providerId, $tags)
    {
        $this->validateIsAProvider($container, $providerId);

        foreach ($tags as $tag) {
            $this->validateTag($tag, $providerId);
            $this->registerProvider($registry, $providerId, $tag);
        }
    }

    private function validateIsAProvider(ContainerBuilder $container, $providerId)
    {
        if ($this->isNotAProvider($container->getDefinition($providerId))) {
            throw new \InvalidArgumentException(
                sprintf(
                    'provider "%s" must implements provider interface.',
                    $providerId
                )
            );
        }
    }

    private function isNotAProvider(Definition $definition)
    {
        $reflection = new \ReflectionClass($definition->getClass());

        return !$reflection->implementsInterface(Provider::class);
    }

    private function validateTag($tag, $providerId)
    {
        if ($this->isTagIncorrect($tag)) {
            throw new \InvalidArgumentException(
                sprintf('provider "%s" must specify the "index"' .
                    ' and "type" attribute.',
                    $providerId
                )
            );
        }
    }

    private function isTagIncorrect($tag)
    {
        return !isset($tag['type'])
            || !isset($tag['index'])
            || empty($tag['index'])
            || empty($tag['type'])
        ;
    }

    private function registerProvider($registry, $providerId, $tag)
    {
        $entryDefinition = new Definition(
            RegistryEntry::class,
            [
                new Reference($providerId),
                $tag['index'],
                $tag['type'],
            ]
        );

        $registry->addMethodCall('add', [$entryDefinition]);
    }
}