vendor/ibexa/corporate-account/src/lib/Form/Processor/InvitationsFormProcessor.php line 118

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\Event\FormActionEvent;
  12. use Ibexa\Contracts\Core\Repository\UserService;
  13. use Ibexa\Contracts\Core\Repository\Values\User\Limitation\SubtreeLimitation;
  14. use Ibexa\Contracts\CorporateAccount\Exception\CorporateSiteAccessConfigurationException;
  15. use Ibexa\Contracts\User\Invitation\Exception\InvitationAlreadyExistsException;
  16. use Ibexa\Contracts\User\Invitation\Invitation;
  17. use Ibexa\Contracts\User\Invitation\InvitationCreateStruct;
  18. use Ibexa\Contracts\User\Invitation\InvitationSender;
  19. use Ibexa\Contracts\User\Invitation\InvitationService;
  20. use Ibexa\Core\MVC\Symfony\SiteAccess\SiteAccessServiceInterface;
  21. use Ibexa\CorporateAccount\Event\DispatcherEvents;
  22. use Ibexa\CorporateAccount\Form\Data\Invitation\InviteMembersData;
  23. use Ibexa\CorporateAccount\Form\Data\Invitation\InviteMembersWithSiteAccessData;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. class InvitationsFormProcessor implements EventSubscriberInterface
  27. {
  28. private UserService $userService;
  30. private InvitationService $invitationService;
  32. private InvitationSender $sender;
  34. private SiteAccessServiceInterface $siteAccessService;
  36. /** @var array<string, array<string>> */
  37. private array $siteAccessGroups;
  39. /** @param array<string, array<string>> $siteAccessGroups */
  40. public function __construct(
  41. UserService $userService,
  42. InvitationService $invitationService,
  43. InvitationSender $sender,
  44. SiteAccessServiceInterface $siteAccessService,
  45. array $siteAccessGroups
  46. ) {
  47. $this->userService = $userService;
  48. $this->invitationService = $invitationService;
  49. $this->sender = $sender;
  50. $this->siteAccessService = $siteAccessService;
  51. $this->siteAccessGroups = $siteAccessGroups;
  52. }
  54. /**
  55. * @return array<string, mixed>
  56. */
  57. public static function getSubscribedEvents(): array
  58. {
  59. return [
  60. DispatcherEvents::COMPANY_INVITATIONS_SEND => ['processCreateAndSend', 10],
  61. DispatcherEvents::COMPANY_INVITATIONS_RESEND => ['processResend', 10],
  62. DispatcherEvents::COMPANY_INVITATIONS_REINVITE => [
  63. ['processRefresh', 20],
  64. ['processResend', 10],
  65. ],
  66. ];
  67. }
  69. public function processCreateAndSend(FormActionEvent $event): void
  70. {
  71. $data = $event->getData();
  73. if (!$data instanceof InviteMembersData && !$data instanceof InviteMembersWithSiteAccessData) {
  74. return;
  75. }
  76. /** @var \Ibexa\Contracts\CorporateAccount\Values\Company $company */
  77. $company = $event->getOption('company');
  79. $siteAccessIdentifier = $data instanceof InviteMembersWithSiteAccessData
  80. ? $data->getSiteAccess()->name
  81. : $this->getCurrentSiteAccessIdentifier();
  83. $membersGroup = $this->userService->loadUserGroup(
  84. $company->getMembersId()
  85. );
  86. foreach ($data->getInvitations() as $simpleInvitation) {
  87. if ($simpleInvitation->getEmail() === null || $simpleInvitation->getRole() === null) {
  88. continue;
  89. }
  90. $struct = new InvitationCreateStruct(
  91. $simpleInvitation->getEmail(),
  92. $siteAccessIdentifier,
  93. $membersGroup,
  94. $simpleInvitation->getRole(),
  95. new SubtreeLimitation(
  96. [
  97. 'limitationValues' => [
  98. $company->getContent()->getVersionInfo()->getContentInfo()->getMainLocation()->pathString,
  99. ],
  100. ]
  101. )
  102. );
  104. try {
  105. $invitation = $this->invitationService->createInvitation($struct);
  106. $this->sender->sendInvitation($invitation);
  107. } catch (InvitationAlreadyExistsException $exception) {
  108. $existingInvitation = $this->invitationService->getInvitationByEmail($simpleInvitation->getEmail());
  109. $this->sender->sendInvitation(
  110. $this->invitationService->refreshInvitation(
  111. $existingInvitation
  112. )
  113. );
  114. }
  115. }
  116. }
  118. public function processRefresh(FormActionEvent $event): void
  119. {
  120. $data = $event->getData();
  122. if (!$data instanceof Invitation) {
  123. return;
  124. }
  125. $refreshed = $this->invitationService->refreshInvitation($data);
  126. $event->setData($refreshed);
  127. }
  129. public function processResend(FormActionEvent $event): void
  130. {
  131. $data = $event->getData();
  133. if (!$data instanceof Invitation) {
  134. return;
  135. }
  136. $this->sender->sendInvitation($data);
  137. }
  139. private function getCurrentSiteAccessIdentifier(): string
  140. {
  141. $currentSiteAccess = $this->siteAccessService->getCurrent();
  143. if ($currentSiteAccess === null) {
  144. $defaultSiteAccess = reset($this->siteAccessGroups['corporate_group']);
  145. if (!$defaultSiteAccess) {
  146. throw new CorporateSiteAccessConfigurationException(
  147. 'There is no site access configured for `corporate_group` group'
  148. );
  149. }
  151. return $defaultSiteAccess;
  152. }
  154. $siteAccessIdentifier = $currentSiteAccess->name;
  155. if (!in_array($siteAccessIdentifier, $this->siteAccessGroups['corporate_group'], true)) {
  156. throw new CorporateSiteAccessConfigurationException(
  157. 'Current SiteAccess is not a part of `corporate_group`'
  158. );
  159. }
  161. return $siteAccessIdentifier;
  162. }
  163. }