vendor/pimcore/data-hub-file-export/src/EventSubscriber/AdminSubscriber.php line 33

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under following license:
  7.  * - Pimcore Commercial License (PCL)
  8.  *
  9.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  10.  *  @license    http://www.pimcore.org/license     PCL
  11.  */
  13. namespace Pimcore\Bundle\DataHubFileExportBundle\EventSubscriber;
  15. use Pimcore\Bundle\DataHubFileExportBundle\Event\Admin\ResetConfigEvent;
  16. use Pimcore\Bundle\DataHubFileExportBundle\Event\Admin\ValidateConfigEvent;
  17. use Pimcore\Bundle\DataHubFileExportBundle\Helper;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class AdminSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @return string[]
  24.      */
  25.     public static function getSubscribedEvents()
  26.     {
  27.         return [
  28.             ValidateConfigEvent::class => 'isValidConfig',
  29.             ResetConfigEvent::class => 'resetConfig',
  30.         ];
  31.     }
  33.     public function resetConfig(ResetConfigEvent $e)
  34.     {
  35.         $config = $e->getConfig();
  36.         $exporter = Helper::getExporterService($config);
  37.         $exporter->resetData();
  38.     }
  40.     /**
  41.      * @param array $config
  42.      *
  43.      * @return array
  44.      */
  45.     protected function getConfigErrors($config)
  46.     {
  47.         $errors = [];
  49.         if ($config['general']['active']) {
  50.             if (!$config['schema']['classId']) {
  51.                 $errors[] = 'Please define a Data Class in the Schema definition';
  52.             }
  54.             if (!$config['schema']['config']) {
  55.                 $errors[] = 'Please define a schema for the export';
  56.             }
  58.             if ($deliveryDestination = ($config['deliveryDestination'] ?? null)) {
  59.                 if (!$config['deliveryDestination']['filename']) {
  60.                     $errors[] = 'Please define a filename in Delivery destination';
  61.                 }
  63.                 if ($deliveryDestination['transmitter'] == 'localDirectory') {
  64.                     if (!$deliveryDestination['transmitter_localDirectory']['directory']) {
  65.                         $errors[] = 'Please provide a "Directory" in "Delivery destination"';
  66.                     }
  67.                 }
  69.                 if ($deliveryDestination['transmitter'] == 'sftp') {
  70.                     $settings = $deliveryDestination['transmitter_sftp'];
  71.                     foreach (['host', 'port', 'username'] as $key) {
  72.                         if (!$settings[$key]) {
  73.                             $errors[] = 'Please provide "'.$key.'" in the SFTP settings';
  74.                         }
  75.                     }
  76.                 }
  78.                 if ($deliveryDestination['transmitter'] == 'http') {
  79.                     $settings = $deliveryDestination['transmitter_http'];
  80.                     foreach (['method', 'url'] as $key) {
  81.                         if (!$settings[$key]) {
  82.                             $errors[] = 'Please provide "'.$key.'" in the HTTP settings';
  83.                         }
  84.                     }
  85.                 }
  86.             }
  87.         }
  89.         return $errors;
  90.     }
  92.     /**
  93.      * @param ValidateConfigEvent $e
  94.      *
  95.      * @return array
  96.      *
  97.      * @throws \Exception
  98.      */
  99.     public function isValidConfig(ValidateConfigEvent $e)
  100.     {
  101.         $config = $e->getConfigData();
  102.         $errors = $this->getConfigErrors($config);
  103.         if ($errors) {
  104.             throw new \Exception(implode("\n", $errors));
  105.         }
  107.         return $errors;
  108.     }
  109. }