Daikon\Boot\Middleware\DefaultPipeline

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	add()	0	3	1
A	addDebug()	0	4	2
A	__invoke()	0	15	2
A	__construct()	0	8	1

<?php declare(strict_types=1);
/**
 * This file is part of the daikon-cqrs/boot project.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Daikon\Boot\Middleware;

use Daikon\Config\ConfigProviderInterface;
use Middlewares\ContentEncoding;
use Middlewares\ContentLanguage;
use Middlewares\ContentType;
use Middlewares\Cors;
use Middlewares\JsonPayload;
use Middlewares\RequestHandler;
use Middlewares\UrlEncodePayload;
use Middlewares\Whoops;
use Psr\Container\ContainerInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Relay\Relay;

final class DefaultPipeline implements PipelineBuilderInterface
{
    private const DEFAULT_PIPELINE = [
        ContentType::class,
        ContentLanguage::class,
        ContentEncoding::class,
        RoutingHandler::class,
        JsonPayload::class,
        UrlEncodePayload::class,
        ActionHandler::class,
        RequestHandler::class
    ];

    private ContainerInterface $container;

    private ConfigProviderInterface $configProvider;

    private array $settings;

    public function __construct(
        ContainerInterface $container,
        ConfigProviderInterface $configProvider,
        array $settings = []
    ) {
        $this->container = $container;
        $this->configProvider = $configProvider;
        $this->settings = $settings;
    }

    public function __invoke(): RequestHandlerInterface
    {
        $middlewares = [];
        $this->addDebug($middlewares, $this->container->get(Whoops::class));

        if ($this->configProvider->get('project.cors.enabled', false)) {
            $this->add($middlewares, $this->container->get(Cors::class));
        }

        $this->add($middlewares, ...array_map(
            [$this->container, 'get'],
            $this->settings['pipeline'] ?? self::DEFAULT_PIPELINE
        ));

        return new Relay($middlewares);
    }

    private function addDebug(array &$middlewares, MiddlewareInterface ...$middleware): void
    {
        if ($this->configProvider->get('app.debug') === true) {
            $this->add($middlewares, ...$middleware);
        }
    }

    private function add(array &$middlewares, MiddlewareInterface ...$middleware): void
    {
        array_push($middlewares, ...$middleware);
    }
}