vendor/ibexa/workflow/src/lib/Event/Subscriber/StartWorkflowSubscriber.php line 55

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\ContentService;
  12. use Ibexa\Contracts\Core\Repository\Events\Content\CreateContentEvent;
  13. use Ibexa\Contracts\Core\Repository\Events\Content\UpdateContentEvent;
  14. use Ibexa\Contracts\Workflow\Registry\WorkflowRegistryInterface;
  15. use Ibexa\Contracts\Workflow\Service\WorkflowServiceInterface;
  16. use Ibexa\Workflow\Exception\NotFoundException;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class StartWorkflowSubscriber implements EventSubscriberInterface
  20. {
  21.     /** @var \Ibexa\Contracts\Workflow\Service\WorkflowServiceInterface */
  22.     private $workflowService;
  24.     /** @var \Ibexa\Contracts\Workflow\Registry\WorkflowRegistryInterface */
  25.     private $workflowRegistry;
  27.     /** @var \Ibexa\Contracts\Core\Repository\ContentService */
  28.     private $contentService;
  30.     public function __construct(
  31.         WorkflowServiceInterface $workflowService,
  32.         WorkflowRegistryInterface $workflowRegistry,
  33.         ContentService $contentService
  34.     ) {
  35.         $this->workflowService = $workflowService;
  36.         $this->workflowRegistry = $workflowRegistry;
  37.         $this->contentService = $contentService;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             UpdateContentEvent::class => 'onUpdateContent',
  44.             CreateContentEvent::class => 'onCreateContent',
  45.         ];
  46.     }
  48.     public function onUpdateContent(UpdateContentEvent $event): void
  49.     {
  50.         $content = $event->getContent();
  52.         $this->doStartWorkflows((int)$content->id, (int)$content->versionInfo->versionNo);
  53.     }
  55.     public function onCreateContent(CreateContentEvent $event): void
  56.     {
  57.         $content = $event->getContent();
  59.         $this->doStartWorkflows((int)$content->id, (int)$content->versionInfo->versionNo);
  60.     }
  62.     private function doStartWorkflows(
  63.         int $contentId,
  64.         int $versionNo
  65.     ): void {
  66.         $content = $this->contentService->loadContent($contentId, [], $versionNo);
  67.         $supportedWorkflows = $this->workflowRegistry->getSupportedWorkflows($content);
  69.         foreach ($supportedWorkflows as $workflow) {
  70.             try {
  71.                 $this->workflowService->loadWorkflowMetadataForContent($content, $workflow->getName());
  72.             } catch (NotFoundException $e) {
  73.                 $this->workflowService->start($content, $workflow->getName());
  74.             }
  75.         }
  76.     }
  77. }
  79. class_alias(StartWorkflowSubscriber::class, 'EzSystems\EzPlatformWorkflow\Event\Subscriber\StartWorkflowSubscriber');