Fresh\CentrifugoBundle\Service\Credentials\CredentialsGenerator

Complexity

Total Complexity

6

Size/Duplication

Total Lines	100
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	generateJwtTokenForUser()	0	12	1
A	generateJwtTokenForAnonymous()	0	12	1
A	generateJwtTokenForPrivateChannel()	0	13	1
A	getExpirationTime()	0	12	2

<?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\Credentials;

use Fresh\CentrifugoBundle\Service\Jwt\JwtGenerator;
use Fresh\CentrifugoBundle\Token\JwtPayload;
use Fresh\CentrifugoBundle\Token\JwtPayloadForPrivateChannel;
use Fresh\CentrifugoBundle\User\CentrifugoUserInterface;
use Fresh\DateTime\DateTimeHelper;

/**
 * CredentialsGenerator.
 *
 * @author Artem Henvald <genvaldartem@gmail.com>
 */
class CredentialsGenerator
{
    /** @var JwtGenerator */
    private $jwtGenerator;

    /** @var DateTimeHelper */
    private $dateTimeHelper;

    /** @var int|null */
    private $centrifugoJwtTtl;

    /**
     * @param JwtGenerator   $jwtGenerator
     * @param DateTimeHelper $dateTimeHelper
     * @param int|null       $centrifugoJwtTtl
     */
    public function __construct(JwtGenerator $jwtGenerator, DateTimeHelper $dateTimeHelper, ?int $centrifugoJwtTtl = null)
    {
        $this->jwtGenerator = $jwtGenerator;
        $this->dateTimeHelper = $dateTimeHelper;
        $this->centrifugoJwtTtl = $centrifugoJwtTtl;
    }

    /**
     * @param CentrifugoUserInterface $user
     * @param string|null             $base64info
     * @param array                   $channels
     *
     * @return string
     */
    public function generateJwtTokenForUser(CentrifugoUserInterface $user, ?string $base64info = null, array $channels = []): string
    {
        $jwtPayload = new JwtPayload(
            $user->getCentrifugoSubject(),
            $user->getCentrifugoUserInfo(),
            $this->getExpirationTime(),
            $base64info,
            $channels
        );

        return $this->jwtGenerator->generateToken($jwtPayload);
    }

    /**
     * @param string|null $base64info
     * @param array       $channels
     *
     * @return string
     */
    public function generateJwtTokenForAnonymous(?string $base64info = null, array $channels = []): string
    {
        $jwtPayload = new JwtPayload(
            '',
            [],
            $this->getExpirationTime(),
            $base64info,
            $channels
        );

        return $this->jwtGenerator->generateToken($jwtPayload);
    }

    /**
     * @param string      $client
     * @param string      $channel
     * @param string|null $base64info
     * @param bool|null   $eto
     *
     * @return string
     */
    public function generateJwtTokenForPrivateChannel(string $client, string $channel, ?string $base64info = null, ?bool $eto = null): string
    {
        $jwtPayload = new JwtPayloadForPrivateChannel(
            $client,
            $channel,
            [],
            $this->getExpirationTime(),
            $base64info,
            $eto
        );

        return $this->jwtGenerator->generateToken($jwtPayload);
    }

    /**
     * @return int|null
     */
    private function getExpirationTime(): ?int
    {
        $expireAt = null;

        if (null !== $this->centrifugoJwtTtl) {
            $now = $this->dateTimeHelper->getCurrentDatetime();
            $now->add(new \DateInterval("PT{$this->centrifugoJwtTtl}S"));
            $expireAt = $now->getTimestamp();
        }

        return $expireAt;
    }
}