Tarantool\JobQueue\Handler\RecurrenceHandler

Complexity

Total Complexity

3

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	11	2
A	__construct()	0	3	1

<?php

namespace Tarantool\JobQueue\Handler;

use Tarantool\JobQueue\JobBuilder\JobOptions;
use Tarantool\Queue\Options;
use Tarantool\Queue\Queue;
use Tarantool\Queue\Task;

class RecurrenceHandler implements Handler
{
    private $handler;

    public function __construct(Handler $handler)
    {
        $this->handler = $handler;
    }

    public function handle(Task $task, Queue $queue): void
    {
        $data = $task->getData();

        if (empty($data[JobOptions::RECURRENCE])) {
            $this->handler->handle($task, $queue);

            return;
        }

        $queue->release($task->getId(), [Options::DELAY => $data[JobOptions::RECURRENCE]]);
    }
}