hiapi\Core\Endpoint\EndpointProcessor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__invoke()	0	14	1
B	endpointMiddlewares()	0	26	7

<?php

namespace hiapi\Core\Endpoint;

use Closure;
use Doctrine\Common\Collections\ArrayCollection;
use hiapi\Core\Endpoint\Middleware\CheckPermissionsMiddleware;
use hiapi\Core\Endpoint\Middleware\TypeCheckMiddleware;
use hiapi\exceptions\ConfigurationException;
use hiapi\middlewares\CallableHandler;
use hiapi\middlewares\ValidateCommandMiddleware;
use hiqdev\yii\compat\yii;
use League\Tactician\CommandBus;
use League\Tactician\Middleware;
use Psr\Container\ContainerInterface;
use yii\base\Model;
use yii\web\User;

class EndpointProcessor
{
    /**
     * @var Endpoint
     */
    private $endpoint;
    /**
     * @var ContainerInterface
     */
    private $di;

    public function __construct(ContainerInterface $di)
    {
        $this->di = $di;
    }

    /**
     * @param $command
     * @param Endpoint $endpoint
     * @return Model|ArrayCollection
     */
    public function __invoke($command, Endpoint $endpoint)
    {
        $this->endpoint = $endpoint;

        $middlewares = [];
        $middlewares[] = new TypeCheckMiddleware($endpoint);
        $middlewares[] = new CheckPermissionsMiddleware($endpoint, $this->di->get(User::class));
        $middlewares[] = new ValidateCommandMiddleware();
        $middlewares = array_merge($middlewares, $this->endpointMiddlewares());

        $result = (new CommandBus($middlewares))->handle($command);

$middlewares is of type array<integer,object<hiapi\Core\Endpoint\Middleware\TypeCheckMiddleware>|object<hiapi\Core\Endpoint\Middleware\CheckPermissionsMiddleware>|object<League\Tactician\Middleware>>, but the function expects a array<integer,object<League\Tactician\Middleware>>.

        return $result;
    }

    /**
     * Produces array of middlewares.
     *
     * TODO: Maybe, the Endpoint must prepare the middlewares array itself?
     *
     * @return Middleware[]
     */
    private function endpointMiddlewares(): array
    {
        return array_map(function ($item): Middleware {
            if (is_string($item)) {
                $item = $this->di->get($item);
            }

            if (is_array($item)) {
                $item = yii::createObject($item);
            }

            if ($item instanceof Middleware) {
                return $item;
            }

            if (is_object($item) && is_callable($item)) {
                $item = Closure::fromCallable($item);
            }

            if ($item instanceof \Closure) {
                return new CallableHandler($item);
            }

            throw new ConfigurationException(sprintf('Do not know how to instantiate %s', (string)$item));
        }, $this->endpoint->middlewares);
    }
}