config_suite-8.x-1.6/src/ConfigSuiteImportSubscriber.php

<?php

namespace Drupal\config_suite;

use Symfony\Component\HttpKernel\Event\RequestEvent;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpKernel\KernelEvents;
use Drupal\Core\Config\StorageComparer;
use Drupal\Core\Config\ConfigImporter;
use Drupal\Core\Cache\ChainedFastBackend;
use Drupal\Core\Site\Settings;
use Drupal\Core\Config\ConfigException;
use Drupal\Core\Utility\Error;

/**
 * Subscribes to KernelEvents::REQUEST events.
 *
 * Redirects if site is currently in maintenance mode.
 */
class ConfigSuiteImportSubscriber implements EventSubscriberInterface {

  /**
   * {@inheritdoc}
   */
  public static function getSubscribedEvents(): array {
    $events[KernelEvents::REQUEST][] = ['checkForRedirection'];

    return $events;
  }

  /**
   * Syncs config upon each request.
   *
   * @param \Symfony\Component\HttpKernel\Event\RequestEvent $event
   *   The current request event.
   */
  public function checkForRedirection(RequestEvent $event) {
    $user = \Drupal::currentUser()->getRoles();
    if (!in_array("administrator", $user)) {
      return;
    }

    $config = \Drupal::config('config_suite.settings');
    if (!$config->get('automatic_import')) {
      return;
    }

    $storage_comparer = new StorageComparer(
      \Drupal::service('config.storage.sync'),
      \Drupal::service('config.storage')
    );

    $config_importer = new ConfigImporter(
      $storage_comparer,
      \Drupal::service('event_dispatcher'),
      \Drupal::service('config.manager'),
      \Drupal::lock(),
      \Drupal::service('config.typed'),
      \Drupal::moduleHandler(),
      \Drupal::service('module_installer'),
      \Drupal::service('theme_handler'),
      \Drupal::service('string_translation'),
      \Drupal::service('extension.list.module'),
      \Drupal::service('extension.list.theme')
    );
    if (!$config_importer->alreadyImporting()) {
      try {
        $config_cache_date = \Drupal::service('cache.backend.database')
          ->get('config')
          ->get(ChainedFastBackend::LAST_WRITE_TIMESTAMP_PREFIX . 'cache_config');
        if ($config_cache_date) {
          $last_save_time = $config_cache_date->data;
        }
        else {
          $last_save_time = 0;
        }

        $last_sync_update = $this->checkModifiedTime();
        if ($last_sync_update > $last_save_time) {
          $sync_steps = $config_importer->initialize();
          foreach ($sync_steps as $step) {
            $context = [];
            do {
              $config_importer->doSyncStep($step, $context);
            } while ($context['finished'] < 1);
          }
        }
      }
      catch (ConfigException $e) {
        $message = 'The import failed due for the following reasons:' . "\n";
        $message .= implode("\n", $config_importer->getErrors());

        $logger = \Drupal::logger('config_import');
        Error::logException($logger, $e);
      }
    }
  }

  /**
   * Gets the last modified date of the config sync directory.
   */
  protected function checkModifiedTime() {
    $destination_dir = Settings::get('config_sync_directory');
    $stat = stat($destination_dir);

    return $stat['mtime'];
  }

}