vendor/ibexa/user/src/lib/Form/Processor/UserRegisterFormProcessor.php line 67

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. namespace Ibexa\User\Form\Processor;
  9. use Ibexa\ContentForms\Event\FormActionEvent;
  10. use Ibexa\Contracts\Core\Repository\Repository;
  11. use Ibexa\Contracts\Core\Repository\RoleService;
  12. use Ibexa\Contracts\Core\Repository\UserService;
  13. use Ibexa\Contracts\Core\Repository\Values\User\User;
  14. use Ibexa\Contracts\Notifications\Service\NotificationServiceInterface;
  15. use Ibexa\Contracts\Notifications\Value\Notification\SymfonyNotificationAdapter;
  16. use Ibexa\Contracts\Notifications\Value\Recipent\SymfonyRecipientAdapter;
  17. use Ibexa\Contracts\Notifications\Value\Recipent\UserRecipient;
  18. use Ibexa\Contracts\User\Notification\UserRegister;
  19. use Ibexa\User\Form\Data\UserRegisterData;
  20. use Ibexa\User\Form\UserFormEvents;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use Symfony\Component\HttpFoundation\RedirectResponse;
  23. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  24. use Symfony\Component\Routing\RouterInterface;
  26. /**
  27.  * Listens for and processes User register events.
  28.  */
  29. class UserRegisterFormProcessor implements EventSubscriberInterface
  30. {
  31.     private UserService $userService;
  33.     private UrlGeneratorInterface $urlGenerator;
  35.     private Repository $repository;
  37.     private RoleService $roleService;
  39.     private NotificationServiceInterface $notificationService;
  41.     public function __construct(
  42.         Repository $repository,
  43.         UserService $userService,
  44.         RouterInterface $router,
  45.         RoleService $roleService,
  46.         NotificationServiceInterface $notificationService
  47.     ) {
  48.         $this->userService = $userService;
  49.         $this->urlGenerator = $router;
  50.         $this->repository = $repository;
  51.         $this->roleService = $roleService;
  52.         $this->notificationService = $notificationService;
  53.     }
  55.     public static function getSubscribedEvents()
  56.     {
  57.         return [
  58.             UserFormEvents::USER_REGISTER => ['processRegister', 20],
  59.         ];
  60.     }
  62.     /**
  63.      * @param \Ibexa\ContentForms\Event\FormActionEvent $event
  64.      *
  65.      * @throws \Exception
  66.      */
  67.     public function processRegister(FormActionEvent $event)
  68.     {
  69.         /** @var \Ibexa\User\Form\Data\UserRegisterData $data */
  70.         if (!($data = $event->getData()) instanceof UserRegisterData) {
  71.             return;
  72.         }
  73.         $form = $event->getForm();
  75.         $user = $this->createUser($data, $form->getConfig()->getOption('languageCode'));
  76.         $this->sendNotification($user);
  78.         $redirectUrl = $this->urlGenerator->generate('ibexa.user.register_confirmation');
  79.         $event->setResponse(new RedirectResponse($redirectUrl));
  80.         $event->stopPropagation();
  81.     }
  83.     private function createUser(UserRegisterData $data, string $languageCode): User
  84.     {
  85.         foreach ($data->fieldsData as $fieldDefIdentifier => $fieldData) {
  86.             $data->setField($fieldDefIdentifier, $fieldData->value, $languageCode);
  87.         }
  89.         return $this->repository->sudo(
  90.             function () use ($data) {
  91.                 $user = $this->userService->createUser($data, $data->getParentGroups());
  92.                 if ($data->getRole() !== null) {
  93.                     $this->roleService->assignRoleToUser($data->getRole(), $user, $data->getRoleLimitation());
  94.                 }
  96.                 return $user;
  97.             }
  98.         );
  99.     }
  101.     private function sendNotification(User $user): void
  102.     {
  103.         $this->notificationService->send(
  104.             new SymfonyNotificationAdapter(
  105.                 new UserRegister($user),
  106.             ),
  107.             [new SymfonyRecipientAdapter(new UserRecipient($user))],
  108.         );
  109.     }
  110. }
  112. class_alias(UserRegisterFormProcessor::class, 'EzSystems\EzPlatformUser\Form\Processor\UserRegisterFormProcessor');