vendor/ibexa/workflow/src/lib/Event/Subscriber/WorkflowTransitionSubscriber.php line 45

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\PermissionResolver;
  12. use Ibexa\Contracts\Workflow\Persistence\Handler\HandlerInterface;
  13. use Ibexa\Workflow\Registry\WorkflowRegistry;
  14. use Ibexa\Workflow\Value\Persistence\TransitionMetadataCreateStruct;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Workflow\Event\EnteredEvent;
  18. class WorkflowTransitionSubscriber implements EventSubscriberInterface
  19. {
  20.     /** @var \Ibexa\Contracts\Core\Repository\PermissionResolver */
  21.     private $permissionResolver;
  23.     /** @var \Ibexa\Contracts\Workflow\Persistence\Handler\HandlerInterface */
  24.     private $workflowHandler;
  26.     private WorkflowRegistry $workflowRegistry;
  28.     public function __construct(
  29.         PermissionResolver $permissionResolver,
  30.         HandlerInterface $workflowHandler,
  31.         WorkflowRegistry $workflowRegistry
  32.     ) {
  33.         $this->permissionResolver = $permissionResolver;
  34.         $this->workflowHandler = $workflowHandler;
  35.         $this->workflowRegistry = $workflowRegistry;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             'workflow.entered' => ['onWorkflowEntered', -255],
  42.         ];
  43.     }
  45.     public function onWorkflowEntered(EnteredEvent $event): void
  46.     {
  47.         if (!$this->workflowRegistry->hasWorkflow($event->getWorkflow()->getName())) {
  48.             return;
  49.         }
  51.         $marking = $event->getWorkflow()->getMarkingStore()->getMarking($event->getSubject());
  53.         if (!$event->getTransition()) {
  54.             return;
  55.         }
  57.         $context = $marking->getContext() ?? [];
  59.         $createStruct = new TransitionMetadataCreateStruct();
  60.         $createStruct->name = $event->getTransition()->getName();
  61.         $createStruct->message = $context['message'];
  62.         $createStruct->userId = $this->permissionResolver->getCurrentUserReference()->getUserId();
  63.         $createStruct->date = time();
  65.         $this->workflowHandler->createTransitionMetadata($createStruct, $context['workflowId']);
  66.     }
  67. }
  69. class_alias(WorkflowTransitionSubscriber::class, 'EzSystems\EzPlatformWorkflow\Event\Subscriber\WorkflowTransitionSubscriber');