Overblog\GraphQLBundle\DependencyInjection\Compiler\ResolverMapTaggedServiceMappingPass

Complexity

Total Complexity

9

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	process()	0	42	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\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
    {
        $resolverMapsSortedBySchema = [];
        $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'])) {
                    throw new RuntimeException(\sprintf('The "schema" attribute on the "overblog_graphql.resolver_map" tag of the "%s" service is required.', $serviceId));
                }

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

                $resolverMapsBySchemas[$tag['schema']][$serviceId] = $tag['priority'] ?? ($resolverMapsBySchemas[$tag['schema']][$serviceId] ?? 0);
            }
        }

        foreach ($resolverMapsBySchemas as $schema => $resolverMaps) {
            foreach ($resolverMaps as $resolverMap => $priority) {
                $resolverMapsSortedBySchema[$schema][$priority][] = $resolverMap;
            }
        }

        foreach ($resolverMapsSortedBySchema as $schema => $resolverMaps) {
            \krsort($resolverMaps);

            $resolverMaps = \array_merge(...$resolverMaps);

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

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

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