vendor/datenwerk/ginger-bundle/Import/EventSubscriber/StorageSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace DW\GingerBundle\Import\EventSubscriber;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use DW\GingerBundle\Import\Entity\FileImport;
  7. use DW\GingerBundle\Import\Event\FileRemovedEvent;
  8. use DW\GingerBundle\Import\Storage\FileManager;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class StorageSubscriber implements EventSubscriberInterface
  12. {
  13.     /**
  14.      * @var EntityManagerInterface
  15.      */
  16.     protected $entityManager;
  18.     public function __construct(EntityManagerInterface $entityManager)
  19.     {
  20.         $this->entityManager = $entityManager;
  21.     }
  23.     /**
  24.      * {@inheritDoc}
  25.      */
  26.     public static function getSubscribedEvents()
  27.     {
  28.         return [
  29.             FileRemovedEvent::NAME => 'clearFileImport',
  30.         ];
  31.     }
  33.     /**
  34.      * Remove linked file import.
  35.      *
  36.      * @param FileRemovedEvent $event
  37.      *
  38.      * @return void
  39.      */
  40.     public function clearFileImport(FileRemovedEvent $event)
  41.     {
  42.         if ($event->getSource() !== FileManager::IMPORT_STORAGE) {
  43.             return;
  44.         }
  46.         $fileImport = $this->entityManager
  47.             ->getRepository(FileImport::class)
  48.             ->findOneByUploadUID($event->getFilename())
  49.         ;
  51.         if (!$fileImport instanceof FileImport) {
  52.             return;
  53.         }
  55.         $this->entityManager->remove($fileImport);
  56.         $this->entityManager->flush();
  57.     }
  58. }