Fresh\CentrifugoBundle\Service\ChannelAuthenticator\PrivateChannelAuthenticator

Complexity

Total Complexity

17

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	authChannelsForUserFromRequest()	0	17	4
A	authChannelForUser()	0	11	3
A	findAppropriateChannelAuthenticator()	0	10	3
A	processRequest()	0	16	6

<?php
/*
 * This file is part of the FreshCentrifugoBundle.
 *
 * (c) Artem Henvald <genvaldartem@gmail.com>
 *
 * 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 <genvaldartem@gmail.com>
 */
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 authChannelsForUserFromRequest(Request $request): array
    {
        $channelsAuth = [];

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

The variable $client does not exist. Did you forget to declare it?

The variable $channels does not exist. Did you mean $channelsAuth?

        foreach ($channels as $channel) {

The variable $channels does not exist. Did you mean $channelsAuth?

            if (($token = $this->authChannelForUser($client, $channel)) && \is_string($token)) {
                $channelsAuth[] = [
                    'channel' => $channel,
                    'token' => $token,
                ];
            }
        }

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

    /**
     * @param string $client
     * @param string $channel
     *
     * @return string|null
     */
    private function authChannelForUser(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
     *
     * @return array
     */
    private function processRequest(Request $request): array
    {
        $content = \json_decode((string) $request->getContent(), true, 512, \JSON_THROW_ON_ERROR);

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

$result was never initialized. Although not strictly required by PHP, it is generally a good practice to add $result = array(); before regardless.

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

        return $result;
    }
}