Geocoder\Plugin\PluginProvider

Complexity

Total Complexity

11

Size/Duplication

Total Lines	131
Duplicated Lines	18.32 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

88.1%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getName()	0	4	1
A	configure()	0	15	2
A	createPluginChain()	0	25	3
A	geocodeQuery()	12	12	2
A	reverseQuery()	12	12	2

<?php

declare(strict_types=1);

/*
 * This file is part of the Geocoder package.
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @license    MIT License
 */

namespace Geocoder\Plugin;

use Geocoder\Collection;
use Geocoder\Exception\Exception;
use Geocoder\Exception\LogicException;
use Geocoder\Plugin\Promise\GeocoderFulfilledPromise;
use Geocoder\Plugin\Promise\GeocoderRejectedPromise;
use Geocoder\Provider\Provider;
use Geocoder\Query\GeocodeQuery;
use Geocoder\Query\Query;
use Geocoder\Query\ReverseQuery;
use Geocoder\Plugin\Exception\LoopException;

/**
 * @author Joel Wurtz <joel.wurtz@gmail.com>
 * @author Tobias Nyholm <tobias.nyholm@gmail.com>
 */
class PluginProvider implements Provider
{
    /**
     * @var Provider
     */
    private $provider;

    /**
     * @var Plugin[]
     */
    private $plugins;

    /**
     * A list of options.
     *
     * @var array
     */
    private $options;

    /**
     * @param Provider $provider
     * @param Plugin[] $plugins
     * @param array    $options  {
     *
     *     @var int      $max_restarts
     * }
     */
    public function __construct(Provider $provider, array $plugins = [], array $options = [])
    {
        $this->provider = $provider;
        $this->plugins = $plugins;
        $this->options = $this->configure($options);
    }

    /**
     * {@inheritdoc}
     */
    public function geocodeQuery(GeocodeQuery $query): Collection

This method seems to be duplicated in your project.

    {
        $pluginChain = $this->createPluginChain($this->plugins, function (GeocodeQuery $query) {
            try {
                return new GeocoderFulfilledPromise($this->provider->geocodeQuery($query));
            } catch (Exception $exception) {
                return new GeocoderRejectedPromise($exception);
            }
        });

        return $pluginChain($query)->wait();
    }

    /**
     * {@inheritdoc}
     */
    public function reverseQuery(ReverseQuery $query): Collection

This method seems to be duplicated in your project.

    {
        $pluginChain = $this->createPluginChain($this->plugins, function (ReverseQuery $query) {
            try {
                return new GeocoderFulfilledPromise($this->provider->reverseQuery($query));
            } catch (Exception $exception) {
                return new GeocoderRejectedPromise($exception);
            }
        });

        return $pluginChain($query)->wait();
    }

    /**
     * {@inheritdoc}
     */
    public function getName(): string
    {
        return $this->provider->getName();
    }

    /**
     * Configure the plugin provider.
     *
     * @param array $options
     *
     * @return array
     */
    private function configure(array $options = []): array
    {
        $defaults = [
            'max_restarts' => 10,
        ];

        $config = array_merge($defaults, $options);

        // Make sure no invalid values are provided
        if (count($config) !== count($defaults)) {
            throw new LogicException(sprintf('Valid options to the PluginProviders are: %s', implode(', ', array_values($defaults))));
        }

        return $config;
    }

    /**
     * Create the plugin chain.
     *
     * @param Plugin[] $pluginList     A list of plugins
     * @param callable $clientCallable Callable making the HTTP call
     *
     * @return callable
     */
    private function createPluginChain(array $pluginList, callable $clientCallable)
    {
        $firstCallable = $lastCallable = $clientCallable;

        while ($plugin = array_pop($pluginList)) {
            $lastCallable = function (Query $query) use ($plugin, $lastCallable, &$firstCallable) {
                return $plugin->handleQuery($query, $lastCallable, $firstCallable);
            };

            $firstCallable = $lastCallable;
        }

        $firstCalls = 0;
        $firstCallable = function (Query $query) use ($lastCallable, &$firstCalls) {
            if ($firstCalls > $this->options['max_restarts']) {
                throw LoopException::create('Too many restarts in plugin provider', $query);
            }

            ++$firstCalls;

            return $lastCallable($query);
        };

        return $firstCallable;
    }
}