Overblog\GraphQLBundle\DependencyInjection\Compiler\ResolverMapTaggedServiceMappingPass

Complexity

Total Complexity

9

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	process()	0	39	9

<?php

declare(strict_types=1);

namespace Overblog\GraphQLBundle\DependencyInjection\Compiler;

use Overblog\GraphQLBundle\EventListener\TypeDecoratorListener;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Exception\InvalidArgumentException;
use Symfony\Component\DependencyInjection\Exception\RuntimeException;
use Symfony\Component\DependencyInjection\Reference;

final class ResolverMapTaggedServiceMappingPass implements CompilerPassInterface
{
    private const SERVICE_TAG = 'overblog_graphql.resolver_map';

    /**
     * {@inheritdoc}
     */
    public function process(ContainerBuilder $container): void
    {
        $resolverMapsBySchemas = $container->getParameter('overblog_graphql.resolver_maps');
        $typeDecoratorListenerDefinition = $container->getDefinition(TypeDecoratorListener::class);

        foreach ($container->findTaggedServiceIds(self::SERVICE_TAG, true) as $serviceId => $tags) {
            foreach ($tags as $tag) {
                if (isset($tag['schema'])) {
                    $schemaName = $tag['schema'];
                } else {
                    if (1 < \count($resolverMapsBySchemas)) {
                        throw new InvalidArgumentException(\sprintf('Service "%s" must define the "schema" attribute on "%s" tags.', $serviceId, self::SERVICE_TAG));
                    }

                    $schemaName = 'default';
                }

                if (!isset($resolverMapsBySchemas[$schemaName])) {
                    throw new RuntimeException(\sprintf('Service "%s" is invalid: schema "%s" specified on the tag "%s" does not exist (known ones are: "%s").', $serviceId, $schemaName, self::SERVICE_TAG, \implode('", "', \array_keys($resolverMapsBySchemas))));
                }

                if (!\in_array($serviceId, $resolverMapsBySchemas[$schemaName], true)) {
                    $resolverMapsBySchemas[$schemaName][] = $serviceId;
                }
            }
        }

        foreach ($resolverMapsBySchemas as $schemaName => $resolverMaps) {
            foreach ($resolverMaps as $index => $resolverMap) {
                $resolverMaps[$index] = new Reference($resolverMap);
            }

            $typeDecoratorListenerDefinition->addMethodCall('addSchemaResolverMaps', [
                $schemaName,
                $resolverMaps,
            ]);
        }

        $container->getParameterBag()->remove('overblog_graphql.resolver_maps');
    }
}