vendor/pimcore/data-importer/src/EventListener/ConfigurationEventSubscriber.php line 85

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Commercial License (PCL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  14.  */
  16. namespace Pimcore\Bundle\DataImporterBundle\EventListener;
  18. use League\Flysystem\FilesystemException;
  19. use League\Flysystem\FilesystemOperator;
  20. use Pimcore\Bundle\DataHubBundle\Configuration;
  21. use Pimcore\Bundle\DataHubBundle\Event\ConfigurationEvents;
  22. use Pimcore\Bundle\DataImporterBundle\DataSource\Interpreter\DeltaChecker\DeltaChecker;
  23. use Pimcore\Bundle\DataImporterBundle\Processing\ExecutionService;
  24. use Pimcore\Bundle\DataImporterBundle\Queue\QueueService;
  25. use Pimcore\Logger;
  26. use Symfony\Component\EventDispatcher\EventSubscriberInterface as EventSubscriberInterfaceAlias;
  27. use Symfony\Component\EventDispatcher\GenericEvent;
  29. class ConfigurationEventSubscriber implements EventSubscriberInterfaceAlias
  30. {
  31.     /**
  32.      * @var DeltaChecker
  33.      */
  34.     protected $deltaChecker;
  36.     /**
  37.      * @var QueueService
  38.      */
  39.     protected $queueService;
  41.     /**
  42.      * @var ExecutionService
  43.      */
  44.     protected $executionService;
  46.     /**
  47.      * @var FilesystemOperator
  48.      */
  49.     protected FilesystemOperator $pimcoreDataImporterUploadStorage;
  51.     /**
  52.      * @var FilesystemOperator
  53.      */
  54.     protected FilesystemOperator $pimcoreDataImporterPreviewStorage;
  56.     /**
  57.      * @param DeltaChecker $deltaChecker
  58.      * @param QueueService $queueService
  59.      * @param ExecutionService $executionService
  60.      * @param FilesystemOperator $pimcoreDataImporterUploadStorage
  61.      * @param FilesystemOperator $pimcoreDataImporterPreviewStorage
  62.      */
  63.     public function __construct(DeltaChecker $deltaChecker, QueueService $queueService, ExecutionService $executionService, FilesystemOperator $pimcoreDataImporterUploadStorage, FilesystemOperator $pimcoreDataImporterPreviewStorage)
  64.     {
  65.         $this->deltaChecker = $deltaChecker;
  66.         $this->queueService = $queueService;
  67.         $this->executionService = $executionService;
  68.         $this->pimcoreDataImporterUploadStorage = $pimcoreDataImporterUploadStorage;
  69.         $this->pimcoreDataImporterPreviewStorage = $pimcoreDataImporterPreviewStorage;
  70.     }
  72.     public static function getSubscribedEvents()
  73.     {
  74.         return [
  75.             ConfigurationEvents::CONFIGURATION_POST_DELETE => 'postDelete',
  76.             ConfigurationEvents::CONFIGURATION_POST_SAVE => 'postSave'
  77.         ];
  78.     }
  80.     /**
  81.      * @param GenericEvent $event
  82.      *
  83.      * @throws \Doctrine\DBAL\DBALException
  84.      */
  85.     public function postDelete(GenericEvent $event)
  86.     {
  87.         /** @var Configuration $config */
  88.         $config = $event->getSubject();
  90.         if ($config->getType() === 'dataImporterDataObject') {
  91.             //cleanup delta cache
  92.             $this->deltaChecker->cleanup($config->getName());
  94.             //cleanup queue
  95.             $this->queueService->cleanupQueueItems($config->getName());
  97.             //cleanup preview files
  98.             try {
  99.                 $this->pimcoreDataImporterPreviewStorage->deleteDirectory($config->getName());
  100.             } catch (FilesystemException $e) {
  101.                 Logger::info($e);
  102.             }
  104.             //cleanup upload files
  105.             try {
  106.                 $this->pimcoreDataImporterUploadStorage->deleteDirectory($config->getName());
  107.             } catch (FilesystemException $e) {
  108.                 Logger::info($e);
  109.             }
  111.             //cleanup cron execution
  112.             $this->executionService->cleanup($config->getName());
  113.         }
  114.     }
  116.     public function postSave(GenericEvent $event)
  117.     {
  118.         /** @var Configuration $config */
  119.         $config = $event->getSubject();
  121.         if ($config->getType() === 'dataImporterDataObject') {
  122.             $this->executionService->initExecution($config->getName());
  123.         }
  124.     }
  125. }