Mcustiel\PowerRoute\PowerRoute

Complexity

Total Complexity

14

Size/Duplication

Total Lines	120
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

84.91%

Importance

Changes	8
Bugs	1	Features	4

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	setConfig()	0	4	1
A	start()	0	6	1
A	execute()	0	21	3
A	evaluateConditions()	0	20	4
A	getConditionsMatcher()	0	7	2
A	getActionsToRun()	0	10	2

<?php
namespace Mcustiel\PowerRoute;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Mcustiel\PowerRoute\Common\Factories\ActionFactory;
use Mcustiel\PowerRoute\Common\TransactionData;
use Mcustiel\PowerRoute\Common\Conditions\ConditionsMatcherFactory;
use Mcustiel\PowerRoute\Common\ConfigOptions;
use Mcustiel\Creature\LazyCreator;
use Mcustiel\PowerRoute\Actions\Psr7MiddlewareAction;

class PowerRoute
{
    const CONDITIONS_MATCHER_ALL = 'allConditionsMatcher';
    const CONDITIONS_MATCHER_ONE = 'oneConditionsMatcher';

    /**
     * @var array $config
     */
    private $config;
    /**
     * @var \Mcustiel\PowerRoute\Common\Factories\ActionFactory $actionFactory
     */
    private $actionFactory;
    /**
     * @var \Mcustiel\PowerRoute\Common\Conditions\ConditionsMatcherInterface[] $conditionsMatchers
     */
    private $conditionMatchers;
    /**
     * @var \Mcustiel\PowerRoute\Common\Conditions\ConditionsMatcherFactory $conditionMatcherFactory
     */
    private $conditionMatcherFactory;
    /**
     * @var \Mcustiel\Creature\LazyCreator $psr7InvokerCreator
     */
    private $psr7InvokerCreator;

    public function __construct(
        array $config,
        ActionFactory $actionFactory,
        ConditionsMatcherFactory $conditionsMatcherFactory
    ) {
        $this->conditionMatchers = [];
        $this->config = $config;
        $this->conditionMatcherFactory = $conditionsMatcherFactory;
        $this->actionFactory = $actionFactory;
        $this->psr7InvokerCreator = new LazyCreator(Psr7MiddlewareAction::class);
    }

    public function setConfig(array $config)
    {
        $this->config = $config;
    }

    /**
     * @param \Psr\Http\Message\ServerRequestInterface $request
     * @param \Psr\Http\Message\ResponseInterface      $response
     */
    public function start(ServerRequestInterface $request, ResponseInterface $response)
    {
        $transactionData = new TransactionData($request, $response);
        $this->execute($this->config[ConfigOptions::CONFIG_ROOT_NODE], $transactionData);
        return $transactionData->getResponse();
    }

    /**
     * @param string                             $routeName
     * @param \PowerRoute\Common\TransactionData $transactionData
     */
    public function execute($routeName, TransactionData $transactionData)
    {
        $route = $this->config[ConfigOptions::CONFIG_NODES][$routeName];

        $actions = $this->actionFactory->createFromConfig(
            $this->getActionsToRun(
                $route,
                $this->evaluateConditions($route, $transactionData->getRequest())
            ),
            $this
        );

        foreach ($actions as $action) {
            $instance = $action->getInstance();
            if (is_callable($instance)) {
                $this->psr7InvokerCreator->getInstance()->execute($transactionData, $action);
            } else {
                $instance->execute($transactionData, $action->getArgument());
            }
        }
    }

    private function evaluateConditions($route, $request)
    {
        if (!$route[ConfigOptions::CONFIG_NODE_CONDITION]) {
            return true;
        }
        if (isset($route[ConfigOptions::CONFIG_NODE_CONDITION][ConfigOptions::CONFIG_NODE_CONDITION_ALL])) {
            return $this->getConditionsMatcher(self::CONDITIONS_MATCHER_ALL)->matches(
                $route[ConfigOptions::CONFIG_NODE_CONDITION][ConfigOptions::CONFIG_NODE_CONDITION_ALL],
                $request
            );
        }
        if (isset($route[ConfigOptions::CONFIG_NODE_CONDITION][ConfigOptions::CONFIG_NODE_CONDITION_ONE])) {
            return $this->getConditionsMatcher(self::CONDITIONS_MATCHER_ONE)->matches(
                $route[ConfigOptions::CONFIG_NODE_CONDITION][ConfigOptions::CONFIG_NODE_CONDITION_ONE],
                $request
            );
        }

        throw new \RuntimeException('Invalid condition specified for route: ' . $route);
    }

    private function getConditionsMatcher($matcher)
    {
        if (!isset($this->conditionMatchers[$matcher])) {
            $this->conditionMatchers[$matcher] = $this->conditionMatcherFactory->get($matcher);
        }
        return $this->conditionMatchers[$matcher];
    }

    private function getActionsToRun($route, $matched)
    {
        if ($matched) {
            return $route[ConfigOptions::CONFIG_NODE_ACTIONS]
                [ConfigOptions::CONFIG_NODE_ACTIONS_MATCH];
        }

        return $route[ConfigOptions::CONFIG_NODE_ACTIONS]
            [ConfigOptions::CONFIG_NODE_ACTIONS_NOTMATCH];
    }
}