comparison core/modules/workspaces/src/EntityOperations.php @ 18:af1871eacc83

Update to Drupal core 8.7.1

       $container->get('workspaces.manager')
     );
   }
 
   /**
-   * Acts on entities when loaded.
-   *
-   * @see hook_entity_load()
-   */
-  public function entityLoad(array &$entities, $entity_type_id) {
+   * Acts on entity IDs before they are loaded.
+   *
+   * @see hook_entity_preload()
+   */
+  public function entityPreload(array $ids, $entity_type_id) {
+    $entities = [];
+
     // Only run if the entity type can belong to a workspace and we are in a
     // non-default workspace.
     if (!$this->workspaceManager->shouldAlterOperations($this->entityTypeManager->getDefinition($entity_type_id))) {
-      return;
+      return $entities;
     }
 
     // Get a list of revision IDs for entities that have a revision set for the
     // current active workspace. If an entity has multiple revisions set for a
     // workspace, only the one with the highest ID is returned.
-    $entity_ids = array_keys($entities);
     $max_revision_id = 'max_target_entity_revision_id';
-    $results = $this->entityTypeManager
+    $query = $this->entityTypeManager
       ->getStorage('workspace_association')
       ->getAggregateQuery()
       ->accessCheck(FALSE)
       ->allRevisions()
       ->aggregate('target_entity_revision_id', 'MAX', NULL, $max_revision_id)
       ->groupBy('target_entity_id')
       ->condition('target_entity_type_id', $entity_type_id)
-      ->condition('target_entity_id', $entity_ids, 'IN')
-      ->condition('workspace', $this->workspaceManager->getActiveWorkspace()->id())
-      ->execute();
-
-    // Since hook_entity_load() is called on both regular entity load as well as
-    // entity revision load, we need to prevent infinite recursion by checking
-    // whether the default revisions were already swapped with the workspace
-    // revision.
-    // @todo This recursion protection should be removed when
-    //   https://www.drupal.org/project/drupal/issues/2928888 is resolved.
-    if ($results) {
-      $results = array_filter($results, function ($result) use ($entities, $max_revision_id) {
-        return $entities[$result['target_entity_id']]->getRevisionId() != $result[$max_revision_id];
-      });
-    }
+      ->condition('workspace', $this->workspaceManager->getActiveWorkspace()->id());
+
+    if ($ids) {
+      $query->condition('target_entity_id', $ids, 'IN');
+    }
+
+    $results = $query->execute();
 
     if ($results) {
       /** @var \Drupal\Core\Entity\RevisionableStorageInterface $storage */
       $storage = $this->entityTypeManager->getStorage($entity_type_id);
 

       $swap_revision_ids = array_column($results, $max_revision_id);
       foreach ($storage->loadMultipleRevisions($swap_revision_ids) as $revision) {
         $entities[$revision->id()] = $revision;
       }
     }
+
+    return $entities;
   }
 
   /**
    * Acts on an entity before it is created or updated.
    *

     // default workspace.
     if (!$this->workspaceManager->isEntityTypeSupported($entity_type)) {
       throw new \RuntimeException('This entity can only be saved in the default workspace.');
     }
 
-    /** @var \Drupal\Core\Entity\RevisionableInterface|\Drupal\Core\Entity\EntityPublishedInterface $entity */
-    if (!$entity->isNew() && !isset($entity->_isReplicating)) {
+    /** @var \Drupal\Core\Entity\ContentEntityInterface|\Drupal\Core\Entity\EntityPublishedInterface $entity */
+    if (!$entity->isNew() && !$entity->isSyncing()) {
       // Force a new revision if the entity is not replicating.
       $entity->setNewRevision(TRUE);
 
       // All entities in the non-default workspace are pending revisions,
       // regardless of their publishing status. This means that when creating

    * If the passed-in entity can belong to a workspace and already has a
    * WorkspaceAssociation entity, then a new revision of this will be created with
    * the new information. Otherwise, a new WorkspaceAssociation entity is created to
    * store the passed-in entity's information.
    *
-   * @param \Drupal\Core\Entity\EntityInterface $entity
+   * @param \Drupal\Core\Entity\RevisionableInterface $entity
    *   The entity to update or create from.
    */
-  protected function trackEntity(EntityInterface $entity) {
-    /** @var \Drupal\Core\Entity\RevisionableInterface|\Drupal\Core\Entity\EntityPublishedInterface $entity */
+  protected function trackEntity(RevisionableInterface $entity) {
     // If the entity is not new, check if there's an existing
     // WorkspaceAssociation entity for it.
     $workspace_association_storage = $this->entityTypeManager->getStorage('workspace_association');
     if (!$entity->isNew()) {
       $workspace_associations = $workspace_association_storage->loadByProperties([