hiapi\Core\Http\Psr15\Middleware\UseBaseMiddleware

Complexity

Total Complexity

12

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	process()	0	4	1
A	perform()	0	17	2
A	getInputData()	0	10	1
A	getCommandName()	0	7	1
A	getBase()	0	8	2
A	ensureCommandExists()	0	6	2
A	ensureCommandAllowed()	0	6	2

<?php

namespace hiapi\Core\Http\Psr15\Middleware;

use hiapi\Core\Http\Psr7\Response\FatResponse;
use hiapi\exceptions\NotAuthenticatedException;
use hiapi\legacy\lib\mrdpBase;
use Psr\Container\ContainerInterface;
use Psr\Http\Message\MessageInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

class UseBaseMiddleware implements MiddlewareInterface
{
    /**
     * @var ContainerInterface
     */
    private $container;

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

    /**
     * @inheritDoc
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        return $this->perform($request);
    }

    private function perform(ServerRequestInterface $request): ResponseInterface
    {
        $command = $this->getCommandName($request);

        $this->ensureCommandExists($command);
        $this->ensureCommandAllowed($command);

        $data = $this->getInputData($request);

        $res = $this->getBase()->{$command}($data);

        if ($res instanceof ResponseInterface) {
            return $res;
        }

        return FatResponse::create($res, $request);
    }

    private function getInputData(ServerRequestInterface $request): array
    {
        $query = $request->getQueryParams();
        $post  = $request->getParsedBody();

        return array_merge($query, $post);

        // XXX TODO check if it really exactly corresponds to
        // return $_REQUEST;
    }

    private function getCommandName(MessageInterface $request): string
    {
        $path = $request->getUri()->getPath();

It seems like you code against a concrete implementation and not the interface Psr\Http\Message\MessageInterface as the method getUri() does only exist in the following implementations of said interface: GuzzleHttp\Psr7\Request, GuzzleHttp\Psr7\ServerRequest, hiapi\console\ServerRequest.

        $URLPARTS = explode('/', ltrim($path, '/'));

        return $URLPARTS[0];
    }

    private $base;

    private function getBase(): mrdpBase
    {
        if ($this->base === null) {
            $this->base = $this->container->get(mrdpBase::class);
        }

        return $this->base;
    }

    private function ensureCommandExists(string $command): void
    {
        if (!$this->getBase()->hasCommand($command)) {
            throw new \RuntimeException("Not existing command: $command");
        }
    }

    private function ensureCommandAllowed(string $command): void
    {
        if (!$this->getBase()->isCommandAllowed($command)) {
            throw new NotAuthenticatedException("Not allowed command: $command");
        }
    }
}