vendor/ibexa/workflow/src/lib/Event/Subscriber/StageChangeSubscriber.php line 72

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\Workflow\Event\Subscriber;
  11. use Ibexa\Contracts\Core\Repository\NotificationService;
  12. use Ibexa\Contracts\Core\Repository\PermissionResolver;
  13. use Ibexa\Contracts\Core\Repository\Repository;
  14. use Ibexa\Contracts\Core\Repository\UserService;
  15. use Ibexa\Contracts\Core\Repository\Values\Notification\CreateStruct;
  16. use Ibexa\Contracts\Workflow\Event\StageChangeEvent;
  17. use Ibexa\Contracts\Workflow\Event\WorkflowEvents;
  18. use Ibexa\Workflow\Registry\WorkflowDefinitionMetadataRegistry;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class StageChangeSubscriber implements EventSubscriberInterface
  22. {
  23. /** @var \Ibexa\Contracts\Core\Repository\PermissionResolver */
  24. private $permissionResolver;
  26. /** @var \Ibexa\Workflow\Registry\WorkflowDefinitionMetadataRegistry */
  27. private $workflowMetadataRegistry;
  29. /** @var \Ibexa\Contracts\Core\Repository\UserService */
  30. private $userService;
  32. /** @var \Ibexa\Contracts\Core\Repository\Repository */
  33. private $repository;
  35. /** @var \Ibexa\Contracts\Core\Repository\NotificationService */
  36. private $notificationService;
  38. /**
  39. * @param \Ibexa\Contracts\Core\Repository\NotificationService $notificationService
  40. * @param \Ibexa\Contracts\Core\Repository\PermissionResolver $permissionResolver
  41. * @param \Ibexa\Contracts\Core\Repository\Repository $repository
  42. * @param \Ibexa\Contracts\Core\Repository\UserService $userService
  43. * @param \Ibexa\Workflow\Registry\WorkflowDefinitionMetadataRegistry $workflowMetadataRegistry
  44. */
  45. public function __construct(
  46. NotificationService $notificationService,
  47. PermissionResolver $permissionResolver,
  48. Repository $repository,
  49. UserService $userService,
  50. WorkflowDefinitionMetadataRegistry $workflowMetadataRegistry
  51. ) {
  52. $this->permissionResolver = $permissionResolver;
  53. $this->workflowMetadataRegistry = $workflowMetadataRegistry;
  54. $this->userService = $userService;
  55. $this->notificationService = $notificationService;
  56. $this->repository = $repository;
  57. }
  59. public static function getSubscribedEvents(): array
  60. {
  61. return [
  62. WorkflowEvents::WORKFLOW_STAGE_CHANGE => ['onStageChange', 0],
  63. ];
  64. }
  66. /**
  67. * @param \Ibexa\Contracts\Workflow\Event\StageChangeEvent $event
  68. *
  69. * @throws \Ibexa\Workflow\Exception\NotFoundException
  70. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\InvalidArgumentException
  71. */
  72. public function onStageChange(StageChangeEvent $event): void
  73. {
  74. $workflowName = $event->getWorkflowMetadata()->name;
  76. if (!$this->workflowMetadataRegistry->hasWorkflowMetadata($workflowName)) {
  77. return;
  78. }
  80. $workflowDefinitionMetadata = $this->workflowMetadataRegistry->getWorkflowMetadata($workflowName);
  81. $transitionMetadata = $workflowDefinitionMetadata->getTransitionMetadata($event->getTransitionMetadata()->name);
  82. $notificationMetadata = $transitionMetadata->getNotificationMetadata();
  84. $users = [];
  86. $this->permissionResolver->sudo(function () use (&$users, $notificationMetadata) {
  87. foreach ($notificationMetadata->getUserGroups() as $userGroupId) {
  88. $groupUsers = $this->userService->loadUsersOfUserGroup($this->userService->loadUserGroup($userGroupId));
  90. foreach ($groupUsers as $groupUser) {
  91. $users[$groupUser->id] = $users[$groupUser->id] ?? $groupUser;
  92. }
  93. }
  95. foreach ($notificationMetadata->getUsers() as $userId) {
  96. $users[$userId] = $users[$userId] ?? $this->userService->loadUser($userId);
  97. }
  98. }, $this->repository);
  100. foreach ($users as $user) {
  101. $this->notificationService->createNotification(
  102. new CreateStruct([
  103. 'ownerId' => $user->id,
  104. 'type' => 'Workflow:StageChange',
  105. 'data' => [
  106. 'content_id' => $event->getWorkflowMetadata()->versionInfo->contentInfo->id,
  107. 'version_number' => $event->getWorkflowMetadata()->versionInfo->versionNo,
  108. 'language' => $event->getWorkflowMetadata()->versionInfo->initialLanguageCode,
  109. 'title' => $event->getWorkflowMetadata()->versionInfo->getName(),
  110. 'message' => $event->getTransitionMetadata()->message,
  111. 'sender_id' => $event->getTransitionMetadata()->userId,
  112. ],
  113. ])
  114. );
  115. }
  116. }
  117. }
  119. class_alias(StageChangeSubscriber::class, 'EzSystems\EzPlatformWorkflow\Event\Subscriber\StageChangeSubscriber');