vendor/symfony/swiftmailer-bundle/EventListener/EmailSenderListener.php line 46

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\Bundle\SwiftmailerBundle\EventListener;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\Console\ConsoleEvents;
  16. use Symfony\Component\DependencyInjection\ContainerInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpKernel\KernelEvents;
  20. /**
  21.  * Sends emails for the memory spool.
  22.  *
  23.  * Emails are sent on the kernel.terminate event.
  24.  *
  25.  * @author Fabien Potencier <fabien@symfony.com>
  26.  */
  27. class EmailSenderListener implements EventSubscriberInterface
  28. {
  29.     private $container;
  31.     private $logger;
  33.     private $wasExceptionThrown = false;
  35.     public function __construct(ContainerInterface $container, LoggerInterface $logger = null)
  36.     {
  37.         $this->container = $container;
  38.         $this->logger = $logger;
  39.     }
  41.     public function onException()
  42.     {
  43.         $this->wasExceptionThrown = true;
  44.     }
  46.     public function onTerminate()
  47.     {
  48.         if ((!$this->container->has('mailer') && !$this->container->has('swiftmailer.mailer.default')) || $this->wasExceptionThrown) {
  49.             return;
  50.         }
  51.         $mailers = array_keys($this->container->getParameter('swiftmailer.mailers'));
  52.         foreach ($mailers as $name) {
  53.             if (method_exists($this->container, 'initialized') ? $this->container->initialized(sprintf('swiftmailer.mailer.%s', $name)) : true) {
  54.                 if ($this->container->getParameter(sprintf('swiftmailer.mailer.%s.spool.enabled', $name))) {
  55.                     $mailer = $this->container->get(sprintf('swiftmailer.mailer.%s', $name));
  56.                     $transport = $mailer->getTransport();
  57.                     if ($transport instanceof \Swift_Transport_SpoolTransport) {
  58.                         $spool = $transport->getSpool();
  59.                         if ($spool instanceof \Swift_MemorySpool) {
  60.                             try {
  61.                                 $spool->flushQueue($this->container->get(sprintf('swiftmailer.mailer.%s.transport.real', $name)));
  62.                             } catch (\Swift_TransportException $exception) {
  63.                                 if (null !== $this->logger) {
  64.                                     $this->logger->error(sprintf('Exception occurred while flushing email queue: %s', $exception->getMessage()));
  65.                                 }
  66.                             }
  67.                         }
  68.                     }
  69.                 }
  70.             }
  71.         }
  72.     }
  74.     public static function getSubscribedEvents()
  75.     {
  76.         $listeners = [
  77.             KernelEvents::EXCEPTION => 'onException',
  78.             KernelEvents::TERMINATE => 'onTerminate',
  79.         ];
  81.         if (class_exists('Symfony\Component\Console\ConsoleEvents')) {
  82.             $listeners[class_exists('Symfony\Component\Console\Event\ConsoleErrorEvent') ? ConsoleEvents::ERROR : ConsoleEvents::EXCEPTION] = 'onException';
  83.             $listeners[ConsoleEvents::TERMINATE] = 'onTerminate';
  84.         }
  86.         return $listeners;
  87.     }
  89.     public function reset()
  90.     {
  91.         $this->wasExceptionThrown = false;
  92.     }
  93. }