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

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