Genkgo\Mail\Transport\PhpMailTransport

Complexity

Total Complexity

9

Size/Duplication

Total Lines	142
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

94%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	send()	0	28	2
A	extractSingleHeader()	0	11	2
B	extractHeaders()	0	26	1
A	constructParameters()	0	11	2
A	newReplaceMailMethod()	0	10	1

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Transport;

use Genkgo\Mail\Exception\EnvelopeException;
use Genkgo\Mail\Header\HeaderLine;
use Genkgo\Mail\HeaderInterface;
use Genkgo\Mail\MessageInterface;
use Genkgo\Mail\TransportInterface;

final class PhpMailTransport implements TransportInterface
{

    /**
     * @var EnvelopeFactory
     */
    private $envelopFactory;
    /**
     * @var array
     */
    private $parameters;
    /**
     * @var \Closure
     */
    private $replacedMailMethod;

    /**
     * PhpMailTransport constructor.
     * @param EnvelopeFactory $envelopFactory
     * @param array $parameters
     */
    public function __construct(EnvelopeFactory $envelopFactory, array $parameters = [])
    {
        $this->envelopFactory = $envelopFactory;
        $this->parameters = $parameters;
    }

    /**
     * @param MessageInterface $message
     * @return void
     */
    public function send(MessageInterface $message): void
    {
        $to = $this->extractSingleHeader($message, 'to');
        $subject = $this->extractSingleHeader($message, 'subject');
        $headers = $this->extractHeaders($message);
        $parameters = $this->constructParameters($message);

        if ($this->replacedMailMethod === null) {
            // @codeCoverageIgnoreStart
            mail(
                $to,
                $subject,
                (string)$message->getBody(),
                $headers,
                $parameters
            );
            // @codeCoverageIgnoreEnd
        } else {
            $callback = $this->replacedMailMethod;
            $callback(
                $to,
                $subject,
                (string)$message->getBody(),
                $headers,
                $parameters
            );
        }
    }

    /**
     * @param MessageInterface $message
     * @param string $name
     * @return string
     */
    private function extractSingleHeader(MessageInterface $message, string $name): string
    {
        $headers = $message->getHeader($name);
        if (count($headers) === 0) {
            throw new \InvalidArgumentException(
                'Cannot transport message without header ' . $name
            );
        }

        return (string)reset($headers)->getValue();
    }

    /**
     * @param MessageInterface $message
     * @return string
     */
    private function extractHeaders(MessageInterface $message): string
    {
        return implode("\r\n",
            array_values(
                array_filter(
                    array_map(
                        function (array $headers) {
                            return implode(
                                "\r\n",
                                array_map(
                                    function (HeaderInterface $header) {
                                        return (string)(new HeaderLine($header));
                                    },
                                    $headers
                                )
                            );
                        },
                        $message
                            ->withoutHeader('to')
                            ->withoutHeader('subject')
                            ->getHeaders()
                    )
                )
            )
        );
    }

    /**
     * @param MessageInterface $message
     * @return string
     * @throws EnvelopeException
     */
    private function constructParameters(MessageInterface $message): string
    {
        $envelop = $this->envelopFactory->make($message);
        if (preg_match('/\"/', $envelop->getAddress())) {
            throw new EnvelopeException(
                'Unable to guarantee injection-free envelop'
            );
        }

        return implode(' ', array_merge($this->parameters, ['-f' . (string)$envelop]));
    }

    /**
     * @param \Closure $callback
     * @param EnvelopeFactory $envelopFactory
     * @param array $parameters
     * @return PhpMailTransport
     */
    public static function newReplaceMailMethod(
        \Closure $callback,
        EnvelopeFactory $envelopFactory,
        array $parameters = []
    ): PhpMailTransport
    {
        $transport = new self($envelopFactory, $parameters);
        $transport->replacedMailMethod = $callback;
        return $transport;
    }
}