class SequenceIndex in Multiversion 8

Hierarchy

• class \Drupal\multiversion\Entity\Index\SequenceIndex implements SequenceIndexInterface

1 string reference to 'SequenceIndex'

multiversion.services.yml in ./multiversion.services.yml

multiversion.services.yml

1 service uses SequenceIndex

multiversion.entity_index.sequence in ./multiversion.services.yml

Drupal\multiversion\Entity\Index\SequenceIndex

File

src/Entity/Index/SequenceIndex.php, line 10

Namespace

Drupal\multiversion\Entity\Index

class SequenceIndex implements SequenceIndexInterface {

  /**
   * @var string
   */
  protected $collectionPrefix = 'multiversion.entity_index.sequence.';

  /**
   * @var string
   */
  protected $workspaceId;

  /**
   * @var \Drupal\key_value\KeyValueStore\KeyValueSortedSetFactoryInterface
   */
  protected $sortedSetFactory;

  /**
   * @var \Drupal\multiversion\Workspace\WorkspaceManagerInterface
   */
  protected $workspaceManager;

  /**
   * @var \Drupal\multiversion\MultiversionManagerInterface
   */
  protected $multiversionManager;

  /**
   * @param \Drupal\key_value\KeyValueStore\KeyValueSortedSetFactoryInterface $sorted_set_factory
   * @param \Drupal\multiversion\Workspace\WorkspaceManagerInterface $workspace_manager
   * @param \Drupal\multiversion\MultiversionManagerInterface $multiversion_manager
   */
  public function __construct(KeyValueSortedSetFactoryInterface $sorted_set_factory, WorkspaceManagerInterface $workspace_manager, MultiversionManagerInterface $multiversion_manager) {
    $this->sortedSetFactory = $sorted_set_factory;
    $this->workspaceManager = $workspace_manager;
    $this->multiversionManager = $multiversion_manager;
  }

  /**
   * {@inheritdoc}
   */
  public function useWorkspace($id) {
    $this->workspaceId = $id;
    return $this;
  }

  /**
   * {@inheritdoc}
   */
  public function add(ContentEntityInterface $entity) {
    $workspace_id = null;
    $record = $this
      ->buildRecord($entity);
    if ($entity
      ->getEntityType()
      ->get('workspace') === FALSE) {
      $workspace_id = 0;
    }
    $this
      ->sortedSetStore($workspace_id)
      ->add($record['seq'], $record);
  }

  /**
   * {@inheritdoc}
   */
  public function getRange($start, $stop = NULL, $inclusive = TRUE) {
    $range = $this
      ->sortedSetStore()
      ->getRange($start, $stop, $inclusive);
    if (empty($range)) {
      $range = $this
        ->sortedSetStore(0)
        ->getRange($start, $stop, $inclusive);
    }
    return $range;
  }

  /**
   * {@inheritdoc}
   */
  public function getLastSequenceId() {
    $max_score = $this
      ->sortedSetStore()
      ->getMaxScore();
    if (empty($max_score)) {
      $max_score = $this
        ->sortedSetStore(0)
        ->getMaxScore();
    }
    return $max_score;
  }

  /**
   * @param $workspace_id
   * @return \Drupal\key_value\KeyValueStore\KeyValueStoreSortedSetInterface
   */
  protected function sortedSetStore($workspace_id = null) {
    if (!$workspace_id) {
      $workspace_id = $this->workspaceId ?: $this->workspaceManager
        ->getActiveWorkspaceId();
    }
    return $this->sortedSetFactory
      ->get($this->collectionPrefix . $workspace_id);
  }

  /**
   * @param \Drupal\Core\Entity\ContentEntityInterface $entity
   * @return array
   */
  protected function buildRecord(ContentEntityInterface $entity) {
    return [
      'entity_type_id' => $entity
        ->getEntityTypeId(),
      'entity_id' => $entity
        ->id(),
      'entity_uuid' => $entity
        ->uuid(),
      'revision_id' => $entity
        ->getRevisionId(),
      'deleted' => $entity->_deleted->value,
      'rev' => $entity->_rev->value,
      'seq' => $this->multiversionManager
        ->newSequenceId(),
      'local' => (bool) $entity
        ->getEntityType()
        ->get('local'),
      'is_stub' => (bool) $entity->_rev->is_stub,
    ];
  }

}

Members

Name	Modifiers	Type	Description	Overrides
SequenceIndex::$collectionPrefix	protected	property
SequenceIndex::$multiversionManager	protected	property
SequenceIndex::$sortedSetFactory	protected	property
SequenceIndex::$workspaceId	protected	property
SequenceIndex::$workspaceManager	protected	property
SequenceIndex::add	public	function	Overrides SequenceIndexInterface::add
SequenceIndex::buildRecord	protected	function
SequenceIndex::getLastSequenceId	public	function	Overrides SequenceIndexInterface::getLastSequenceId
SequenceIndex::getRange	public	function	Overrides SequenceIndexInterface::getRange
SequenceIndex::sortedSetStore	protected	function
SequenceIndex::useWorkspace	public	function	Overrides IndexInterface::useWorkspace
SequenceIndex::__construct	public	function