ViewsEntitySchemaSubscriber.php

<?php

namespace Drupal\views\EventSubscriber;

use Drupal\Core\Entity\EntityTypeEventSubscriberTrait;
use Drupal\Core\Entity\EntityTypeInterface;
use Drupal\Core\Entity\EntityTypeListenerInterface;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Entity\Sql\SqlContentEntityStorage;
use Drupal\views\ViewEntityInterface;
use Drupal\views\Views;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

/**
 * Reacts to changes on entity types to update all views entities.
 */
class ViewsEntitySchemaSubscriber implements EntityTypeListenerInterface, EventSubscriberInterface {
    use EntityTypeEventSubscriberTrait;
    
    /**
     * Indicates that a base table got renamed.
     */
    const BASE_TABLE_RENAME = 0;
    
    /**
     * Indicates that a data table got renamed.
     */
    const DATA_TABLE_RENAME = 1;
    
    /**
     * Indicates that a data table got added.
     */
    const DATA_TABLE_ADDITION = 2;
    
    /**
     * Indicates that a data table got removed.
     */
    const DATA_TABLE_REMOVAL = 3;
    
    /**
     * Indicates that a revision table got renamed.
     */
    const REVISION_TABLE_RENAME = 4;
    
    /**
     * Indicates that a revision table got added.
     */
    const REVISION_TABLE_ADDITION = 5;
    
    /**
     * Indicates that a revision table got removed.
     */
    const REVISION_TABLE_REMOVAL = 6;
    
    /**
     * Indicates that a revision data table got renamed.
     */
    const REVISION_DATA_TABLE_RENAME = 7;
    
    /**
     * Indicates that a revision data table got added.
     */
    const REVISION_DATA_TABLE_ADDITION = 8;
    
    /**
     * Indicates that a revision data table got removed.
     */
    const REVISION_DATA_TABLE_REMOVAL = 9;
    
    /**
     * The entity type manager.
     *
     * @var \Drupal\Core\Entity\EntityTypeManagerInterface
     */
    protected $entityTypeManager;
    
    /**
     * The default logger service.
     *
     * @var \Psr\Log\LoggerInterface
     */
    protected $logger;
    
    /**
     * Array of views that need to be saved, indexed by view name.
     *
     * @var \Drupal\views\ViewEntityInterface[]
     */
    protected $viewsToSave = [];
    
    /**
     * Constructs a ViewsEntitySchemaSubscriber.
     *
     * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
     *   The entity type manager.
     * @param \Psr\Log\LoggerInterface $logger
     *   A logger instance.
     */
    public function __construct(EntityTypeManagerInterface $entity_type_manager, LoggerInterface $logger) {
        $this->entityTypeManager = $entity_type_manager;
        $this->logger = $logger;
    }
    
    /**
     * {@inheritdoc}
     */
    public static function getSubscribedEvents() {
        return static::getEntityTypeEvents();
    }
    
