RequestResponseListener::isExcludedPrefix() - Code Metrics - redirectionio/proxy-symfony - Measure and Improve Code Quality continuously with Scrutinizer

RequestResponseListener::isExcludedPrefix() A
last analyzed 2021-04-27 08:30 UTC

↳ Parent: RequestResponseListener

Complexity

Conditions	3
Paths	3

Size

Total Lines	9
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes

Metric	Value
cc	3
eloc	4
nc	3
nop	1
dl	0
loc	9
ccs	0
cts	0
cp	0
crap	12
rs	10
c	0
b	0
f	0

<?php

namespace RedirectionIO\Client\ProxySymfony\EventListener;

use RedirectionIO\Client\Sdk\Client;
use RedirectionIO\Client\Sdk\Command\CommandInterface;
use RedirectionIO\Client\Sdk\Command\LogCommand;
use RedirectionIO\Client\Sdk\Command\MatchCommand;
use RedirectionIO\Client\Sdk\Command\MatchWithResponseCommand;
use RedirectionIO\Client\Sdk\Exception\ExceptionInterface;
use RedirectionIO\Client\Sdk\HttpMessage\Request;
use RedirectionIO\Client\Sdk\HttpMessage\Response;
use Symfony\Component\HttpFoundation\RedirectResponse as SymfonyRedirectResponse;
use Symfony\Component\HttpFoundation\Request as SymfonyRequest;
use Symfony\Component\HttpFoundation\Response as SymfonyResponse;
use Symfony\Component\HttpKernel\Event\FilterResponseEvent;
use Symfony\Component\HttpKernel\Event\GetResponseEvent;
use Symfony\Component\HttpKernel\Event\PostResponseEvent;

/**
 * @internal
 */
final class RequestResponseListener
{
    private $client;
    private $allowMatchOnResponse;
    private $circuitBreakers;

    public function __construct(Client $client, bool $allowMatchOnResponse = false, /* iterable */ $circuitBreakers = [])
    {
        $this->client = $client;
        $this->allowMatchOnResponse = $allowMatchOnResponse;
        $this->circuitBreakers = $circuitBreakers;
    }

    public function onKernelRequest(GetResponseEvent $event)
    {
        if (!$event->isMasterRequest()) {
            return;
        }

        $request = $event->getRequest();

        foreach ($this->circuitBreakers as $circuitBreaker) {
            if ($circuitBreaker->shouldNotProcessRequest($request)) {
                return;
            }
        }

        /** @var Response $response */
        $response = $this->client->request($this->createMatchCommand($request));
        $request->attributes->set('redirectionio_response', $response);

        if (!$response) {

            return;
        }

        if ($response->getMatchOnResponseStatus() > 0) {
            return;
        }

        410 === $response->getStatusCode()
            ? $event->setResponse((new SymfonyResponse())->setStatusCode(410))
            : $event->setResponse(new SymfonyRedirectResponse($response->getLocation(), $response->getStatusCode()));
    }

    public function onKernelResponse(FilterResponseEvent $event)
    {
        /** @var Response $rioResponse */
        $rioResponse = $event->getRequest()->attributes->get('redirectionio_response');

        if (null === $rioResponse) {
            return;
        }

        $symfonyResponse = $event->getResponse();

        if (0 === $rioResponse->getMatchOnResponseStatus() || $rioResponse->getMatchOnResponseStatus() !== $symfonyResponse->getStatusCode()) {
            return;
        }

        410 === $rioResponse->getStatusCode()
            ? $event->setResponse((new SymfonyResponse())->setStatusCode(410))
            : $event->setResponse(new SymfonyRedirectResponse($rioResponse->getLocation(), $rioResponse->getStatusCode()));
    }

    public function onKernelTerminate(PostResponseEvent $event)
    {
        foreach ($this->circuitBreakers as $circuitBreaker) {
            if ($circuitBreaker->shouldNotProcessRequest($event->getRequest())) {
                return;
            }
        }

        $response = $event->getRequest()->attributes->get('redirectionio_response');

        if (!$response) {
            $symfonyResponse = $event->getResponse();
            $location = $symfonyResponse->headers->get('location', null);

            $response = new Response($event->getResponse()->getStatusCode(), null, $location);
        }

        $request = $this->createSdkRequest($event->getRequest());

        try {
            $this->client->request(new LogCommand($request, $response));
        } catch (ExceptionInterface $exception) {
            // do nothing
        }
    }

