src/Component/Organization/EventListener/SimpleRegistrationEventListener.php line 29

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace BitBag\OpenMarketplace\Component\Organization\EventListener;
  7. use BitBag\OpenMarketplace\Component\Core\Shop\Checker\ReCaptchaCheckerInterface;
  8. use BitBag\OpenMarketplace\Component\Customer\Model\CustomerInterface;
  9. use BitBag\OpenMarketplace\Component\Inquiry\Entity\InquiryInterface;
  10. use BitBag\OpenMarketplace\Component\Inquiry\Entity\MessageInterface as InquiryMessageInterface;
  11. use BitBag\OpenMarketplace\Component\Organization\Email\OrganizationEmailManagerInterface;
  12. use BitBag\OpenMarketplace\Component\Organization\Entity\OrganizationInterface;
  13. use BitBag\OpenMarketplace\Component\Organization\Manager\RegistrationConflictManager;
  14. use BitBag\OpenMarketplace\Component\RFQ\Entity\MessageInterface as RFQMessageInterface;
  15. use BitBag\OpenMarketplace\Component\RFQ\Entity\RFQInterface;
  16. use BitBag\OpenMarketplace\Component\Vendor\Repository\CustomerRepositoryInterface;
  17. use Sylius\Bundle\ResourceBundle\Event\ResourceControllerEvent;
  19. final class SimpleRegistrationEventListener
  20. {
  21.     public function __construct(
  22.         private CustomerRepositoryInterface $customerRepository,
  23.         private OrganizationEmailManagerInterface $emailManager,
  24.         private RegistrationConflictManager $registrationConflictManager,
  25.         private ReCaptchaCheckerInterface $reCaptchaChecker
  26.     ) {
  27.     }
  29.     public function __invoke(ResourceControllerEvent $event): void
  30.     {
  31.         $object = $event->getSubject();
  32.         if (!$object instanceof InquiryInterface && !$object instanceof RFQInterface) {
  33.             return;
  34.         }
  36.         if (!$this->reCaptchaChecker->checkIsValid($object->getRecaptcha())) {
  37.             $event->stop('open_marketplace.recaptcha.invalid', 'error');
  39.             return;
  40.         }
  42.         $customer = $object->getCustomer();
  43.         if (!$customer instanceof CustomerInterface) {
  44.             return;
  45.         }
  47.         $this->registrationConflictManager->manage($event);
  49.         if ($event->isPropagationStopped()) {
  50.             return;
  51.         }
  53.         $this->assignToOrganization($customer, $object, true);
  54.         $this->customerRepository->add($customer);
  55.         $this->emailManager->sendActivationEmail($customer, $object);
  56.     }
  58.     private function assignToOrganization(
  59.         CustomerInterface $customer,
  60.         InquiryInterface|RFQInterface $object,
  61.         bool $assignEmail = false
  62.     ): void {
  63.         $organization = $customer->getOrganization();
  64.         if (!$organization instanceof OrganizationInterface) {
  65.             return;
  66.         }
  68.         $object->setBuyer($organization);
  70.         if (true === $assignEmail) {
  71.             $organization->setEmail($customer->getEmail() ?? '');
  72.         }
  74.         /** @var RFQMessageInterface|InquiryMessageInterface $message */
  75.         foreach ($object->getMessages() as $message) {
  76.             $message->setCustomer($customer);
  77.         }
  78.     }
  79. }