Mailer.php

Go to the documentation of this file.

<?php
 
/*
 * This file is part of the TYPO3 CMS project.
 *
 * It is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License, either version 2
 * of the License, or any later version.
 *
 * For the full copyright and license information, please read the
 * LICENSE.txt file that was distributed with this source code.
 *
 * The TYPO3 project - inspiring people to share!
 */
 
namespace ‪TYPO3\CMS\Core\Mail;
 
use Psr\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\Mailer\Envelope;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\Mailer\SentMessage;
use Symfony\Component\Mailer\Transport\TransportInterface;
use Symfony\Component\Mime\Address;
use Symfony\Component\Mime\Email;
use Symfony\Component\Mime\RawMessage;
use ‪TYPO3\CMS\Core\Exception as ‪CoreException;
use ‪TYPO3\CMS\Core\Mail\Event\AfterMailerInitializationEvent;
use ‪TYPO3\CMS\Core\Utility\GeneralUtility;
use ‪TYPO3\CMS\Core\Utility\MailUtility;
 
class ‪Mailer implements MailerInterface
{
    protected ‪$transport;
 
    protected ‪$mailSettings = [];
 
    protected ‪$sentMessage;
 
    protected ‪$mailerHeader = 'TYPO3';
 
    protected ‪$eventDispatcher;
 
    public function ‪__construct(TransportInterface ‪$transport = null, EventDispatcherInterface ‪$eventDispatcher = null)
    {
        if (‪$transport !== null) {
            $this->transport = ‪$transport;
        } else {
            if (empty($this->mailSettings)) {
                $this->‪injectMailSettings();
            }
            try {
                $this->‪initializeTransport();
            } catch (\‪Exception $e) {
                throw new ‪CoreException($e->getMessage(), 1291068569);
            }
        }
        if (‪$eventDispatcher !== null) {
            $this->eventDispatcher = ‪$eventDispatcher;
            $this->eventDispatcher->dispatch(new ‪AfterMailerInitializationEvent($this));
        }
    }
 
    public function ‪send(RawMessage $message, Envelope $envelope = null): void
    {
        if ($message instanceof Email) {
            // Ensure to always have a From: header set
            if (empty($message->getFrom())) {
                $address = ‪MailUtility::getSystemFromAddress();
                if ($address) {
                    $name = ‪MailUtility::getSystemFromName();
                    if ($name) {
                        $from = new Address($address, $name);
                    } else {
                        $from = new Address($address);
                    }
                    $message->from($from);
                }
            }
            if (empty($message->getReplyTo())) {
                $replyTo = ‪MailUtility::getSystemReplyTo();
                if (!empty($replyTo)) {
                    $address = key($replyTo);
                    if ($address === 0) {
                        $replyTo = new Address($replyTo[$address]);
                    } else {
                        $replyTo = new Address((string)$address, reset($replyTo));
                    }
                    $message->replyTo($replyTo);
                }
            }
            $message->getHeaders()->addTextHeader('X-Mailer', $this->mailerHeader);
        }
 
        $this->sentMessage = $this->transport->send($message, $envelope);
    }
 
    public function ‪getSentMessage(): ?SentMessage
    {
        return ‪$this->sentMessage;
    }
 
    public function ‪getTransport(): TransportInterface
    {
        return ‪$this->transport;
    }
 
    private function ‪initializeTransport()
    {
        $this->transport = $this->‪getTransportFactory()->‪get($this->mailSettings);
    }
 
    public function ‪injectMailSettings(array ‪$mailSettings = null)
    {
        if (is_array(‪$mailSettings)) {
            $this->mailSettings = ‪$mailSettings;
        } else {
            $this->mailSettings = (array)‪$GLOBALS['TYPO3_CONF_VARS']['MAIL'];
        }
    }
 
    public function ‪getRealTransport(): TransportInterface
    {
        ‪$mailSettings = !empty($this->mailSettings) ? $this->mailSettings : (array)‪$GLOBALS['TYPO3_CONF_VARS']['MAIL'];
        unset(‪$mailSettings['transport_spool_type']);
        return $this->‪getTransportFactory()->‪get(‪$mailSettings);
    }
 
    protected function ‪getTransportFactory(): ‪TransportFactory
    {
        return GeneralUtility::makeInstance(TransportFactory::class);
    }
}