Spiral\Queue\RetryPolicy

Complexity

Total Complexity

11

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	22	4
A	isRetryable()	0	11	6
A	getDelay()	0	3	1

<?php

declare(strict_types=1);

namespace Spiral\Queue;

use Spiral\Queue\Exception\InvalidArgumentException;
use Spiral\Queue\Exception\JobException;
use Spiral\Queue\Exception\RetryableExceptionInterface;

final class RetryPolicy implements RetryPolicyInterface
{
    /**
     * @var positive-int|0

The doc comment positive-int|0 at position 0 could not be parsed: Unknown type name 'positive-int' at position 0 in positive-int|0.

     */
    private int $maxAttempts;

    /**
     * @var positive-int|0

The doc comment positive-int|0 at position 0 could not be parsed: Unknown type name 'positive-int' at position 0 in positive-int|0.

     */
    private int $delay;

    private float $multiplier;

    /**
     * @param positive-int|0 $maxAttempts

The doc comment positive-int|0 at position 0 could not be parsed: Unknown type name 'positive-int' at position 0 in positive-int|0.

     * @param positive-int|0 $delay
     *
     * @throws InvalidArgumentException
     */
    public function __construct(int $maxAttempts, int $delay, float $multiplier = 1)
    {
        if ($maxAttempts < 0) {
            throw new InvalidArgumentException(
                \sprintf('Maximum attempts must be greater than or equal to zero: `%s` given.', $maxAttempts)
            );
        }
        $this->maxAttempts = $maxAttempts;

        if ($delay < 0) {
            throw new InvalidArgumentException(
                \sprintf('Delay must be greater than or equal to zero: `%s` given.', $delay)
            );
        }
        $this->delay = $delay;

        if ($multiplier < 1) {
            throw new InvalidArgumentException(
                \sprintf('Multiplier must be greater than zero: `%s` given.', $multiplier)
            );
        }
        $this->multiplier = $multiplier;
    }

    /**
     * @param positive-int|0 $attempts

The doc comment positive-int|0 at position 0 could not be parsed: Unknown type name 'positive-int' at position 0 in positive-int|0.

     *
     * @return positive-int

The doc comment positive-int at position 0 could not be parsed: Unknown type name 'positive-int' at position 0 in positive-int.

     */
    public function getDelay(int $attempts = 0): int
    {
        return (int) \ceil($this->delay * $this->multiplier ** $attempts);
    }

    /**
     * @param positive-int|0 $attempts

The doc comment positive-int|0 at position 0 could not be parsed: Unknown type name 'positive-int' at position 0 in positive-int|0.

     */
    public function isRetryable(\Throwable $exception, int $attempts = 0): bool
    {
        if ($exception instanceof JobException && $exception->getPrevious() !== null) {
            $exception = $exception->getPrevious();
        }

        if (!$exception instanceof RetryableExceptionInterface || $this->maxAttempts === 0) {
            return false;
        }

        return $exception->isRetryable() && $attempts < $this->maxAttempts;
    }
}