App\Middlewares\Cors

Complexity

Total Complexity

12

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	requestUriPrefix()	0	3	1
A	required()	0	4	2
A	peel()	0	5	1
A	caUri()	0	3	1
A	isExclude()	0	12	3
A	process()	0	22	4

<?php

declare(strict_types=1);

namespace App\Middlewares;

use Nymfonya\Component\Http\Request;
use Nymfonya\Component\Http\Response;
use Nymfonya\Component\Http\Interfaces\MiddlewareInterface;
use Nymfonya\Component\Container;

/**
 * App\Middleware\Cors
 *
 * Patch initial response to accept CORS requests
 */
class Cors implements MiddlewareInterface
{
    use \App\Middlewares\Reuse\TInit;

    const _PREFLIGHT = 'preflight';
    const _SIGN = 'X-Middleware-Cors';

    /**
     * peel
     *
     * @param Container $container
     * @param \Closure $next
     * @return \Closure
     */
    public function peel(Container $container, \Closure $next)
    {
        $this->init($container);
        $this->process();
        return $next($container);
    }

    /**
     * process
     *
     */
    private function process()
    {
        if ($this->enabled) {
            $this->response->getHeaderManager()->add(
                self::_SIGN,
                strval(microtime(true))
            );
            if ($this->required()) {
                if (Request::METHOD_OPTIONS == $this->request->getMethod()) {
                    $pureCa = preg_replace('/\?.*/', '', $this->caUri()) . '/';
                    $caFrags = explode('/', $pureCa);
                    $controller = $caFrags[0];
                    $this->kernel->setAction([$controller, self::_PREFLIGHT]);
                }
                $this->response
                    ->setCode(Response::HTTP_NOT_FOUND)
                    ->setContent([
                        Response::_ERROR_CODE => Response::HTTP_NOT_FOUND,
                        Response::_ERROR_MSG => 'Not found'
                    ])
                    ->getHeaderManager()
                    ->addMany($this->configParams['headers']);
            }
        }
    }

    /**
     * required
     *
     * @return boolean
     */
    protected function required(): bool
    {
        return (!$this->isExclude()
            && $this->requestUriPrefix() === $this->prefix);
    }

    /**
     * isExclude
     *
     * @return Boolean
     */
    protected function isExclude(): bool
    {
        $disallowed = $this->configParams['exclude'];
        $countEx = count($disallowed);
        for ($c = 0; $c < $countEx; ++$c) {
            $excludeUri = $this->prefix . $disallowed[$c];
            $isExclude = ($excludeUri == $this->request->getUri());
            if ($isExclude) {
                return true;
            }
        }
        return false;
    }

    /**
     * return controller action from uri
     *
     * @return string
     */
    protected function caUri(): string
    {
        return str_replace($this->prefix, '', $this->request->getUri());
    }

    /**
     * uriPrefix
     *
     * @return string
     */
    protected function requestUriPrefix(): string
    {
        return substr($this->request->getUri(), 0, strlen($this->prefix));
    }
}