class ConfigSubscriber in Field Encryption 3.0.x

Updates existing data when field encryption settings are updated.

Hierarchy

• class \Drupal\field_encrypt\EventSubscriber\ConfigSubscriber implements \Symfony\Component\EventDispatcher\EventSubscriberInterface uses StringTranslationTrait

1 string reference to 'ConfigSubscriber'

field_encrypt.services.yml in ./field_encrypt.services.yml

field_encrypt.services.yml

1 service uses ConfigSubscriber

field_encrypt.config_subscriber in ./field_encrypt.services.yml

Drupal\field_encrypt\EventSubscriber\ConfigSubscriber

File

src/EventSubscriber/ConfigSubscriber.php, line 23

Namespace

Drupal\field_encrypt\EventSubscriber

class ConfigSubscriber implements EventSubscriberInterface {
  use StringTranslationTrait;

  /**
   * The entity type manager service.
   *
   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
   */
  protected $entityTypeManager;

  /**
   * The queue factory.
   *
   * @var \Drupal\Core\Queue\QueueFactory
   */
  protected $queueFactory;

  /**
   * The state manager.
   *
   * @var \Drupal\field_encrypt\StateManager
   */
  protected $stateManager;

  /**
   * The messenger service.
   *
   * @var \Drupal\Core\Messenger\MessengerInterface
   */
  protected $messenger;

  /**
   * Constructs a new ConfigSubscriber object.
   *
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
   *   The entity type manager service.
   * @param \Drupal\Core\Queue\QueueFactory $queue_factory
   *   The queue factory.
   * @param \Drupal\field_encrypt\StateManager $state_manager
   *   The state manager.
   * @param \Drupal\Core\StringTranslation\TranslationInterface $translation
   *   The string translation service.
   * @param \Drupal\Core\Messenger\MessengerInterface $messenger
   *   The messenger service.
   */
  public function __construct(EntityTypeManagerInterface $entity_type_manager, QueueFactory $queue_factory, StateManager $state_manager, TranslationInterface $translation, MessengerInterface $messenger) {
    $this->entityTypeManager = $entity_type_manager;
    $this->queueFactory = $queue_factory;
    $this->stateManager = $state_manager;
    $this->stringTranslation = $translation;
    $this->messenger = $messenger;
  }

  /**
   * {@inheritdoc}
   */
  public static function getSubscribedEvents() {
    $events[ConfigEvents::SAVE][] = [
      'onConfigSave',
      0,
    ];
    $events[ConfigEvents::DELETE][] = [
      'onConfigDelete',
      0,
    ];
    $events[FieldStorageDefinitionEvents::DELETE] = [
      'onBaseFieldDelete',
      0,
    ];
    return $events;
  }

  /**
   * React on the configuration save event.
   *
   * @param \Drupal\Core\Config\ConfigCrudEvent $event
   *   The configuration event.
   *
   * @todo why is this not just using hook_field_storage_update?
   */
  public function onConfigSave(ConfigCrudEvent $event) {
    $config = $event
      ->getConfig();
    if (substr($config
      ->getName(), 0, 14) == 'field.storage.') {
      $this
        ->onFieldStorageChange($config);
    }
    if (!$config
      ->isNew() && $config
      ->getName() === 'field_encrypt.settings') {
      $this
        ->onFieldEncryptSettingsChange($config);
    }
  }

  /**
   * Reacts to changes in field.storage.*.
   *
   * @param \Drupal\Core\Config\Config $config
   *   The field storage config.
   */
  protected function onFieldStorageChange(Config $config) {

    // Get the original field_encrypt configuration.
    $original_config = $config
      ->getOriginal('third_party_settings.field_encrypt');
    if ($config
      ->get('third_party_settings.field_encrypt') === $original_config) {
      return;
    }

    // Update existing entities, if data encryption settings changed.
    // Get the entity type and field from the changed config key.
    $storage_name = substr($config
      ->getName(), 14);
    [
      $entity_type,
      $field_name,
    ] = explode('.', $storage_name, 2);

    // Load the FieldStorageConfig entity that was updated.
    $field_storage_config = FieldStorageConfig::loadByName($entity_type, $field_name);
    if ($field_storage_config) {
      if ($field_storage_config
        ->hasData()) {

        // Get entities that need updating, because they contain the field
        // that has its field encryption settings updated.
        $query = $this->entityTypeManager
          ->getStorage($entity_type)
          ->getQuery();

        // Check if the field is present.
        $query
          ->exists($field_name);

        // Make sure to get all revisions for revisionable entities.
        if ($this->entityTypeManager
          ->getDefinition($entity_type)
          ->isRevisionable()) {
          $query
            ->allRevisions();
        }
        $entity_ids = $query
          ->execute();
        if (!empty($entity_ids)) {

          // Call the Queue API and add items for processing.
          $queue = $this->queueFactory
            ->get('field_encrypt_update_entity_encryption');
          $data = [
            'entity_type' => $entity_type,
          ];
          foreach (array_keys($entity_ids) as $entity_id) {
            $data['entity_id'] = $entity_id;
            $queue
              ->createItem($data);
          }
        }
        $this->messenger
          ->addMessage($this
          ->t('Updates to entities with existing data for this field have been queued to be processed. You should immediately <a href=":url">run this process manually</a>. Alternatively, the updates will be performed automatically by cron.', [
          ':url' => Url::fromRoute('field_encrypt.process_queue')
            ->toString(),
        ]));
      }
    }

    // Update the field_encrypt module's state.
    $this->stateManager
      ->update();
  }

