Genkgo\Mail\Queue\TimeLimitedQueue

Complexity

Total Complexity

11

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

92.59%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	store()	0	4	1
A	fetch()	0	11	3
A	hasMessageExpired()	0	11	3
A	getSubmissionTimestamp()	0	14	3

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Queue;

use Genkgo\Mail\MessageInterface;
use Genkgo\Mail\Transport\QueueIfFailedTransport;

final class TimeLimitedQueue implements QueueInterface
{
    /**
     * @var QueueInterface
     */
    private $decoratedQueue;

    /**
     * @var int
     */
    private $timeLimit;

    public function __construct(QueueInterface $queue, int $timeLimit)
    {
        $this->decoratedQueue = $queue;
        $this->timeLimit = $timeLimit;
    }

    /**
     * {@inheritdoc}
     */
    public function store(MessageInterface $message): void
    {
        $this->decoratedQueue->store($message);
    }

    /**
     * {@inheritdoc}
     */
    public function fetch(): MessageInterface
    {
        while ($message = $this->decoratedQueue->fetch()) {
            if ($this->hasMessageExpired($message)) {
                continue;
            }
            break;
        }

        return $message;
    }

    /**
     * @param MessageInterface $message
     * @return bool
     */
    private function hasMessageExpired(MessageInterface $message): bool
    {
        if ($this->timeLimit === 0) {
            return false;
        }
        if ($this->getSubmissionTimestamp($message) + $this->timeLimit > \time()) {
            return false;
        }

        return true;
    }

    /**
     * @param MessageInterface $message
     * @return int
     */
    private function getSubmissionTimestamp(MessageInterface $message): int
    {
        $queuedAt = $message->getHeader(QueueIfFailedTransport::QUEUED_HEADER);
        if (!\is_array($queuedAt)) {
            $queuedAt = \iterator_to_array($queuedAt);
        }

        $header = \reset($queuedAt);
        if ($header === false) {
            throw new \UnexpectedValueException('Cannot extract queue header from message');
        }

        return (int) \strtotime($header->getValue()->getRaw());
    }
}