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

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.     public static function getSubscribedEvents()
  23.     {
  24.         return [
  25.             ValidateConfigEvent::class => 'isValidConfig',
  26.             ResetConfigEvent::class => 'resetConfig',
  27.         ];
  28.     }
  30.     public function resetConfig(ResetConfigEvent $e)
  31.     {
  32.         $config = $e->getConfig();
  33.         $exporter = Helper::getExporterService($config);
  34.         $exporter->resetData();
  35.     }
  37.     protected function getConfigErrors($config)
  38.     {
  39.         $errors = [];
  41.         if ($config['general']['active']) {
  42.             if (!$config['schema']['classId']) {
  43.                 $errors[] = 'Please define a Data Class in the Schema definition';
  44.             }
  46.             if (!$config['schema']['config']) {
  47.                 $errors[] = 'Please define a schema for the export';
  48.             }
  50.             if ($deliveryDestination = ($config['deliveryDestination'] ?? null)) {
  51.                 if (!$config['deliveryDestination']['filename']) {
  52.                     $errors[] = 'Please define a filename in Delivery destination';
  53.                 }
  55.                 if ($deliveryDestination['transmitter'] == 'localDirectory') {
  56.                     if (!$deliveryDestination['transmitter_localDirectory']['directory']) {
  57.                         $errors[] = 'Please provide a "Directory" in "Delivery destination"';
  58.                     }
  59.                 }
  61.                 if ($deliveryDestination['transmitter'] == 'sftp') {
  62.                     $settings = $deliveryDestination['transmitter_sftp'];
  63.                     foreach (['host', 'port', 'username'] as $key) {
  64.                         if (!$settings[$key]) {
  65.                             $errors[] = 'Please provide "'.$key.'" in the SFTP settings';
  66.                         }
  67.                     }
  68.                 }
  70.                 if ($deliveryDestination['transmitter'] == 'http') {
  71.                     $settings = $deliveryDestination['transmitter_http'];
  72.                     foreach (['method', 'url'] as $key) {
  73.                         if (!$settings[$key]) {
  74.                             $errors[] = 'Please provide "'.$key.'" in the HTTP settings';
  75.                         }
  76.                     }
  77.                 }
  78.             }
  79.         }
  81.         return $errors;
  82.     }
  84.     public function isValidConfig(ValidateConfigEvent $e)
  85.     {
  86.         $config = $e->getConfigData();
  87.         $errors = $this->getConfigErrors($config);
  88.         if ($errors) {
  89.             throw new \Exception(implode("\n", $errors));
  90.         }
  92.         return $errors;
  93.     }
  94. }