custom/plugins/SwagMigrationAssistant/Migration/Subscriber/MediaDeletedSubscriber.php line 43

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace SwagMigrationAssistant\Migration\Subscriber;
  10. use Shopware\Core\Content\Media\MediaDefinition;
  11. use Shopware\Core\Content\Media\MediaEvents;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class MediaDeletedSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var EntityRepositoryInterface
  22.      */
  23.     private $mediaFileRepository;
  25.     public function __construct(EntityRepositoryInterface $mediaFileRepository)
  26.     {
  27.         $this->mediaFileRepository = $mediaFileRepository;
  28.     }
  30.     /**
  31.      * Due to the order in which media file entries get written, which
  32.      * is before the related media is written, we cannot use a foreign
  33.      * key constraint for deletion and need to delete the media file entries
  34.      * manually.
  35.      */
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             MediaEvents::MEDIA_DELETED_EVENT => 'onMediaDelete',
  40.         ];
  41.     }
  43.     public function onMediaDelete(EntityDeletedEvent $event): void
  44.     {
  45.         if ($event->getEntityName() !== MediaDefinition::ENTITY_NAME) {
  46.             return;
  47.         }
  48.         $context = $event->getContext();
  49.         $deletedMediaIds = $event->getIds();
  51.         $criteria = new Criteria();
  52.         $criteria->addFilter(new EqualsAnyFilter('mediaId', $deletedMediaIds));
  54.         $result = $this->mediaFileRepository->searchIds($criteria, $context);
  55.         $mediaFileIds = $result->getIds();
  57.         if (empty($mediaFileIds)) {
  58.             return;
  59.         }
  60.         $mediaFileDeletions = [];
  62.         foreach ($mediaFileIds as $mediaFileId) {
  63.             $mediaFileDeletions[] = [
  64.                 'id' => $mediaFileId,
  65.             ];
  66.         }
  67.         $this->mediaFileRepository->delete($mediaFileDeletions, $context);
  68.     }
  69. }