App\Service\Task\Base

Complexity

Total Complexity

11

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Test Coverage

Coverage

96.77%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	validateTaskName()	0	7	2
A	getTaskRepository()	0	3	1
A	__construct()	0	5	1
A	saveInCache()	0	5	1
A	getTaskFromDb()	0	3	1
A	getTaskFromCache()	0	12	2
A	validateTaskStatus()	0	7	2
A	deleteFromCache()	0	5	1

<?php

declare(strict_types=1);

namespace App\Service\Task;

use App\Entity\Task;
use App\Repository\TaskRepository;
use App\Service\BaseService;
use App\Service\RedisService;
use App\Service\LoggerService;
use Respect\Validation\Validator as v;

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

    public function __construct(
        protected TaskRepository $taskRepository,
        protected RedisService $redisService,
        protected LoggerService $loggerService
    ) {
    }

    protected function getTaskRepository(): TaskRepository
    {
        return $this->taskRepository;
    }

    protected static function validateTaskName(string $name): string
    {
        if (!v::length(1, 100)->validate($name)) {
            throw new \App\Exception\TaskException('Invalid name.', 400);
        }

        return $name;
    }

    protected static function validateTaskStatus(int $status): int
    {
        if (!v::numeric()->between(0, 1)->validate($status)) {
            throw new \App\Exception\TaskException('Invalid status', 400);
        }

        return $status;
    }

    protected function getTaskFromCache(int $taskId, int $userId): object
    {
        $redisKey = sprintf(self::REDIS_KEY, $taskId, $userId);
        $key = $this->redisService->generateKey($redisKey);
        if ($this->redisService->exists($key)) {
            $task = $this->redisService->get($key);
        } else {
            $task = $this->getTaskFromDb($taskId, $userId)->toJson();
            $this->redisService->setex($key, $task);
        }

        return $task;
    }

    protected function getTaskFromDb(int $taskId, int $userId): Task
    {
        return $this->taskRepository->checkAndGetTask($taskId, $userId);
    }

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

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