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

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\DependencyInjection\ContainerInterface;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  17. use Symfony\Component\Console\ConsoleEvents;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  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 {
  29.     private $container;
  30.     private $logger;
  31.     private $wasExceptionThrown = false;
  33.     public function __construct(ContainerInterface $container, LoggerInterface $logger = null) {
  34.         $this->container = $container;
  35.         $this->logger = $logger;
  36.     }
  38.     public function onException() {
  39.         $this->wasExceptionThrown = true;
  40.     }
  42.     public function onTerminate() {
  43.         if (!$this->container->has('mailer') || $this->wasExceptionThrown) {
  44.             return;
  45.         }
  46.         $mailers = array_keys($this->container->getParameter('swiftmailer.mailers'));
  47.         foreach ($mailers as $name) {
  48.             if (method_exists($this->container, 'initialized') ? $this->container->initialized(sprintf('swiftmailer.mailer.%s', $name)) : true) {
  49.                 if ($this->container->getParameter(sprintf('swiftmailer.mailer.%s.spool.enabled', $name))) {
  50.                     $mailer = $this->container->get(sprintf('swiftmailer.mailer.%s', $name));
  51.                     $transport = $mailer->getTransport();
  52.                     if ($transport instanceof \Swift_Transport_SpoolTransport) {
  53.                         $spool = $transport->getSpool();
  54.                         if ($spool instanceof \Swift_MemorySpool) {
  55.                             try {
  56.                                 $spool->flushQueue($this->container->get(sprintf('swiftmailer.mailer.%s.transport.real', $name)));
  57.                             } catch (\Swift_TransportException $exception) {
  58.                                 if (null !== $this->logger) {
  59.                                     $this->logger->error(sprintf('Exception occurred while flushing email queue: %s', $exception->getMessage()));
  60.                                 }
  61.                             }
  62.                         }
  63.                     }
  64.                 }
  65.             }
  66.         }
  67.     }
  69.     public static function getSubscribedEvents() {
  70.         $listeners = [
  71.             KernelEvents::EXCEPTION => 'onException',
  72.             KernelEvents::TERMINATE => 'onTerminate',
  73.         ];
  75.         if (class_exists('Symfony\Component\Console\ConsoleEvents')) {
  76.             $listeners[class_exists('Symfony\Component\Console\Event\ConsoleErrorEvent') ? ConsoleEvents::ERROR : ConsoleEvents::EXCEPTION] = 'onException';
  77.             $listeners[ConsoleEvents::TERMINATE] = 'onTerminate';
  78.         }
  80.         return $listeners;
  81.     }
  83.     public function reset() {
  84.         $this->wasExceptionThrown = false;
  85.     }
  87. }