vendor/bitbag/mailchimp-plugin/src/EventListener/CustomerNewsletterListener.php line 33

Open in your IDE?
  1. <?php
  3. /*
  4. * This file was created by developers working at BitBag
  5. * Do you need more information about us and what we do? Visit our https://bitbag.io website!
  6. * We are hiring developers from all over the world. Join us and start your new, exciting adventure and become part of us: https://bitbag.io/career
  7. */
  9. declare(strict_types=1);
  11. namespace BitBag\SyliusMailChimpPlugin\EventListener;
  13. use BitBag\SyliusMailChimpPlugin\Handler\NewsletterSubscriptionHandler;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Sylius\Component\Core\Model\CustomerInterface;
  16. use Sylius\Component\Resource\Exception\UnexpectedTypeException;
  17. use Symfony\Component\EventDispatcher\GenericEvent;
  19. final class CustomerNewsletterListener
  20. {
  21. /** @var NewsletterSubscriptionHandler */
  22. private $newsletterSubscriptionHandler;
  24. /** @var EntityManagerInterface */
  25. private $entityManager;
  27. public function __construct(NewsletterSubscriptionHandler $newsletterSubscriptionHandler, EntityManagerInterface $entityManager)
  28. {
  29. $this->newsletterSubscriptionHandler = $newsletterSubscriptionHandler;
  30. $this->entityManager = $entityManager;
  31. }
  33. public function customerCreateEvent(GenericEvent $event): void
  34. {
  35. $customer = $event->getSubject();
  37. if (!$customer instanceof CustomerInterface) {
  38. throw new UnexpectedTypeException(
  39. $customer,
  40. CustomerInterface::class
  41. );
  42. }
  44. $customer->isSubscribedToNewsletter() === false ? $this->unsubscribe($customer) : $this->subscribe($customer);
  45. }
  47. public function customerPostUpdateEvent(GenericEvent $event): void
  48. {
  49. $this->customerCreateEvent($event);
  50. }
  52. public function customerPreUpdateEvent(GenericEvent $event): void
  53. {
  54. $customer = $event->getSubject();
  56. if (!$customer instanceof CustomerInterface) {
  57. throw new UnexpectedTypeException(
  58. $customer,
  59. CustomerInterface::class
  60. );
  61. }
  63. $unitOfWork = $this->entityManager->getUnitOfWork();
  64. $unitOfWork->computeChangeSets();
  65. $changelist = $unitOfWork->getEntityChangeSet($customer);
  67. $oldEmail = $this->getOldEmailFromChangeList($changelist);
  69. if (null !== $oldEmail) {
  70. $this->newsletterSubscriptionHandler->unsubscribeEmail($oldEmail);
  71. }
  72. }
  74. private function subscribe(CustomerInterface $customer): void
  75. {
  76. if (null !== $customer->getEmail()) {
  77. $this->newsletterSubscriptionHandler->subscribe($customer->getEmail());
  78. }
  79. }
  81. private function unsubscribe(CustomerInterface $customer): void
  82. {
  83. $this->newsletterSubscriptionHandler->unsubscribe($customer);
  84. }
  86. private function getOldEmailFromChangeList(array $changelist): ?string
  87. {
  88. if (!array_key_exists('email', $changelist)) {
  89. return null;
  90. }
  91. $emailChanges = $changelist['email'];
  92. if (!is_array($emailChanges)) {
  93. return null;
  94. }
  95. $oldEmail = reset($emailChanges);
  96. if (false === $oldEmail) {
  97. return null;
  98. }
  100. return $oldEmail;
  101. }
  102. }