src/EventListener/CustomerEditedListener.php line 41

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventListener;
  7. use App\Application\DTO\A4BDataCommunication\A4BDataCommunicationCustomerDTO;
  8. use App\Application\DTO\Hubspot\HubspotCustomerDTO;
  9. use App\Application\Message\A4BDataCommunicationCustomerMessage;
  10. use App\Application\Message\HubspotCustomerMessage;
  11. use App\Event\CustomerEditedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use App\Client\ThePowerMBA\Service\UserService as ThePowerMBAUserService;
  14. use App\Service\Customer\ThePowerMBAService;
  15. use Symfony\Component\Messenger\MessageBusInterface;
  17. use function Sentry\captureException;
  19. class CustomerEditedListener implements EventSubscriberInterface
  20. {
  21.     private ThePowerMBAUserService $thePowerMBAUserService;
  22.     private ThePowerMBAService $thePowerMBAService;
  24.     private MessageBusInterface $bus;
  26.     public function __construct(
  27.         ThePowerMBAUserService $thePowerMBAUserService,
  28.         ThePowerMBAService $thePowerMBAService,
  29.         MessageBusInterface $bus
  30.     ) {
  31.         $this->thePowerMBAUserService = $thePowerMBAUserService;
  32.         $this->thePowerMBAService = $thePowerMBAService;
  33.         $this->bus = $bus;
  34.     }
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [CustomerEditedEvent::class => 'onChange'];
  39.     }
  41.     public function onChange(CustomerEditedEvent $event): void
  42.     {
  43.         $customer = $event->getCustomer();
  45.         $this->bus->dispatch(new A4BDataCommunicationCustomerMessage(new A4BDataCommunicationCustomerDTO($customer->getId())));
  46.         $this->bus->dispatch(new HubspotCustomerMessage(new HubspotCustomerDTO($customer->getId())));
  48.         if (!$customer->getThePowerMbaUserId()) {
  49.             return;
  50.         }
  52.         try {
  53.             $userResponse = $this->thePowerMBAUserService->getById($customer->getThePowerMbaUserId());
  54.         } catch (\Throwable $exception) {
  55.             captureException($exception);
  57.             return;
  58.         }
  60.         if (
  61.             $customer->getEmail() === $userResponse->getEmail()
  62.             && $customer->getName() === $userResponse->getFirstName()
  63.             && $customer->getSurnames() === $userResponse->getLastName()
  64.             && $customer->getLanguage()->getIsoCode() === $userResponse->getLanguage()
  65.         ) {
  66.             return;
  67.         }
  69.         $this->thePowerMBAService->updateUserParameters($customer, $userResponse->getPrograms());
  70.     }
  71. }