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

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.     protected FilesystemOperator $pimcoreDataImporterUploadStorage;
  48.     protected FilesystemOperator $pimcoreDataImporterPreviewStorage;
  50.     public function __construct(DeltaChecker $deltaChecker, QueueService $queueService, ExecutionService $executionService, FilesystemOperator $pimcoreDataImporterUploadStorage, FilesystemOperator $pimcoreDataImporterPreviewStorage)
  51.     {
  52.         $this->deltaChecker = $deltaChecker;
  53.         $this->queueService = $queueService;
  54.         $this->executionService = $executionService;
  55.         $this->pimcoreDataImporterUploadStorage = $pimcoreDataImporterUploadStorage;
  56.         $this->pimcoreDataImporterPreviewStorage = $pimcoreDataImporterPreviewStorage;
  57.     }
  59.     /**
  60.      * @return string[]
  61.      */
  62.     public static function getSubscribedEvents()
  63.     {
  64.         return [
  65.             ConfigurationEvents::CONFIGURATION_POST_DELETE => 'postDelete',
  66.             ConfigurationEvents::CONFIGURATION_POST_SAVE => 'postSave'
  67.         ];
  68.     }
  70.     /**
  71.      * @param GenericEvent $event
  72.      */
  73.     public function postDelete(GenericEvent $event)
  74.     {
  75.         /** @var Configuration $config */
  76.         $config = $event->getSubject();
  78.         if ($config->getType() === 'dataImporterDataObject') {
  79.             //cleanup delta cache
  80.             $this->deltaChecker->cleanup($config->getName());
  82.             //cleanup queue
  83.             $this->queueService->cleanupQueueItems($config->getName());
  85.             //cleanup preview files
  86.             try {
  87.                 $this->pimcoreDataImporterPreviewStorage->deleteDirectory($config->getName());
  88.             } catch (FilesystemException $e) {
  89.                 Logger::info($e);
  90.             }
  92.             //cleanup upload files
  93.             try {
  94.                 $this->pimcoreDataImporterUploadStorage->deleteDirectory($config->getName());
  95.             } catch (FilesystemException $e) {
  96.                 Logger::info($e);
  97.             }
  99.             //cleanup cron execution
  100.             $this->executionService->cleanup($config->getName());
  101.         }
  102.     }
  104.     public function postSave(GenericEvent $event)
  105.     {
  106.         /** @var Configuration $config */
  107.         $config = $event->getSubject();
  109.         if ($config->getType() === 'dataImporterDataObject') {
  110.             $this->executionService->initExecution($config->getName());
  111.         }
  112.     }
  113. }