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

  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. public function __construct(private readonly EntityManagerInterface $em, private readonly UserManager $userManager)
  19. {
  20. }
  22. public function disabledAccount(SNSNotificationsEvent $event): void
  23. {
  24. /** @var SESNotificationData $message */
  25. $message = $event->getMessage();
  27. if (preg_match('/bounce/i', (string) $message->getEventType())) {
  28. if (preg_match('/permanent/i', $message->getBounce()->getBounceType())) {
  29. foreach ($message->getMail()->getDestination() as $email) {
  30. /** @var User $user */
  31. $user = $this->em->getRepository(User::class)->findOneBy(['emailCanonical' => $email]);
  32. if ($user) {
  33. $user->setHasEmail(false);
  34. $this->userManager->disable($user);
  35. }
  36. }
  37. }
  38. }
  39. }
  41. public function globalUnsubscribe(SNSNotificationsEvent $event): void
  42. {
  43. $message = $event->getMessage();
  45. foreach ($message->getMail()->getDestination() as $email) {
  46. /** @var User $user */
  47. $user = $this->em->getRepository(User::class)->findOneBy(['emailCanonical' => $email]);
  49. if ($user) {
  50. $this->userManager->globalUnsubscribe($user);
  51. }
  52. }
  53. }
  55. public static function getSubscribedEvents(): array
  56. {
  57. return [
  58. SNSNotificationsEvent::SNS_NOTIFICATION_BOUNCE => ['disabledAccount'],
  59. SNSNotificationsEvent::SNS_NOTIFICATION_COMPLAINT => ['globalUnsubscribe'],
  60. ];
  61. }
  62. }