    private function createMatchCommand(SymfonyRequest $symfonyRequest): CommandInterface
    {
        $request = $this->createSdkRequest($symfonyRequest);

        if ($this->allowMatchOnResponse) {
            return new MatchWithResponseCommand($request);
        }

        return new MatchCommand($request);
    }

    private function createSdkRequest(SymfonyRequest $symfonyRequest)
    {
        return new Request(
            $symfonyRequest->getHttpHost(),
            $this->getFullPath($symfonyRequest),
            $symfonyRequest->headers->get('User-Agent'),
            $symfonyRequest->headers->get('Referer'),
            $symfonyRequest->getScheme()
        );
    }

    private function getFullPath(SymfonyRequest $symfonyRequest)
    {
        if (null === ($requestUri = $symfonyRequest->getRequestUri())) {

            return '/';
        }

        if ('' !== $requestUri && '/' !== $requestUri[0]) {
            $requestUri = '/'.$requestUri;
        }

        if (null === ($baseUrl = $symfonyRequest->getBaseUrl())) {

            return $requestUri;
        }

        $pathInfo = substr($requestUri, \strlen($baseUrl));

        if (false === $pathInfo || '' === $pathInfo) {
            return '/';
        }

        return (string) $pathInfo;
    }

    private function isExcludedPrefix($url): bool

    {
        foreach ($this->excludedPrefixes as $excludedPrefix) {

            if (0 === strpos($url, $excludedPrefix)) {
                return true;
            }
        }

        return false;
    }
}


