custom/plugins/PickwareErpStarter/vendor/pickware/document-bundle/src/Model/Subscriber/DeleteFileSubscriber.php line 54

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) Pickware GmbH. All rights reserved.
  4.  * This file is part of software that is released under a proprietary license.
  5.  * You must not copy, modify, distribute, make publicly available, or execute
  6.  * its contents or parts thereof without express permission by the copyright
  7.  * holder, unless otherwise permitted by law.
  8.  */
  10. declare(strict_types=1);
  12. namespace Pickware\DocumentBundle\Model\Subscriber;
  14. use League\Flysystem\FilesystemInterface;
  15. use Pickware\DalBundle\EntityPreWriteValidationEvent;
  16. use Pickware\DalBundle\EntityPreWriteValidationEventDispatcher;
  17. use Pickware\DocumentBundle\Model\DocumentDefinition;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. class DeleteFileSubscriber implements EventSubscriberInterface
  23. {
  24.     private FilesystemInterface $privateFileSystem;
  26.     public function __construct(FilesystemInterface $privateFileSystem)
  27.     {
  28.         $this->privateFileSystem = $privateFileSystem;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             DocumentDefinition::ENTITY_DELETED_EVENT => 'onDocumentEntityDeleted',
  35.             EntityPreWriteValidationEventDispatcher::getEventName(DocumentDefinition::ENTITY_NAME) => 'onPreWriteValidationEvent',
  36.         ];
  37.     }
  39.     public function onPreWriteValidationEvent($event): void
  40.     {
  41.         if (!($event instanceof EntityPreWriteValidationEvent)) {
  42.             // The subscriber is probably instantiated in its old version (with the Shopware PreWriteValidationEvent) in
  43.             // the container and will be updated on the next container rebuild (next request). Early return.
  44.             return;
  45.         }
  47.         foreach ($event->getCommands() as $command) {
  48.             if ($command instanceof DeleteCommand) {
  49.                 $command->requestChangeSet();
  50.             }
  51.         }
  52.     }
  54.     public function onDocumentEntityDeleted(EntityDeletedEvent $event): void
  55.     {
  56.         foreach ($event->getWriteResults() as $writeResult) {
  57.             $changeSet = $writeResult->getChangeSet();
  58.             $filePath = $changeSet->getBefore('path_in_private_file_system');
  59.             if ($filePath === null) {
  60.                 $filePath = 'documents/' . bin2hex($changeSet->getBefore('id'));
  61.             }
  62.             if ($this->privateFileSystem->has($filePath)) {
  63.                 $this->privateFileSystem->delete($filePath);
  64.             }
  65.         }
  66.     }
  67. }