  /**
   * Reacts to changes in field_encrypt.settings.
   *
   * @param \Drupal\Core\Config\Config $config
   *   The field_encrypt.settings config object.
   */
  protected function onFieldEncryptSettingsChange(Config $config) {
    if ($config
      ->getOriginal('make_entities_uncacheable') !== $config
      ->get('make_entities_uncacheable')) {
      $this->stateManager
        ->onFieldEncryptSettingsCacheChange();
    }
  }

  /**
   * React on the configuration delete event.
   *
   * @param \Drupal\Core\Config\ConfigCrudEvent $event
   *   The configuration event.
   */
  public function onConfigDelete(ConfigCrudEvent $event) {
    $config = $event
      ->getConfig();
    if (substr($config
      ->getName(), 0, 14) == 'field.storage.') {
      $this->stateManager
        ->update();
    }
  }

  /**
   * React to a base field being deleted.
   *
   * @param \Drupal\Core\Field\FieldStorageDefinitionEvent $event
   *   The field storage event.
   */
  public function onBaseFieldDelete(FieldStorageDefinitionEvent $event) {

    // @todo as this makes a configuration change should we disable during
    //   configuration import?
    $field = $event
      ->getFieldStorageDefinition();
    if ($event
      ->getFieldStorageDefinition()
      ->isBaseField()) {

      /** @var \Drupal\field_encrypt\Entity\FieldEncryptEntityType $field_encrypt_settings */
      $field_encrypt_settings = $this->entityTypeManager
        ->getStorage('field_encrypt_entity_type')
        ->load($field
        ->getTargetEntityTypeId());
      if ($field_encrypt_settings && $field_encrypt_settings
        ->hasBaseField($field
        ->getName())) {
        $field_encrypt_settings
          ->removeBaseField($field
          ->getName());
        empty($field_encrypt_settings
          ->getBaseFields()) ? $field_encrypt_settings
          ->delete() : $field_encrypt_settings
          ->save();
      }
    }
  }

}

Members

Name	Modifiers	Type	Description	Overrides
ConfigSubscriber::$entityTypeManager	protected	property	The entity type manager service.
ConfigSubscriber::$messenger	protected	property	The messenger service.
ConfigSubscriber::$queueFactory	protected	property	The queue factory.
ConfigSubscriber::$stateManager	protected	property	The state manager.
ConfigSubscriber::getSubscribedEvents	public static	function
ConfigSubscriber::onBaseFieldDelete	public	function	React to a base field being deleted.
ConfigSubscriber::onConfigDelete	public	function	React on the configuration delete event.
ConfigSubscriber::onConfigSave	public	function	React on the configuration save event.
ConfigSubscriber::onFieldEncryptSettingsChange	protected	function	Reacts to changes in field_encrypt.settings.
ConfigSubscriber::onFieldStorageChange	protected	function	Reacts to changes in field.storage.*.
ConfigSubscriber::__construct	public	function	Constructs a new ConfigSubscriber object.
StringTranslationTrait::$stringTranslation	protected	property	The string translation service.	4
StringTranslationTrait::formatPlural	protected	function	Formats a string containing a count of items.
StringTranslationTrait::getNumberOfPlurals	protected	function	Returns the number of plurals supported by a given language.
StringTranslationTrait::getStringTranslation	protected	function	Gets the string translation service.
StringTranslationTrait::setStringTranslation	public	function	Sets the string translation service to use.	2
StringTranslationTrait::t	protected	function	Translates a string to the current language or to a given language.