src/Aqarmap/Bundle/UserBundle/EventListener/UserUpdateListener.php line 31

  1. <?php
  3. namespace Aqarmap\Bundle\UserBundle\EventListener;
  5. use Aqarmap\Bundle\ListingBundle\Contracts\PhoneManagerInterface;
  6. use Aqarmap\Bundle\UserBundle\Entity\User;
  7. use Aqarmap\Bundle\UserBundle\Services\Contracts\UserPhoneManagerInterface;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use FOS\UserBundle\Event\FormEvent;
  10. use FOS\UserBundle\FOSUserEvents;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class UserUpdateListener implements EventSubscriberInterface
  14. {
  15. public function __construct(private readonly PhoneManagerInterface $phoneManager, private readonly EntityManagerInterface $entityManager, private readonly UserPhoneManagerInterface $userPhoneManager)
  16. {
  17. }
  19. public function onProfileEditSuccess(FormEvent $event): void
  20. {
  21. $mainPhones = [
  22. $event->getForm()->get('firstPhone')->getData(),
  23. $event->getForm()->get('secondPhone')->getData(),
  24. ];
  26. $countryCodes = [
  27. $event->getForm()->get('firstCountryCode')->getData(),
  28. $event->getForm()->get('secondCountryCode')->getData(),
  29. ];
  31. $hasWhatsApp = $event->getRequest()->request->get('hasWhatsApp');
  32. $phones = $this->preparePhones($mainPhones, $countryCodes);
  34. /** @var User $user */
  35. $user = $event->getForm()->getData();
  37. $this->userPhoneManager->addMainPhoneNumbers($user, $phones, $countryCodes, $hasWhatsApp);
  39. $user->setMigratedPhone(true);
  40. $user->setPhoneNumber($user->getPhoneNumber());
  42. $this->entityManager->persist($user);
  43. $this->entityManager->flush();
  45. try {
  46. $this->checkPhoneDuplications($mainPhones, $countryCodes);
  47. } catch (\Exception) {
  48. }
  49. }
  51. private function checkPhoneDuplications(array $mainPhones, array $countryCodes): void
  52. {
  53. foreach ($mainPhones as $index => $mainPhone) {
  54. if (!$mainPhone) {
  55. continue;
  56. }
  57. $mainPhone = $countryCodes[$index].$mainPhone;
  58. $mainPhone = $this->phoneManager->trimZero($mainPhone, $countryCodes[$index]);
  59. $phones[] = $mainPhone;
  60. }
  61. }
  63. /**
  64. * @return array
  65. */
  66. private function preparePhones(array $mainPhones, array $countryCodes)
  67. {
  68. $preparedPhones = [];
  70. foreach ($mainPhones as $index => $mainPhone) {
  71. if (!$mainPhone) {
  72. continue; // Skip empty phone numbers
  73. }
  75. // Trim leading zeros
  76. $mainPhone = $this->phoneManager->trimZero($mainPhone, $countryCodes[$index]);
  78. // Add prepared phone to the list
  79. $preparedPhones[] = $mainPhone;
  80. }
  82. return $preparedPhones;
  83. }
  85. public static function getSubscribedEvents(): array
  86. {
  87. return [
  88. FOSUserEvents::PROFILE_EDIT_SUCCESS => [
  89. ['onProfileEditSuccess'],
  90. ],
  91. ];
  92. }
  93. }