App\Application\User\Service\UserService

Complexity

Total Complexity

6

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Test Coverage

Coverage

85%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	logout()	0	4	1
A	login()	0	22	4
A	__construct()	0	8	1

<?php

declare(strict_types=1);

namespace App\Application\User\Service;

use App\Application\Exception\BadRequestException;
use App\Application\User\Entity\User;
use App\Queue\LoggingAuthorizationHandler;
use App\Queue\UserLoggedInMessage;
use Yiisoft\Auth\IdentityInterface;
use Yiisoft\Auth\IdentityRepositoryInterface;
use Yiisoft\User\CurrentUser;
use Yiisoft\Yii\Queue\QueueFactoryInterface;
use Yiisoft\Definitions\Exception\InvalidConfigException;

final class UserService
{
    private IdentityRepositoryInterface $identityRepository;
    private CurrentUser $currentUser;
    private QueueFactoryInterface $queueFactory;

    public function __construct(
        CurrentUser $currentUser,
        IdentityRepositoryInterface $identityRepository,
        QueueFactoryInterface $queueFactory
    ) {
        $this->currentUser = $currentUser;
        $this->identityRepository = $identityRepository;
        $this->queueFactory = $queueFactory;
    }

    /**
     * @param string $login
     * @param string $password
     *
     * @throws InvalidConfigException
     * @throws BadRequestException
     *
     * @return IdentityInterface
     */
    public function login(string $login, string $password): IdentityInterface
    {
        $identity = $this->identityRepository->findByLogin($login);
        if ($identity === null) {
            throw new BadRequestException('No such user.');
        }

        if (!$identity->validatePassword($password)) {
            throw new BadRequestException('Invalid password.');
        }

        if (!$this->currentUser->login($identity)) {
            throw new BadRequestException();
        }

        $identity->resetToken();
        $this->identityRepository->save($identity);

        $queueMessage = new UserLoggedInMessage($identity->getId(), time());
        $this->queueFactory->get(LoggingAuthorizationHandler::CHANNEL)->push($queueMessage);

        return $identity;
    }

    public function logout(User $user): void
    {
        $user->resetToken();
        $this->identityRepository->save($user);
    }
}