Lamoda\QueueBundle\Service\DelayService

Complexity

Total Complexity

3

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

83.33%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	delayQueue()	0	11	1
A	getStartDateTime()	0	4	1

<?php

declare(strict_types=1);

namespace Lamoda\QueueBundle\Service;

use DateTime;
use Lamoda\QueueBundle\Entity\QueueEntityInterface;

class DelayService
{
    /**
     * @var ResolverStrategyService
     */
    protected $strategyService;


    public function __construct(ResolverStrategyService $strategyService)
    {
        $this->strategyService = $strategyService;
    }

    public function delayQueue(QueueEntityInterface $queue): QueueEntityInterface
    {
        $strategy         = $this->strategyService->getStrategy($queue->getName());
        $iteration        = $queue->getAttempts() ?? 1;
        $newDelayInterval = $strategy->generateInterval($iteration);
        $delayUntil       = $this->getStartDateTime()->add($newDelayInterval);

        $queue->setWaiting($delayUntil);

        return $queue;
    }

    protected function getStartDateTime(): DateTime
    {
        return new DateTime();
    }
}