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