PrivateChannelAuthenticator::processRequest() - Code Metrics - Inspection of "JWT token" - fre5h/CentrifugoBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#2)

by Artem

created 2020-05-07 14:21 UTC

PrivateChannelAuthenticator::processRequest() B

↳ Parent: PrivateChannelAuthenticator

Complexity

Conditions	10
Paths	7

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	31
rs	7.6666
c	0
b	0
f	0
cc	10
nc	7
nop	1

How to fix Complexity

<?php
/*
 * This file is part of the FreshCentrifugoBundle.
 *
 * (c) Artem Henvald <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Fresh\CentrifugoBundle\Service\ChannelAuthenticator;

use Fresh\CentrifugoBundle\Service\Credentials\CredentialsGenerator;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;

/**
 * PrivateChannelAuthenticator.
 *
 * @author Artem Henvald <[email protected]>
 */
class PrivateChannelAuthenticator
{
    /** @var CredentialsGenerator */
    private $credentialsGenerator;

    /** @var ChannelAuthenticatorInterface[]|iterable */
    private $channelAuthenticators;

    /**
     * @param CredentialsGenerator                     $credentialsGenerator
     * @param ChannelAuthenticatorInterface[]|iterable $channelAuthenticators
     */
    public function __construct(CredentialsGenerator $credentialsGenerator, iterable $channelAuthenticators)
    {
        $this->credentialsGenerator = $credentialsGenerator;
        $this->channelAuthenticators = $channelAuthenticators;
    }

    /**
     * @param Request $request
     *
     * @return array
     */
    public function authChannelsForClientFromRequest(Request $request): array
    {
        $authData = [];

        [$client, $channels] = $this->processRequest($request);


        foreach ($channels as $channel) {
            $token = $this->authChannelForClient($client, (string) $channel);

            if (\is_string($token)) {
                $authData[] = [
                    'channel' => (string) $channel,
                    'token' => $token,
                ];
            }
        }

        return ['channels' => $authData];
    }

    /**
     * @param string $client
     * @param string $channel
     *
     * @return string|null
     */
    private function authChannelForClient(string $client, string $channel): ?string
    {
        $token = null;

        $channelAuthenticator = $this->findAppropriateChannelAuthenticator($channel);
        if ($channelAuthenticator instanceof ChannelAuthenticatorInterface && $channelAuthenticator->hasAccessToChannel($channel)) {
            $token = $this->credentialsGenerator->generateJwtTokenForPrivateChannel($client, $channel);
        }

        return $token;
    }

    /**
     * @param string $channel
     *
     * @return ChannelAuthenticatorInterface|null
     */
    private function findAppropriateChannelAuthenticator(string $channel): ?ChannelAuthenticatorInterface
    {
        foreach ($this->channelAuthenticators as $channelAuthenticator) {
            if ($channelAuthenticator->supports($channel)) {
                return $channelAuthenticator;
            }
        }

        return null;
    }

    /**
     * @param Request $request
     *
     * @throws BadRequestHttpException
     * @throws \Exception
     *
     * @return array
     */
    private function processRequest(Request $request): array
    {
        try {
            $content = \json_decode((string) $request->getContent(), true, 512, \JSON_THROW_ON_ERROR);
        } catch (\JsonException $e) {
            throw new BadRequestHttpException('Invalid JSON.');
        } catch (\Exception $e) {
            throw $e;
        }

        $result = [];

        if (!isset($content['client']) || !\is_string($content['client'])) {
            throw new BadRequestHttpException('Client must be set in request.');
        }
        $result[] = $content['client'];

        if (!isset($content['channels']) || !\is_array($content['channels']) || empty($content['channels'])) {
            throw new BadRequestHttpException('Channels must be set in request.');
        }

        foreach ($content['channels'] as $channel) {
            if (!\is_string($channel)) {
                throw new BadRequestHttpException('Channel must be a string.');
            }
        }

        $result[] = $content['channels'];

        return $result;
    }
}


