vendor/symfony/mailer/Mailer.php line 35

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\Mailer;
  14. use Psr\EventDispatcher\EventDispatcherInterface;
  15. use Symfony\Component\EventDispatcher\Event;
  16. use Symfony\Component\EventDispatcher\LegacyEventDispatcherProxy;
  17. use Symfony\Component\Mailer\Event\MessageEvent;
  18. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  19. use Symfony\Component\Mailer\Messenger\SendEmailMessage;
  20. use Symfony\Component\Mailer\Transport\TransportInterface;
  21. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  22. use Symfony\Component\Messenger\MessageBusInterface;
  23. use Symfony\Component\Mime\RawMessage;
  24. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface as SymfonyEventDispatcherInterface;
  26. /**
  27. * @author Fabien Potencier <fabien@symfony.com>
  28. */
  29. final class Mailer implements MailerInterface
  30. {
  31. private $transport;
  32. private $bus;
  33. private $dispatcher;
  35. public function __construct(TransportInterface $transport, MessageBusInterface $bus = null, EventDispatcherInterface $dispatcher = null)
  36. {
  37. $this->transport = $transport;
  38. $this->bus = $bus;
  39. $this->dispatcher = class_exists(Event::class) && $dispatcher instanceof SymfonyEventDispatcherInterface ? LegacyEventDispatcherProxy::decorate($dispatcher) : $dispatcher;
  40. }
  42. public function send(RawMessage $message, Envelope $envelope = null): void
  43. {
  44. if (null === $this->bus) {
  45. $this->transport->send($message, $envelope);
  47. return;
  48. }
  50. if (null !== $this->dispatcher) {
  51. $clonedMessage = clone $message;
  52. $clonedEnvelope = null !== $envelope ? clone $envelope : Envelope::create($clonedMessage);
  53. $event = new MessageEvent($clonedMessage, $clonedEnvelope, (string) $this->transport, true);
  54. $this->dispatcher->dispatch($event);
  55. }
  57. try {
  58. $this->bus->dispatch(new SendEmailMessage($message, $envelope));
  59. } catch (HandlerFailedException $e) {
  60. foreach ($e->getNestedExceptions() as $nested) {
  61. if ($nested instanceof TransportExceptionInterface) {
  62. throw $nested;
  63. }
  64. }
  65. throw $e;
  66. }
  67. }
  68. }