vendor/symfony/notifier/Channel/EmailChannel.php line 36

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Notifier\Channel;
  14. use Symfony\Component\Mailer\Envelope;
  15. use Symfony\Component\Mailer\Messenger\SendEmailMessage;
  16. use Symfony\Component\Mailer\Transport\TransportInterface;
  17. use Symfony\Component\Messenger\MessageBusInterface;
  18. use Symfony\Component\Mime\Email;
  19. use Symfony\Component\Notifier\Exception\LogicException;
  20. use Symfony\Component\Notifier\Message\EmailMessage;
  21. use Symfony\Component\Notifier\Notification\EmailNotificationInterface;
  22. use Symfony\Component\Notifier\Notification\Notification;
  23. use Symfony\Component\Notifier\Recipient\EmailRecipientInterface;
  24. use Symfony\Component\Notifier\Recipient\RecipientInterface;
  26. /**
  27.  * @author Fabien Potencier <fabien@symfony.com>
  28.  */
  29. class EmailChannel implements ChannelInterface
  30. {
  31.     private $transport;
  32.     private $bus;
  33.     private $from;
  34.     private $envelope;
  36.     public function __construct(TransportInterface $transport = null, MessageBusInterface $bus = null, string $from = null, Envelope $envelope = null)
  37.     {
  38.         if (null === $transport && null === $bus) {
  39.             throw new LogicException(sprintf('"%s" needs a Transport or a Bus but both cannot be "null".', static::class));
  40.         }
  42.         $this->transport = $transport;
  43.         $this->bus = $bus;
  44.         $this->from = $from ?: ($envelope ? $envelope->getSender() : null);
  45.         $this->envelope = $envelope;
  46.     }
  48.     public function notify(Notification $notification, RecipientInterface $recipient, string $transportName = null): void
  49.     {
  50.         $message = null;
  51.         if ($notification instanceof EmailNotificationInterface) {
  52.             $message = $notification->asEmailMessage($recipient, $transportName);
  53.         }
  55.         $message = $message ?: EmailMessage::fromNotification($notification, $recipient, $transportName);
  56.         $email = $message->getMessage();
  57.         if ($email instanceof Email) {
  58.             if (!$email->getFrom()) {
  59.                 if (null === $this->from) {
  60.                     throw new LogicException(sprintf('To send the "%s" notification by email, you should either configure a global "from" header, set a sender in the global "envelope" of the mailer configuration or set a "from" header in the "asEmailMessage()" method.', get_debug_type($notification)));
  61.                 }
  63.                 $email->from($this->from);
  64.             }
  66.             if (!$email->getTo()) {
  67.                 $email->to($recipient->getEmail());
  68.             }
  69.         }
  71.         if (null !== $this->envelope) {
  72.             $message->envelope($this->envelope);
  73.         }
  75.         if (null !== $transportName) {
  76.             $message->transport($transportName);
  77.         }
  79.         if (null === $this->bus) {
  80.             $this->transport->send($message->getMessage(), $message->getEnvelope());
  81.         } else {
  82.             $this->bus->dispatch(new SendEmailMessage($message->getMessage(), $message->getEnvelope()));
  83.         }
  84.     }
  86.     public function supports(Notification $notification, RecipientInterface $recipient): bool
  87.     {
  88.         return $recipient instanceof EmailRecipientInterface;
  89.     }
  90. }