1			<?php
2			/*
3			* This file is part of the FreshCentrifugoBundle.
4			*
5			* (c) Artem Henvald <[email protected]>
6			*
7			* For the full copyright and license information, please view the LICENSE
8			* file that was distributed with this source code.
9			*/
10
11			declare(strict_types=1);
12
13			namespace Fresh\CentrifugoBundle\Service\ChannelAuthenticator;
14
15			use Fresh\CentrifugoBundle\Service\Credentials\CredentialsGenerator;
16			use Symfony\Component\HttpFoundation\Request;
17			use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
18
19			/**
20			* PrivateChannelAuthenticator.
21			*
22			* @author Artem Henvald <[email protected]>
23			*/
24			class PrivateChannelAuthenticator
25			{
26			/** @var CredentialsGenerator */
27			private $credentialsGenerator;
28
29			/** @var ChannelAuthenticatorInterface[]\|iterable */
30			private $channelAuthenticators;
31
32			/**
33			* @param CredentialsGenerator $credentialsGenerator
34			* @param ChannelAuthenticatorInterface[]\|iterable $channelAuthenticators
35			*/
36			public function __construct(CredentialsGenerator $credentialsGenerator, iterable $channelAuthenticators)
37			{
38			$this->credentialsGenerator = $credentialsGenerator;
39			$this->channelAuthenticators = $channelAuthenticators;
40			}
41
42			/**
43			* @param Request $request
44			*
45			* @return array
46			*/
47			public function authChannelsForClientFromRequest(Request $request): array
48			{
49			$authData = [];
50
51			[$client, $channels] = $this->processRequest($request);
			0 ignored issues – show Bug introduced 2020-05-07 09:17 UTC by Report Bug Copy Issue Report The variable `$client` does not exist. Did you forget to declare it? This check marks access to variables or properties that have not been declared yet. While PHP has no explicit notion of declaring a variable, accessing it before a value is assigned to it is most likely a bug. Loading history... Bug introduced 2020-05-07 13:41 UTC by Report Bug Copy Issue Report The variable `$channels` does not exist. Did you forget to declare it? This check marks access to variables or properties that have not been declared yet. While PHP has no explicit notion of declaring a variable, accessing it before a value is assigned to it is most likely a bug. Loading history...
52
53			foreach ($channels as $channel) {
54			$token = $this->authChannelForClient($client, (string) $channel);
55
56			if (\is_string($token)) {
57			$authData[] = [
58			'channel' => (string) $channel,
59			'token' => $token,
60			];
61			}
62			}
63
64			return ['channels' => $authData];
65			}
66
67			/**
68			* @param string $client
69			* @param string $channel
70			*
71			* @return string\|null
72			*/
73			private function authChannelForClient(string $client, string $channel): ?string
74			{
75			$token = null;
76
77			$channelAuthenticator = $this->findAppropriateChannelAuthenticator($channel);
78			if ($channelAuthenticator instanceof ChannelAuthenticatorInterface && $channelAuthenticator->hasAccessToChannel($channel)) {
79			$token = $this->credentialsGenerator->generateJwtTokenForPrivateChannel($client, $channel);
80			}
81
82			return $token;
83			}
84
85			/**
86			* @param string $channel
87			*
88			* @return ChannelAuthenticatorInterface\|null
89			*/
90			private function findAppropriateChannelAuthenticator(string $channel): ?ChannelAuthenticatorInterface
91			{
92			foreach ($this->channelAuthenticators as $channelAuthenticator) {
93			if ($channelAuthenticator->supports($channel)) {
94			return $channelAuthenticator;
95			}
96			}
97
98			return null;
99			}
100
101			/**
102			* @param Request $request
103			*
104			* @throws BadRequestHttpException
105			* @throws \Exception
106			*
107			* @return array
108			*/
109			private function processRequest(Request $request): array
110			{
111			try {
112			$content = \json_decode((string) $request->getContent(), true, 512, \JSON_THROW_ON_ERROR);
113			} catch (\JsonException $e) {
114			throw new BadRequestHttpException('Invalid JSON.');
115			} catch (\Exception $e) {
116			throw $e;
117			}
118
119			$result = [];
120
121			if (!isset($content['client']) \|\| !\is_string($content['client'])) {
122			throw new BadRequestHttpException('Client must be set in request.');
123			}
124			$result[] = $content['client'];
125
126			if (!isset($content['channels']) \|\| !\is_array($content['channels']) \|\| empty($content['channels'])) {
127			throw new BadRequestHttpException('Channels must be set in request.');
128			}
129
130			foreach ($content['channels'] as $channel) {
131			if (!\is_string($channel)) {
132			throw new BadRequestHttpException('Channel must be a string.');
133			}
134			}
135
136			$result[] = $content['channels'];
137
138			return $result;
139			}
140			}
141

fre5h / CentrifugoBundle

Pull Request — master (#2)

PrivateChannelAuthenticator::processRequest() B

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like