Overblog\GraphQLBundle\Definition\ConfigProcessor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	addConfigProcessor()	0	4	1
A	register()	0	7	2
A	process()	0	9	2
A	initialize()	0	17	4

<?php

namespace Overblog\GraphQLBundle\Definition;

use Overblog\GraphQLBundle\Definition\ConfigProcessor\ConfigProcessorInterface;

final class ConfigProcessor implements ConfigProcessorInterface
{
    /**
     * @var ConfigProcessorInterface[]
     */
    private $orderedProcessors;

    /**
     * @var array
     */
    private $processors;

    /**
     * @var bool
     */
    private $isInitialized = false;

    public function addConfigProcessor(ConfigProcessorInterface $configProcessor, $priority = 0)
    {
        $this->register($configProcessor, $priority);
    }

    public function register(ConfigProcessorInterface $configProcessor, $priority = 0)
    {
        if ($this->isInitialized) {
            throw new \LogicException('Registering config processor after calling process() is not supported.');
        }
        $this->processors[] = ['processor' => $configProcessor, 'priority' => $priority];
    }

    public function process(LazyConfig $lazyConfig)
    {
        $this->initialize();
        foreach ($this->orderedProcessors as $processor) {
            $lazyConfig = $processor->process($lazyConfig);
        }

        return $lazyConfig;
    }

    private function initialize()
    {
        if (!$this->isInitialized) {
            // order processors by DESC priority
            $processors = $this->processors;
            usort($processors, function ($processorA, $processorB) {
                if ($processorA['priority'] === $processorB['priority']) {
                    return 0;
                }

                return ($processorA['priority'] < $processorB['priority']) ? 1 : -1;
            });

            $this->orderedProcessors = array_column($processors, 'processor');
            $this->isInitialized = true;
        }
    }
}