custom/plugins/PickwareDhl/vendor/pickware/document-bundle/src/Model/Subscriber/DeleteFileSubscriber.php line 41

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\DocumentBundle\Model\DocumentDefinition;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class DeleteFileSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var FilesystemInterface
  25.      */
  26.     private $privateFileSystem;
  28.     public function __construct(FilesystemInterface $privateFileSystem)
  29.     {
  30.         $this->privateFileSystem = $privateFileSystem;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             DocumentDefinition::ENTITY_DELETED_EVENT => 'onDocumentEntityDeleted',
  37.             PreWriteValidationEvent::class => 'onPreWriteValidationEvent',
  38.         ];
  39.     }
  41.     public function onPreWriteValidationEvent(PreWriteValidationEvent $event): void
  42.     {
  43.         foreach ($event->getCommands() as $command) {
  44.             if ($command->getDefinition()->getEntityName() !== DocumentDefinition::ENTITY_NAME) {
  45.                 continue;
  46.             }
  47.             if (!$command instanceof DeleteCommand) {
  48.                 continue;
  49.             }
  50.             $command->requestChangeSet();
  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. }