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 handles bounced and complained emails by globally unsubscribing affected users.
  15. */
  16. class BouncedEmailListener implements EventSubscriberInterface
  17. {
  18. public function __construct(private readonly EntityManagerInterface $em, private readonly UserManager $userManager)
  19. {
  20. }
  22. public function handleBouncedEmail(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->globalUnsubscribe($user, false);
  40. }
  41. }
  43. $this->em->flush();
  44. }
  45. }
  46. }
  48. public function globalUnsubscribe(SNSNotificationsEvent $event): void
  49. {
  50. $message = $event->getMessage();
  52. foreach ($message->getMail()->getDestination() as $email) {
  53. /** @var User $user */
  54. $user = $this->em->getRepository(User::class)->findOneBy(['emailCanonical' => $email]);
  56. if ($user) {
  57. $this->userManager->globalUnsubscribe($user);
  58. }
  59. }
  60. }
  62. public static function getSubscribedEvents(): array
  63. {
  64. return [
  65. SNSNotificationsEvent::SNS_NOTIFICATION_BOUNCE => ['handleBouncedEmail'],
  66. SNSNotificationsEvent::SNS_NOTIFICATION_COMPLAINT => ['globalUnsubscribe'],
  67. ];
  68. }
  69. }