Genkgo\Mail\Queue\TimeLimitedQueue

Complexity

Total Complexity

9

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

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	6	1

<?php

namespace Genkgo\Mail\Queue;

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

/**
 * Class TimeLimitedQueue
 * @package Genkgo\Mail\Queue
 */
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);

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