vendor/ibexa/workflow/src/lib/Event/Subscriber/DeleteWorkflowSubscriber.php line 51

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\Events\Content\DeleteContentEvent;
  12. use Ibexa\Contracts\Core\Repository\Events\Content\DeleteVersionEvent;
  13. use Ibexa\Contracts\Core\Repository\Events\Trash\DeleteTrashItemEvent;
  14. use Ibexa\Contracts\Core\Repository\Events\Trash\EmptyTrashEvent;
  15. use Ibexa\Contracts\Workflow\Persistence\Handler\HandlerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class DeleteWorkflowSubscriber implements EventSubscriberInterface
  19. {
  20.     /** @var \Ibexa\Contracts\Workflow\Persistence\Handler\HandlerInterface */
  21.     private $workflowHandler;
  23.     /**
  24.      * @param \Ibexa\Contracts\Workflow\Persistence\Handler\HandlerInterface $workflowHandler
  25.      */
  26.     public function __construct(HandlerInterface $workflowHandler)
  27.     {
  28.         $this->workflowHandler = $workflowHandler;
  29.     }
  31.     /**
  32.      * {@inheritdoc}
  33.      */
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             DeleteVersionEvent::class => 'onDeleteVersion',
  38.             DeleteContentEvent::class => 'onDeleteContent',
  39.             DeleteTrashItemEvent::class => 'onDeleteTrashItem',
  40.             EmptyTrashEvent::class => 'onEmptyTrash',
  41.         ];
  42.     }
  44.     public function onDeleteVersion(DeleteVersionEvent $event): void
  45.     {
  46.         $versionInfo = $event->getVersionInfo();
  48.         $this->doDeleteWorkflowMetadata($versionInfo->contentInfo->id, $versionInfo->versionNo);
  49.     }
  51.     public function onDeleteContent(DeleteContentEvent $event): void
  52.     {
  53.         $contentInfo = $event->getContentInfo();
  55.         $this->doDeleteWorkflowMetadata($contentInfo->id);
  56.     }
  58.     public function onDeleteTrashItem(DeleteTrashItemEvent $event): void
  59.     {
  60.         $trashItemDeleteResult = $event->getResult();
  62.         if (!$trashItemDeleteResult->contentRemoved) {
  63.             return;
  64.         }
  66.         $this->doDeleteWorkflowMetadata($trashItemDeleteResult->contentId);
  67.     }
  69.     public function onEmptyTrash(EmptyTrashEvent $event): void
  70.     {
  71.         $resultList = $event->getResultList();
  73.         foreach ($resultList as $trashItemDeleteResult) {
  74.             if (!$trashItemDeleteResult->contentRemoved) {
  75.                 continue;
  76.             }
  78.             $this->doDeleteWorkflowMetadata($trashItemDeleteResult->contentId);
  79.         }
  80.     }
  82.     private function doDeleteWorkflowMetadata(
  83.         int $contentId,
  84.         ?int $versionNo = null
  85.     ): void {
  86.         $persistenceWorkflowList = $this->workflowHandler->loadWorkflowMetadataByContent($contentId, $versionNo);
  87.         foreach ($persistenceWorkflowList as $workflowMetadata) {
  88.             $this->workflowHandler->deleteWorkflowMetadata($workflowMetadata->id);
  89.         }
  90.     }
  91. }
  93. class_alias(DeleteWorkflowSubscriber::class, 'EzSystems\EzPlatformWorkflow\Event\Subscriber\DeleteWorkflowSubscriber');