src/Listener/MailArchiveListener.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\Listener;
  5. use App\Entity\MailArchive\Message;
  6. use App\Service\Mailer;
  7. use Doctrine\Bundle\DoctrineBundle\EventSubscriber\EventSubscriberInterface;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Doctrine\ORM\Events;
  10. use Doctrine\Persistence\Event\LifecycleEventArgs;
  11. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  12. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  14. class MailArchiveListener implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var EntityManagerInterface
  18.      */
  19.     private $em;
  20.     /**
  21.      * @var Mailer
  22.      */
  23.     private $mailer;
  24.     /**
  25.      * @var string
  26.      */
  27.     private $fileStorage;
  29.     public function getSubscribedEvents()
  30.     {
  31.         return [Events::postLoad];
  32.     }
  34.     public function __construct(EntityManagerInterface $em, Mailer $mailer, string $fileStorage)
  35.     {
  36.         $this->em = $em;
  37.         $this->mailer = $mailer;
  38.         $this->fileStorage = $fileStorage;
  39.     }
  41.     private function flushArchive()
  42.     {
  43.         $this->mailer->flushArchive();
  44.     }
  46.     public function onKernelTerminate(TerminateEvent $event)
  47.     {
  48.         $this->flushArchive();
  49.     }
  51.     public function onConsoleTerminate(ConsoleTerminateEvent $event)
  52.     {
  53.         $this->flushArchive();
  54.     }
  56.     public function postLoad(LifecycleEventArgs $args)
  57.     {
  58.         $message = $args->getObject();
  59.         if (!$message instanceof Message) {
  60.             return;
  61.         }
  63.         $body = sprintf('%s/mail-archive/%d.html', $this->fileStorage, $message->getId());
  64.         $export = sprintf('%s/mail-archive/%d.eml', $this->fileStorage, $message->getId());
  65.         if (is_file($body)) {
  66.             $message->setBody(file_get_contents($body));
  67.         }
  68.         if (is_file($export)) {
  69.             $message->setExport(file_get_contents($export));
  70.         }
  71.     }
  72. }