vendor/symfony/monolog-bridge/Handler/SwiftMailerHandler.php line 47

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\Bridge\Monolog\Handler;
  14. use Monolog\Handler\SwiftMailerHandler as BaseSwiftMailerHandler;
  15. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  16. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  18. /**
  19.  * Extended SwiftMailerHandler that flushes mail queue if necessary.
  20.  *
  21.  * @author Philipp Kräutli <pkraeutli@astina.ch>
  22.  *
  23.  * @final
  24.  */
  25. class SwiftMailerHandler extends BaseSwiftMailerHandler
  26. {
  27.     protected $transport;
  29.     protected $instantFlush = false;
  31.     public function setTransport(\Swift_Transport $transport)
  32.     {
  33.         $this->transport = $transport;
  34.     }
  36.     /**
  37.      * After the kernel has been terminated we will always flush messages.
  38.      */
  39.     public function onKernelTerminate(TerminateEvent $event)
  40.     {
  41.         $this->instantFlush = true;
  42.     }
  44.     /**
  45.      * After the CLI application has been terminated we will always flush messages.
  46.      */
  47.     public function onCliTerminate(ConsoleTerminateEvent $event)
  48.     {
  49.         $this->instantFlush = true;
  50.     }
  52.     /**
  53.      * {@inheritdoc}
  54.      */
  55.     protected function send($content, array $records): void
  56.     {
  57.         parent::send($content, $records);
  59.         if ($this->instantFlush) {
  60.             $this->flushMemorySpool();
  61.         }
  62.     }
  64.     /**
  65.      * {@inheritdoc}
  66.      */
  67.     public function reset(): void
  68.     {
  69.         $this->flushMemorySpool();
  70.     }
  72.     /**
  73.      * Flushes the mail queue if a memory spool is used.
  74.      */
  75.     private function flushMemorySpool()
  76.     {
  77.         $mailerTransport = $this->mailer->getTransport();
  78.         if (!$mailerTransport instanceof \Swift_Transport_SpoolTransport) {
  79.             return;
  80.         }
  82.         $spool = $mailerTransport->getSpool();
  83.         if (!$spool instanceof \Swift_MemorySpool) {
  84.             return;
  85.         }
  87.         if (null === $this->transport) {
  88.             throw new \Exception('No transport available to flush mail queue.');
  89.         }
  91.         $spool->flushQueue($this->transport);
  92.     }
  93. }