function WorkspaceMerger::merge

Merges the contents of the source workspace into the target workspace.

Overrides WorkspaceMergerInterface::merge

File

core/modules/workspaces/src/WorkspaceMerger.php, line 84

Class

WorkspaceMerger

Default implementation of the workspace merger.

Namespace

Code

public function merge() {
  if (!$this->sourceWorkspace
    ->hasParent() || $this->sourceWorkspace->parent->target_id != $this->targetWorkspace
    ->id()) {
    throw new \InvalidArgumentException('The contents of a workspace can only be merged into its parent workspace.');
  }
  if ($this->checkConflictsOnTarget()) {
    throw new WorkspaceConflictException();
  }
  try {
    $transaction = $this->database
      ->startTransaction();
    $max_execution_time = ini_get('max_execution_time');
    $step_size = Settings::get('entity_update_batch_size', 50);
    $counter = 0;
    foreach ($this->getDifferringRevisionIdsOnSource() as $entity_type_id => $revision_difference) {
      $entity_type = $this->entityTypeManager
        ->getDefinition($entity_type_id);
      $revisions_on_source = $this->entityTypeManager
        ->getStorage($entity_type_id)
        ->loadMultipleRevisions(array_keys($revision_difference));
      /** @var \Drupal\Core\Entity\ContentEntityInterface $revision */
      foreach ($revisions_on_source as $revision) {
        // Track all the differing revisions from the source workspace in
        // the context of the target workspace. This will automatically
        // update all the descendants of the target workspace as well.
        $this->workspaceAssociation
          ->trackEntity($revision, $this->targetWorkspace);
        // Set the workspace in which the revision was merged.
        $field_name = $entity_type->getRevisionMetadataKey('workspace');
        $revision->{$field_name}->target_id = $this->targetWorkspace
          ->id();
        $revision->setSyncing(TRUE);
        $revision->save();
        $counter++;
        // Extend the execution time in order to allow processing workspaces
        // that contain a large number of items.
        if ((int) ($counter / $step_size) >= 1) {
          set_time_limit($max_execution_time);
          $counter = 0;
        }
      }
    }
  } catch (\Exception $e) {
    if (isset($transaction)) {
      $transaction->rollBack();
    }
    Error::logException($this->logger, $e);
    throw $e;
  }
}