src/Aqarmap/Bundle/MainBundle/EventListener/BouncedEmailListener.php line 46

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\MainBundle\EventListener;
  5. use Aqarmap\Bundle\MainBundle\Event\SNSNotificationsEvent;
  6. use Aqarmap\Bundle\NotificationBundle\Model\SESNotificationData;
  7. use Aqarmap\Bundle\UserBundle\Entity\User;
  8. use Aqarmap\Bundle\UserBundle\Services\UserManager;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. /**
  13.  * Bounced Email Listener
  14.  * This listener does some actions, such as, disabling user account, pause notifiers, ..etc.
  15.  */
  16. class BouncedEmailListener implements EventSubscriberInterface
  17. {
  18.     private EntityManagerInterface $em;
  19.     private UserManager $userManager;
  21.     public function __construct(EntityManagerInterface $em, UserManager $userManager)
  22.     {
  23.         $this->em = $em;
  24.         $this->userManager = $userManager;
  25.     }
  27.     public function disabledAccount(SNSNotificationsEvent $event): void
  28.     {
  29.         /** @var SESNotificationData $message */
  30.         $message = $event->getMessage();
  32.         if (preg_match('/bounce/i', $message->getEventType())) {
  33.             if (preg_match('/permanent/i', $message->getBounce()->getBounceType())) {
  34.                 foreach ($message->getMail()->getDestination() as $email) {
  35.                     /** @var User $user */
  36.                     $user = $this->em->getRepository(User::class)->findOneBy(['emailCanonical' => $email]);
  37.                     if ($user) {
  38.                         $user->setHasEmail(false);
  39.                         $this->userManager->disable($user);
  40.                     }
  41.                 }
  42.             }
  43.         }
  44.     }
  46.     public function globalUnsubscribe(SNSNotificationsEvent $event): void
  47.     {
  48.         $message = $event->getMessage();
  50.         foreach ($message->getMail()->getDestination() as $email) {
  51.             /** @var User $user */
  52.             $user = $this->em->getRepository(User::class)->findOneBy(['emailCanonical' => $email]);
  54.             if ($user) {
  55.                 $this->userManager->globalUnsubscribe($user);
  56.             }
  57.         }
  58.     }
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             SNSNotificationsEvent::SNS_NOTIFICATION_BOUNCE => ['disabledAccount'],
  64.             SNSNotificationsEvent::SNS_NOTIFICATION_COMPLAINT => ['globalUnsubscribe'],
  65.         ];
  66.     }
  67. }