vendor/ibexa/corporate-account/src/lib/Form/Processor/ApplicationFormProcessor.php line 74

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. declare(strict_types=1);
  9. namespace Ibexa\CorporateAccount\Form\Processor;
  11. use Ibexa\ContentForms\Data\Content\ContentCreateData;
  12. use Ibexa\ContentForms\Data\Content\ContentUpdateData;
  13. use Ibexa\ContentForms\Event\FormActionEvent;
  14. use Ibexa\Contracts\Core\Repository\ContentService;
  15. use Ibexa\Contracts\Core\Repository\Repository;
  16. use Ibexa\Contracts\Core\Repository\RoleService;
  17. use Ibexa\Contracts\Core\Repository\UserService;
  18. use Ibexa\Contracts\Core\Repository\Values\Content\Query\Criterion\Operator;
  19. use Ibexa\Contracts\CorporateAccount\Service\ApplicationService;
  20. use Ibexa\Contracts\CorporateAccount\Service\CompanyService;
  21. use Ibexa\Contracts\CorporateAccount\Service\MemberService;
  22. use Ibexa\Contracts\CorporateAccount\Service\ShippingAddressService;
  23. use Ibexa\Contracts\CorporateAccount\Values\Application;
  24. use Ibexa\Contracts\CorporateAccount\Values\Query\Criterion\ApplicationEmail;
  25. use Ibexa\Core\Base\Exceptions\InvalidArgumentException;
  26. use Ibexa\CorporateAccount\Event\DispatcherEvents;
  27. use Ibexa\CorporateAccount\Values\Mapper\DomainMapperInterface;
  28. use Symfony\Component\HttpFoundation\RedirectResponse;
  29. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  31. class ApplicationFormProcessor extends FormProcessor
  32. {
  33. private ApplicationService $applicationService;
  35. private Repository $repository;
  37. public function __construct(
  38. ContentService $contentService,
  39. UserService $userService,
  40. RoleService $roleService,
  41. UrlGeneratorInterface $urlGenerator,
  42. DomainMapperInterface $domainMapper,
  43. CompanyService $companyService,
  44. MemberService $memberService,
  45. ShippingAddressService $shippingAddressService,
  46. Repository $repository,
  47. ApplicationService $applicationService
  48. ) {
  49. parent::__construct(
  50. $contentService,
  51. $userService,
  52. $roleService,
  53. $urlGenerator,
  54. $domainMapper,
  55. $companyService,
  56. $memberService,
  57. $shippingAddressService
  58. );
  60. $this->applicationService = $applicationService;
  61. $this->repository = $repository;
  62. }
  64. /**
  65. * @return array<string, mixed>
  66. */
  67. public static function getSubscribedEvents(): array
  68. {
  69. return [
  70. DispatcherEvents::APPLICATION_EDIT_PUBLISH => ['processCreate', 10],
  71. ];
  72. }
  74. public function processCreate(FormActionEvent $event): void
  75. {
  76. $data = $event->getData();
  77. $form = $event->getForm();
  79. if (!$data instanceof ContentCreateData && !$data instanceof ContentUpdateData) {
  80. throw new InvalidArgumentException(
  81. '$data',
  82. 'Expected ContentCreateData or ContentUpdateData'
  83. );
  84. }
  86. $languageCode = $form->getConfig()->getOption('languageCode');
  88. if ($data->isNew() && $data instanceof ContentCreateData) {
  89. $email = $data->fieldsData['user']->value->email;
  90. $applicationsCount = $this->repository->sudo(function () use ($email): int {
  91. return $this->applicationService->getApplicationsCount(
  92. new ApplicationEmail(Operator::EQ, $email)
  93. );
  94. });
  96. if ($applicationsCount > 0) {
  97. $event->setResponse(new RedirectResponse(
  98. $this->urlGenerator->generate('ibexa.corporate_account.customer_portal.corporate_account.register.confirmation')
  99. ));
  101. return;
  102. }
  103. $application = $this->createApplication($data, $languageCode);
  104. } elseif ($data instanceof ContentUpdateData) {
  105. $application = $this->updateApplication($data, $languageCode);
  106. }
  108. $event->setPayload('application', $application ?? null);
  109. }
  111. protected function createApplication(
  112. ContentCreateData $contentCreateData,
  113. string $languageCode
  114. ): Application {
  115. $applicationCreateStruct = $this->applicationService->newApplicationCreateStruct();
  116. $applicationCreateStruct->contentType = $contentCreateData->contentType;
  117. $applicationCreateStruct->mainLanguageCode = $contentCreateData->mainLanguageCode;
  118. $applicationCreateStruct->alwaysAvailable = $contentCreateData->alwaysAvailable;
  120. $mainLanguageCode = $this->resolveMainLanguageCode($contentCreateData);
  122. foreach ($contentCreateData->fieldsData as $fieldDefIdentifier => $fieldData) {
  123. if ($mainLanguageCode != $languageCode && !$fieldData->fieldDefinition->isTranslatable) {
  124. continue;
  125. }
  127. $applicationCreateStruct->setField($fieldDefIdentifier, $fieldData->value, $languageCode);
  128. }
  130. return $this->applicationService->createApplication($applicationCreateStruct);
  131. }
  133. protected function updateApplication(
  134. ContentUpdateData $contentUpdateData,
  135. string $languageCode
  136. ): Application {
  137. $applicationUpdateStruct = $this->applicationService->newApplicationUpdateStruct();
  138. $applicationUpdateStruct->initialLanguageCode = $contentUpdateData->initialLanguageCode;
  139. $applicationUpdateStruct->creatorId = $contentUpdateData->creatorId;
  141. $mainLanguageCode = $this->resolveMainLanguageCode($contentUpdateData);
  143. foreach ($contentUpdateData->fieldsData as $fieldDefIdentifier => $fieldData) {
  144. if ($mainLanguageCode != $languageCode && !$fieldData->fieldDefinition->isTranslatable) {
  145. continue;
  146. }
  148. $applicationUpdateStruct->setField($fieldDefIdentifier, $fieldData->value, $languageCode);
  149. }
  151. $application = $this->applicationService->getApplication($contentUpdateData->contentDraft->id);
  153. return $this->applicationService->updateApplication($application, $applicationUpdateStruct);
  154. }
  155. }