function WorkspacePublisher::publish

Publishes the contents of a workspace to the default (Live) workspace.

Overrides WorkspacePublisherInterface::publish

File

core/modules/workspaces/src/WorkspacePublisher.php, line 104

Class

WorkspacePublisher

Default implementation of the workspace publisher.

Namespace

Code

public function publish() {
  if ($this->sourceWorkspace
    ->hasParent()) {
    throw new WorkspacePublishException('Only top-level workspaces can be published.');
  }
  if ($this->checkConflictsOnTarget()) {
    throw new WorkspaceConflictException();
  }
  $tracked_entities = $this->workspaceAssociation
    ->getTrackedEntities($this->sourceWorkspace
    ->id());
  $event = new WorkspacePrePublishEvent($this->sourceWorkspace, $tracked_entities);
  $this->eventDispatcher
    ->dispatch($event);
  if ($event->isPublishingStopped()) {
    throw new WorkspacePublishException((string) $event->getPublishingStoppedReason());
  }
  try {
    $transaction = $this->database
      ->startTransaction();
    $this->workspaceManager
      ->executeOutsideWorkspace(function () use ($tracked_entities) {
      $max_execution_time = ini_get('max_execution_time');
      $step_size = Settings::get('entity_update_batch_size', 50);
      $counter = 0;
      foreach ($tracked_entities as $entity_type_id => $revision_difference) {
        $entity_revisions = $this->entityTypeManager
          ->getStorage($entity_type_id)
          ->loadMultipleRevisions(array_keys($revision_difference));
        $default_revisions = $this->entityTypeManager
          ->getStorage($entity_type_id)
          ->loadMultiple(array_values($revision_difference));
        /** @var \Drupal\Core\Entity\ContentEntityInterface $entity */
        foreach ($entity_revisions as $entity) {
          // When pushing workspace-specific revisions to the default
          // workspace (Live), we simply need to mark them as default
          // revisions.
          $entity->setSyncing(TRUE);
          $entity->isDefaultRevision(TRUE);
          // The default revision is not workspace-specific anymore.
          $field_name = $entity->getEntityType()
            ->getRevisionMetadataKey('workspace');
          $entity->{$field_name}->target_id = NULL;
          $entity->original = $default_revisions[$entity->id()];
          $entity->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;
  }
  $event = new WorkspacePostPublishEvent($this->sourceWorkspace, $tracked_entities);
  $this->eventDispatcher
    ->dispatch($event);
}