src/Listener/MessagingListener.php line 75

Open in your IDE?
  1. <?php
  3. namespace App\Listener;
  5. use App\Controller\MessengerController;
  6. use App\Entity\Messaging\Message;
  7. use App\Entity\Messaging\Request;
  8. use App\Entity\User;
  9. use App\Service\Mailer;
  10. use Doctrine\Bundle\DoctrineBundle\EventSubscriber\EventSubscriberInterface;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Doctrine\ORM\Event\LifecycleEventArgs;
  13. use Doctrine\ORM\Events;
  14. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  15. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  16. use Symfony\Component\Security\Http\Event\InteractiveLoginEvent;
  18. class MessagingListener implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var TokenStorageInterface
  22.      */
  23.     private $storage;
  24.     /**
  25.      * @var EntityManagerInterface
  26.      */
  27.     private $em;
  28.     /**
  29.      * @var Mailer
  30.      */
  31.     private $mailer;
  33.     public function __construct(TokenStorageInterface $storage, EntityManagerInterface $em, Mailer $mailer)
  34.     {
  35.         $this->storage = $storage;
  36.         $this->em = $em;
  37.         $this->mailer = $mailer;
  38.     }
  40.     public function getSubscribedEvents()
  41.     {
  42.         return [Events::prePersist];
  43.     }
  45.     private function setLatestMessage(Message $message)
  46.     {
  47.         $message->getRequest()->setLatest($message);
  48.         $md = $this->em->getClassMetadata(Request::class);
  49.         $this->em->getUnitOfWork()->computeChangeSet($md, $message->getRequest());
  50.     }
  52.     public function prePersist(LifecycleEventArgs $args)
  53.     {
  54.         $entity = $args->getEntity();
  55.         if ($entity instanceof Message) {
  56.             $this->setLatestMessage($entity);
  58.             if (!$entity->shouldNotify()) {
  59.                 return;
  60.             }
  61.             // Send a notification email
  62.             if ($entity->getAuthor()->isStaff()) {
  63.                 $user = $entity->getRequest()->getAuthor() === $entity->getAuthor()
  64.                     ? $entity->getRequest()->getRecipient()
  65.                     : $entity->getRequest()->getAuthor();
  66.                 if (!$user->getSettings()->isMessengerNotificationSent()) {
  67.                     $user->getSettings()->setMessengerNotificationSent(true);
  68.                     $email = $this->mailer->template($user, 'messenger-notification');
  69.                     $this->mailer->send($email);
  70.                 }
  71.             }
  72.         }
  73.     }
  75.     public function onKernelController(ControllerEvent $event)
  76.     {
  77.         $controller = $event->getController();
  78.         if (!is_array($controller)) {
  79.             return;
  80.         }
  81.         if (!$controller[0] instanceof MessengerController) {
  82.             return;
  83.         }
  84.         // Reset notification lock
  85.         $user = $this->storage->getToken()->getUser();
  86.         if (!$user instanceof User) {
  87.             return;
  88.         }
  89.         if (!$user->getSettings()->isMessengerNotificationSent()) {
  90.             return;
  91.         }
  92.         $user->getSettings()->setMessengerNotificationSent(false);
  93.         $this->em->flush();
  94.     }
  96.     public function onSecurityInteractiveLogin(InteractiveLoginEvent $event)
  97.     {
  98.         // Reset notification lock
  100.         /** @var User $user */
  101.         $user = $event->getAuthenticationToken()->getUser();
  102.         if (!$user->getSettings()->isMessengerNotificationSent()) {
  103.             return;
  104.         }
  105.         $user->getSettings()->setMessengerNotificationSent(false);
  106.         $this->em->flush();
  107.     }
  108. }