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->getBounce()->getBouncedRecipients() as $recipient) {
  30. $email = $recipient['emailAddress'] ?? null;
  31. if (!$email) {
  32. continue;
  33. }
  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. }