    /**
     * {@inheritdoc}
     */
    public function onEntityTypeUpdate(EntityTypeInterface $entity_type, EntityTypeInterface $original) {
        $changes = [];
        // We implement a specific logic for table updates, which is bound to the
        // default sql content entity storage.
        if (!$this->entityTypeManager
            ->getStorage($entity_type->id()) instanceof SqlContentEntityStorage) {
            return;
        }
        if ($entity_type->getBaseTable() != $original->getBaseTable()) {
            $changes[] = static::BASE_TABLE_RENAME;
        }
        $revision_add = $entity_type->isRevisionable() && !$original->isRevisionable();
        $revision_remove = !$entity_type->isRevisionable() && $original->isRevisionable();
        $translation_add = $entity_type->isTranslatable() && !$original->isTranslatable();
        $translation_remove = !$entity_type->isTranslatable() && $original->isTranslatable();
        if ($revision_add) {
            $changes[] = static::REVISION_TABLE_ADDITION;
        }
        elseif ($revision_remove) {
            $changes[] = static::REVISION_TABLE_REMOVAL;
        }
        elseif ($entity_type->isRevisionable() && $entity_type->getRevisionTable() != $original->getRevisionTable()) {
            $changes[] = static::REVISION_TABLE_RENAME;
        }
        if ($translation_add) {
            $changes[] = static::DATA_TABLE_ADDITION;
        }
        elseif ($translation_remove) {
            $changes[] = static::DATA_TABLE_REMOVAL;
        }
        elseif ($entity_type->isTranslatable() && $entity_type->getDataTable() != $original->getDataTable()) {
            $changes[] = static::DATA_TABLE_RENAME;
        }
        if ($entity_type->isRevisionable() && $entity_type->isTranslatable()) {
            if ($revision_add || $translation_add) {
                $changes[] = static::REVISION_DATA_TABLE_ADDITION;
            }
            elseif ($entity_type->getRevisionDataTable() != $original->getRevisionDataTable()) {
                $changes[] = static::REVISION_DATA_TABLE_RENAME;
            }
        }
        elseif ($original->isRevisionable() && $original->isTranslatable() && ($revision_remove || $translation_remove)) {
            $changes[] = static::REVISION_DATA_TABLE_REMOVAL;
        }
        // Stop here if no changes are needed.
        if (empty($changes)) {
            return;
        }
        
        /** @var \Drupal\views\Entity\View[] $all_views */
        $all_views = $this->entityTypeManager
            ->getStorage('view')
            ->loadMultiple(NULL);
        foreach ($changes as $change) {
            switch ($change) {
                case static::BASE_TABLE_RENAME:
                    $this->baseTableRename($all_views, $entity_type->id(), $original->getBaseTable(), $entity_type->getBaseTable());
                    break;
                case static::DATA_TABLE_RENAME:
                    $this->dataTableRename($all_views, $entity_type->id(), $original->getDataTable(), $entity_type->getDataTable());
                    break;
                case static::DATA_TABLE_ADDITION:
                    $this->dataTableAddition($all_views, $entity_type, $entity_type->getDataTable(), $entity_type->getBaseTable());
                    break;
                case static::DATA_TABLE_REMOVAL:
                    $this->dataTableRemoval($all_views, $entity_type->id(), $original->getDataTable(), $entity_type->getBaseTable());
                    break;
                case static::REVISION_TABLE_RENAME:
                    $this->baseTableRename($all_views, $entity_type->id(), $original->getRevisionTable(), $entity_type->getRevisionTable());
                    break;
                case static::REVISION_TABLE_ADDITION:
                    // If we add revision support we don't have to do anything.
                    break;
                case static::REVISION_TABLE_REMOVAL:
                    $this->revisionRemoval($all_views, $original);
                    break;
                case static::REVISION_DATA_TABLE_RENAME:
                    $this->dataTableRename($all_views, $entity_type->id(), $original->getRevisionDataTable(), $entity_type->getRevisionDataTable());
                    break;
                case static::REVISION_DATA_TABLE_ADDITION:
                    $this->dataTableAddition($all_views, $entity_type, $entity_type->getRevisionDataTable(), $entity_type->getRevisionTable());
                    break;
                case static::REVISION_DATA_TABLE_REMOVAL:
                    $this->dataTableRemoval($all_views, $entity_type->id(), $original->getRevisionDataTable(), $entity_type->getRevisionTable());
                    break;
            }
        }
        foreach ($this->viewsToSave as $view) {
            try {
                // All changes done to the views here can be trusted and this might be
                // called during updates, when it is not safe to rely on configuration
                // containing valid schema. Trust the data and disable schema validation
                // and casting.
                $view->trustData()
                    ->save();
            } catch (\Exception $e) {
                // In case the view could not be saved, log an error message that the
                // view needs to be updated manually instead of failing the entire
                // entity update process.
                $this->logger
                    ->critical("The %view_id view could not be updated automatically while processing an entity schema update for the %entity_type_id entity type.", [
                    '%view_id' => $view->id(),
                    '%entity_type_id' => $entity_type->id(),
                ]);
            }
        }
        $this->viewsToSave = [];
    }
    
    /**
     * {@inheritdoc}
     */
    public function onEntityTypeDelete(EntityTypeInterface $entity_type) {
        $tables = [
            $entity_type->getBaseTable(),
            $entity_type->getDataTable(),
            $entity_type->getRevisionTable(),
            $entity_type->getRevisionDataTable(),
        ];
        $all_views = $this->entityTypeManager
            ->getStorage('view')
            ->loadMultiple(NULL);
        
        /** @var \Drupal\views\Entity\View $view */
        foreach ($all_views as $view) {
            // First check just the base table.
            if (in_array($view->get('base_table'), $tables)) {
                $view->disable();
                $view->save();
            }
        }
    }
    
    /**
     * Applies a callable onto all handlers of all passed in views.
     *
     * @param \Drupal\views\Entity\View[] $all_views
     *   All views entities.
     * @param callable $process
     *   A callable which retrieves a handler config array.
     */
    protected function processHandlers(array $all_views, callable $process) {
        foreach ($all_views as $view) {
            foreach (array_keys($view->get('display')) as $display_id) {
                $display =& $view->getDisplay($display_id);
                foreach (Views::getHandlerTypes() as $handler_type) {
                    $handler_type = $handler_type['plural'];
                    if (!isset($display['display_options'][$handler_type])) {
                        continue;
                    }
                    foreach ($display['display_options'][$handler_type] as $id => &$handler_config) {
                        $process($handler_config, $view);
                        if ($handler_config === NULL) {
                            unset($display['display_options'][$handler_type][$id]);
                        }
                    }
                }
            }
        }
    }
    
