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');