Genkgo\Mail\Transport\QueueIfFailedTransport

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	send()	0	36	8

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Transport;

use Genkgo\Mail\Exception\AbstractProtocolException;
use Genkgo\Mail\Exception\QueueIfFailedException;
use Genkgo\Mail\Exception\QueueStoreException;
use Genkgo\Mail\Header\GenericHeader;
use Genkgo\Mail\MessageInterface;
use Genkgo\Mail\Queue\QueueInterface;
use Genkgo\Mail\TransportInterface;

final class QueueIfFailedTransport implements TransportInterface
{
    public const QUEUED_HEADER = 'X-Queued-At';

    /**
     * @var array|TransportInterface[]
     */
    private $transports;

    /**
     * @var array|QueueInterface[]
     */
    private $queueStorage;

    /**
     * @var bool
     */
    private $useQueue = false;

    /**
     * @param TransportInterface[] $transports
     * @param QueueInterface[] $queueStorage
     */
    public function __construct(array $transports, array $queueStorage)
    {
        $this->transports = $transports;
        $this->queueStorage = $queueStorage;
    }

    /**
     * @param MessageInterface $message
     * @throws QueueIfFailedException
     */
    public function send(MessageInterface $message): void
    {
        if ($this->useQueue === false) {
            foreach ($this->transports as $sender) {
                try {
                    $sender->send($message);
                    return;
                } catch (AbstractProtocolException $e) {

Consider adding a comment why this CATCH block is empty.

                }
            }
        }

        // switch later deliveries with this transport directly to queue
        if ($this->useQueue === false) {
            $this->useQueue = true;
        }

        foreach ($this->queueStorage as $storage) {
            try {
                if (!$message->hasHeader(self::QUEUED_HEADER)) {
                    $message = $message->withHeader(
                        new GenericHeader(
                            self::QUEUED_HEADER,
                            (new \DateTimeImmutable('now'))->format('r')
                        )
                    );
                }

                $storage->store($message);
                return;
            } catch (QueueStoreException $e) {

Consider adding a comment why this CATCH block is empty.

            }
        }

        throw new QueueIfFailedException('Cannot send nor queue this e-mail message');
    }
}