App\Service\User\Base

Complexity

Total Complexity

10

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Test Coverage

Coverage

97.06%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	deleteFromCache()	0	5	1
A	getUserFromDb()	0	3	1
A	validateUserName()	0	7	2
A	validateEmail()	0	8	2
A	getUserFromCache()	0	13	2
A	saveInCache()	0	5	1

<?php

declare(strict_types=1);

namespace App\Service\User;

use App\Exception\UserException;
use App\Repository\UserRepository;
use App\Service\BaseService;
use App\Service\LoggerService;
use App\Service\RedisService;
use Respect\Validation\Validator as v;

abstract class Base extends BaseService
{
    private const REDIS_KEY = 'user:%s';

    /** @var UserRepository */
    protected $userRepository;

    /** @var RedisService */
    protected $redisService;

    /** @var LoggerService */
    protected $loggerService;

    public function __construct(
        UserRepository $userRepository,
        RedisService $redisService,
        LoggerService $loggerService
    ) {
        $this->userRepository = $userRepository;
        $this->redisService = $redisService;
        $this->loggerService = $loggerService;
    }

    protected static function validateUserName(string $name): string
    {
        if (!v::alnum('ÁÉÍÓÚÑáéíóúñ.')->length(1, 100)->validate($name)) {
            throw new UserException('Invalid name.', 400);
        }

        return $name;
    }

    protected static function validateEmail(string $emailValue): string
    {
        $email = filter_var($emailValue, FILTER_SANITIZE_EMAIL);
        if (!v::email()->validate($email)) {
            throw new UserException('Invalid email', 400);
        }

        return (string) $email;
    }

    protected function getUserFromCache(int $userId): object
    {
        $redisKey = sprintf(self::REDIS_KEY, $userId);
        $key = $this->redisService->generateKey($redisKey);
        if ($this->redisService->exists($key)) {
            $data = $this->redisService->get($key);
            $user = json_decode((string) json_encode($data), false);
        } else {
            $user = $this->getUserFromDb($userId)->getData();
            $this->redisService->setex($key, $user);
        }

        return $user;
    }

    protected function getUserFromDb(int $userId): \App\Entity\User
    {
        return $this->userRepository->checkAndGetUser($userId);
    }

    protected function saveInCache(int $id, object $user): void
    {
        $redisKey = sprintf(self::REDIS_KEY, $id);
        $key = $this->redisService->generateKey($redisKey);
        $this->redisService->setex($key, $user);
    }

    protected function deleteFromCache(int $userId): void
    {
        $redisKey = sprintf(self::REDIS_KEY, $userId);
        $key = $this->redisService->generateKey($redisKey);
        $this->redisService->del([$key]);
    }
}