1			<?php
2
3			namespace RedirectionIO\Client\ProxySymfony\EventListener;
4
5			use RedirectionIO\Client\Sdk\Client;
6			use RedirectionIO\Client\Sdk\Command\CommandInterface;
7			use RedirectionIO\Client\Sdk\Command\LogCommand;
8			use RedirectionIO\Client\Sdk\Command\MatchCommand;
9			use RedirectionIO\Client\Sdk\Command\MatchWithResponseCommand;
10			use RedirectionIO\Client\Sdk\Exception\ExceptionInterface;
11			use RedirectionIO\Client\Sdk\HttpMessage\Request;
12			use RedirectionIO\Client\Sdk\HttpMessage\Response;
13			use Symfony\Component\HttpFoundation\RedirectResponse as SymfonyRedirectResponse;
14			use Symfony\Component\HttpFoundation\Request as SymfonyRequest;
15			use Symfony\Component\HttpFoundation\Response as SymfonyResponse;
16			use Symfony\Component\HttpKernel\Event\FilterResponseEvent;
17			use Symfony\Component\HttpKernel\Event\GetResponseEvent;
18			use Symfony\Component\HttpKernel\Event\PostResponseEvent;
19
20			/**
21			* @internal
22			*/
23			final class RequestResponseListener
24			{
25			private $client;
26			private $allowMatchOnResponse;
27			private $circuitBreakers;
28
29			public function __construct(Client $client, bool $allowMatchOnResponse = false, /* iterable */ $circuitBreakers = [])
30			{
31			$this->client = $client;
32			$this->allowMatchOnResponse = $allowMatchOnResponse;
33			$this->circuitBreakers = $circuitBreakers;
34			}
35
36			public function onKernelRequest(GetResponseEvent $event)
37			{
38			if (!$event->isMasterRequest()) {
39			return;
40			}
41
42			$request = $event->getRequest();
43
44			foreach ($this->circuitBreakers as $circuitBreaker) {
45			if ($circuitBreaker->shouldNotProcessRequest($request)) {
46			return;
47			}
48			}
49
50			/** @var Response $response */
51			$response = $this->client->request($this->createMatchCommand($request));
52			$request->attributes->set('redirectionio_response', $response);
53
54			if (!$response) {
			0 ignored issues – show introduced 2019-01-31 10:35 UTC by Report Bug Copy Issue Report `$response` is of type `RedirectionIO\Client\Sdk\HttpMessage\Response`, thus it always evaluated to `true`. Loading history...
55			return;
56			}
57
58			if ($response->getMatchOnResponseStatus() > 0) {
59			return;
60			}
61
62			410 === $response->getStatusCode()
63			? $event->setResponse((new SymfonyResponse())->setStatusCode(410))
64			: $event->setResponse(new SymfonyRedirectResponse($response->getLocation(), $response->getStatusCode()));
65			}
66
67			public function onKernelResponse(FilterResponseEvent $event)
68			{
69			/** @var Response $rioResponse */
70			$rioResponse = $event->getRequest()->attributes->get('redirectionio_response');
71
72			if (null === $rioResponse) {
73			return;
74			}
75
76			$symfonyResponse = $event->getResponse();
77
78			if (0 === $rioResponse->getMatchOnResponseStatus() \|\| $rioResponse->getMatchOnResponseStatus() !== $symfonyResponse->getStatusCode()) {
79			return;
80			}
81
82			410 === $rioResponse->getStatusCode()
83			? $event->setResponse((new SymfonyResponse())->setStatusCode(410))
84			: $event->setResponse(new SymfonyRedirectResponse($rioResponse->getLocation(), $rioResponse->getStatusCode()));
85			}
86
87			public function onKernelTerminate(PostResponseEvent $event)
88			{
89			foreach ($this->circuitBreakers as $circuitBreaker) {
90			if ($circuitBreaker->shouldNotProcessRequest($event->getRequest())) {
91			return;
92			}
93			}
94
95			$response = $event->getRequest()->attributes->get('redirectionio_response');
96
97			if (!$response) {
98			$symfonyResponse = $event->getResponse();
99			$location = $symfonyResponse->headers->get('location', null);
100
101			$response = new Response($event->getResponse()->getStatusCode(), null, $location);
102			}
103
104			$request = $this->createSdkRequest($event->getRequest());
105
106			try {
107			$this->client->request(new LogCommand($request, $response));
108			} catch (ExceptionInterface $exception) {
109			// do nothing
110			}
111			}
112
113			private function createMatchCommand(SymfonyRequest $symfonyRequest): CommandInterface
114			{
115			$request = $this->createSdkRequest($symfonyRequest);
116
117			if ($this->allowMatchOnResponse) {
118			return new MatchWithResponseCommand($request);
119			}
120
121			return new MatchCommand($request);
122			}
123
124			private function createSdkRequest(SymfonyRequest $symfonyRequest)
125			{
126			return new Request(
127			$symfonyRequest->getHttpHost(),
128			$this->getFullPath($symfonyRequest),
129			$symfonyRequest->headers->get('User-Agent'),
130			$symfonyRequest->headers->get('Referer'),
131			$symfonyRequest->getScheme()
132			);
133			}
134
135			private function getFullPath(SymfonyRequest $symfonyRequest)
136			{
137			if (null === ($requestUri = $symfonyRequest->getRequestUri())) {
			0 ignored issues – show introduced 2018-12-05 11:14 UTC by Report Bug Copy Issue Report The condition `null === $requestUri = $...equest->getRequestUri()` is always `false`. Loading history...
138			return '/';
139			}
140
141			if ('' !== $requestUri && '/' !== $requestUri[0]) {
142			$requestUri = '/'.$requestUri;
143			}
144
145			if (null === ($baseUrl = $symfonyRequest->getBaseUrl())) {
			0 ignored issues – show introduced 2018-12-05 11:14 UTC by Report Bug Copy Issue Report The condition `null === $baseUrl = $symfonyRequest->getBaseUrl()` is always `false`. Loading history...
146			return $requestUri;
147			}
148
149			$pathInfo = substr($requestUri, \strlen($baseUrl));
150
151			if (false === $pathInfo \|\| '' === $pathInfo) {
152			return '/';
153			}
154
155			return (string) $pathInfo;
156			}
157
158			private function isExcludedPrefix($url): bool
			0 ignored issues – show Unused Code introduced 2019-04-17 14:56 UTC by Report Bug Copy Issue Report The method `isExcludedPrefix()` is not used, and could be removed. This check looks for private methods that have been defined, but are not used inside the class. Loading history...
159			{
160			foreach ($this->excludedPrefixes as $excludedPrefix) {
			0 ignored issues – show Bug Best Practice introduced 2019-04-17 14:56 UTC by Report Bug Copy Issue Report The property `excludedPrefixes` does not exist on `RedirectionIO\Client\Pro...RequestResponseListener`. Did you maybe forget to declare it? Loading history...
161			if (0 === strpos($url, $excludedPrefix)) {
162			return true;
163			}
164			}
165
166			return false;
167			}
168			}
169

redirectionio / proxy-symfony

RequestResponseListener::isExcludedPrefix() A last analyzed 2021-04-27 08:30 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

RequestResponseListener::isExcludedPrefix() A
last analyzed 2021-04-27 08:30 UTC