    /**
     * Updates views if a base table is renamed.
     *
     * @param \Drupal\views\Entity\View[] $all_views
     *   All views.
     * @param string $entity_type_id
     *   The entity type ID.
     * @param string $old_base_table
     *   The old base table name.
     * @param string $new_base_table
     *   The new base table name.
     */
    protected function baseTableRename($all_views, $entity_type_id, $old_base_table, $new_base_table) {
        foreach ($all_views as $view) {
            if ($view->get('base_table') == $old_base_table) {
                $view->set('base_table', $new_base_table);
                $this->viewsToSave[$view->id()] = $view;
            }
        }
        $this->processHandlers($all_views, function (&$handler_config, ViewEntityInterface $view) use ($entity_type_id, $old_base_table, $new_base_table) {
            if (isset($handler_config['entity_type']) && $handler_config['entity_type'] == $entity_type_id && $handler_config['table'] == $old_base_table) {
                $handler_config['table'] = $new_base_table;
                $this->viewsToSave[$view->id()] = $view;
            }
        });
    }
    
    /**
     * Updates views if a data table is renamed.
     *
     * @param \Drupal\views\Entity\View[] $all_views
     *   All views.
     * @param string $entity_type_id
     *   The entity type ID.
     * @param string $old_data_table
     *   The old data table name.
     * @param string $new_data_table
     *   The new data table name.
     */
    protected function dataTableRename($all_views, $entity_type_id, $old_data_table, $new_data_table) {
        foreach ($all_views as $view) {
            if ($view->get('base_table') == $old_data_table) {
                $view->set('base_table', $new_data_table);
                $this->viewsToSave[$view->id()] = $view;
            }
        }
        $this->processHandlers($all_views, function (&$handler_config, ViewEntityInterface $view) use ($entity_type_id, $old_data_table, $new_data_table) {
            if (isset($handler_config['entity_type']) && $handler_config['entity_type'] == $entity_type_id && $handler_config['table'] == $old_data_table) {
                $handler_config['table'] = $new_data_table;
                $this->viewsToSave[$view->id()] = $view;
            }
        });
    }
    
    /**
     * Updates views if a data table is added.
     *
     * @param \Drupal\views\Entity\View[] $all_views
     *   All views.
     * @param \Drupal\Core\Entity\EntityTypeInterface $entity_type
     *   The entity type.
     * @param string $new_data_table
     *   The new data table.
     * @param string $base_table
     *   The base table.
     */
    protected function dataTableAddition($all_views, EntityTypeInterface $entity_type, $new_data_table, $base_table) {
        
        /** @var \Drupal\Core\Entity\Sql\SqlContentEntityStorage $storage */
        $entity_type_id = $entity_type->id();
        $storage = $this->entityTypeManager
            ->getStorage($entity_type_id);
        $storage->setEntityType($entity_type);
        $table_mapping = $storage->getTableMapping();
        $data_table_fields = $table_mapping->getFieldNames($new_data_table);
        $base_table_fields = $table_mapping->getFieldNames($base_table);
        $data_table = $new_data_table;
        $this->processHandlers($all_views, function (&$handler_config, ViewEntityInterface $view) use ($entity_type_id, $base_table, $data_table, $base_table_fields, $data_table_fields) {
            if (isset($handler_config['entity_type']) && isset($handler_config['entity_field']) && $handler_config['entity_type'] == $entity_type_id) {
                // Move all fields which just exists on the data table.
                if ($handler_config['table'] == $base_table && in_array($handler_config['entity_field'], $data_table_fields) && !in_array($handler_config['entity_field'], $base_table_fields)) {
                    $handler_config['table'] = $data_table;
                    $this->viewsToSave[$view->id()] = $view;
                }
            }
        });
    }
    
    /**
     * Updates views if a data table is removed.
     *
     * @param \Drupal\views\Entity\View[] $all_views
     *   All views.
     * @param string $entity_type_id
     *   The entity type ID.
     * @param string $old_data_table
     *   The name of the previous existing data table.
     * @param string $base_table
     *   The name of the base table.
     */
    protected function dataTableRemoval($all_views, $entity_type_id, $old_data_table, $base_table) {
        // We move back the data table back to the base table.
        $this->processHandlers($all_views, function (&$handler_config, ViewEntityInterface $view) use ($entity_type_id, $old_data_table, $base_table) {
            if (isset($handler_config['entity_type']) && $handler_config['entity_type'] == $entity_type_id) {
                if ($handler_config['table'] == $old_data_table) {
                    $handler_config['table'] = $base_table;
                    $this->viewsToSave[$view->id()] = $view;
                }
            }
        });
    }
    
    /**
     * Updates views if revision support is removed.
     *
     * @param \Drupal\views\Entity\View[] $all_views
     *   All views.
     * @param \Drupal\Core\Entity\EntityTypeInterface $original
     *   The origin entity type.
     */
    protected function revisionRemoval($all_views, EntityTypeInterface $original) {
        $revision_base_table = $original->getRevisionTable();
        $revision_data_table = $original->getRevisionDataTable();
        foreach ($all_views as $view) {
            if (in_array($view->get('base_table'), [
                $revision_base_table,
                $revision_data_table,
            ])) {
                // Let's disable the views as we no longer support revisions.
                $view->setStatus(FALSE);
                $this->viewsToSave[$view->id()] = $view;
            }
            // For any kind of field, let's rely on the broken handler functionality.
        }
    }

}