class ContentLock extends ServiceProviderBase {
  use StringTranslationTrait;

  /**
   * Form operation mode disabled.
   */
  const FORM_OP_MODE_DISABLED = 0;

  /**
   * Form operation mode whitelist.
   */
  const FORM_OP_MODE_WHITELIST = 1;

  /**
   * Form operation mode blacklist.
   */
  const FORM_OP_MODE_BLACKLIST = 2;

  /**
   * The database service.
   *
   * @var \Drupal\Core\Database\Connection
   *   The database service.
   */
  protected $database;

  /**
   * The module_handler service.
   *
   * @var \Drupal\Core\Extension\ModuleHandler
   *   The module_handler service.
   */
  protected $moduleHandler;

  /**
   * The date.formatter service.
   *
   * @var \Drupal\Core\Datetime\DateFormatter
   *   The date.formatter service.
   */
  protected $dateFormatter;

  /**
   * The current_user service.
   *
   * @var \Drupal\Core\Session\AccountProxy
   *   The current_user service.
   */
  protected $currentUser;

  /**
   * The config.factory service.
   *
   * @var \Drupal\Core\Config\Config
   *   The config settings.
   */
  protected $config;

  /**
   * The redirect.destination service.
   *
   * @var \Symfony\Component\HttpFoundation\Request
   *   The current request.
   */
  protected $currentRequest;

  /**
   * The entity_type.manager service.
   *
   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
   *   The entity_type.manager service.
   */
  protected $entityTypeManager;

  /**
   * The messenger service.
   *
   * @var \Drupal\Core\Messenger\MessengerInterface
   */
  protected $messenger;

  /**
   * Constructor.
   *
   * @param \Drupal\Core\Database\Connection $database
   *   The database connection.
   * @param \Drupal\Core\Extension\ModuleHandler $moduleHandler
   *   The module Handler service.
   * @param \Drupal\Core\Datetime\DateFormatter $dateFormatter
   *   The date.formatter service.
   * @param \Drupal\Core\Session\AccountProxy $currentUser
   *   The current_user service.
   * @param \Drupal\Core\Config\ConfigFactory $configFactory
   *   The config.factory service.
   * @param \Symfony\Component\HttpFoundation\RequestStack $requestStack
   *   The request stack service.
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entityTypeManager
   *   The entity_type.manager service.
   * @param \Drupal\Core\Messenger\MessengerInterface $messenger
   *   The messenger service.
   */
  public function __construct(Connection $database, ModuleHandler $moduleHandler, DateFormatter $dateFormatter, AccountProxy $currentUser, ConfigFactory $configFactory, RequestStack $requestStack, EntityTypeManagerInterface $entityTypeManager, MessengerInterface $messenger) {
    $this->database = $database;
    $this->moduleHandler = $moduleHandler;
    $this->dateFormatter = $dateFormatter;
    $this->currentUser = $currentUser;
    $this->config = $configFactory
      ->get('content_lock.settings');
    $this->currentRequest = $requestStack
      ->getCurrentRequest();
    $this->entityTypeManager = $entityTypeManager;
    $this->messenger = $messenger;
  }

  /**
   * Fetch the lock for an entity.
   *
   * @param int $entity_id
   *   The entity id.
   * @param string $langcode
   *   The translation language code of the entity.
   * @param string $form_op
   *   (optional) The entity form operation.
   * @param string $entity_type
   *   The entity type.
   *
   * @return object
   *   The lock for the node. FALSE, if the document is not locked.
   */
  public function fetchLock($entity_id, $langcode, $form_op = NULL, $entity_type = 'node') {
    if (!$this
      ->isTranslationLockEnabled($entity_type)) {
      $langcode = LanguageInterface::LANGCODE_NOT_SPECIFIED;
    }
    if (!$this
      ->isFormOperationLockEnabled($entity_type)) {
      $form_op = '*';
    }
    $query = $this->database
      ->select('content_lock', 'c');
    $query
      ->leftJoin('users_field_data', 'u', '%alias.uid = c.uid');
    $query
      ->fields('c')
      ->fields('u', [
      'name',
    ])
      ->condition('c.entity_type', $entity_type)
      ->condition('c.entity_id', $entity_id)
      ->condition('c.langcode', $langcode);
    if (isset($form_op)) {
      $query
        ->condition('c.form_op', $form_op);
    }
    return $query
      ->execute()
      ->fetchObject();
  }

  /**
   * Tell who has locked node.
   *
   * @param object $lock
   *   The lock for a node.
   * @param bool $translation_lock
   *   Defines whether the lock is on translation level or not.
   *
   * @return string
   *   String with the message.
   */
  public function displayLockOwner($lock, $translation_lock) {
    $username = $this->entityTypeManager
      ->getStorage('user')
      ->load($lock->uid);
    $date = $this->dateFormatter
      ->formatInterval(REQUEST_TIME - $lock->timestamp);
    if ($translation_lock) {
      $message = $this
        ->t('This content translation is being edited by the user @name and is therefore locked to prevent other users changes. This lock is in place since @date.', [
        '@name' => $username
          ->getDisplayName(),
        '@date' => $date,
      ]);
    }
    else {
      $message = $this
        ->t('This content is being edited by the user @name and is therefore locked to prevent other users changes. This lock is in place since @date.', [
        '@name' => $username
          ->getDisplayName(),
        '@date' => $date,
      ]);
    }
    return $message;
  }

  /**
   * Check lock status.
   *
   * @param int $entity_id
   *   The entity id.
   * @param string $langcode
   *   The translation language code of the entity.
   * @param string $form_op
   *   The entity form operation.
   * @param int $uid
   *   The user id.
   * @param string $entity_type
   *   The entity type.
   *
   * @return bool
   *   Return TRUE OR FALSE.
   */
  public function isLockedBy($entity_id, $langcode, $form_op, $uid, $entity_type = 'node') {
    if (!$this
      ->isTranslationLockEnabled($entity_type)) {
      $langcode = LanguageInterface::LANGCODE_NOT_SPECIFIED;
    }
    if (!$this
      ->isFormOperationLockEnabled($entity_type)) {
      $form_op = '*';
    }

    /** @var \Drupal\Core\Database\Query\SelectInterface $query */
    $query = $this->database
      ->select('content_lock', 'c')
      ->fields('c')
      ->condition('entity_id', $entity_id)
      ->condition('uid', $uid)
      ->condition('entity_type', $entity_type)
      ->condition('langcode', $langcode)
      ->condition('form_op', $form_op);
    $num_rows = $query
      ->countQuery()
      ->execute()
      ->fetchField();
    return (bool) $num_rows;
  }

  /**
   * Release a locked entity.
   *
   * @param int $entity_id
   *   The entity id.
   * @param string $langcode
   *   The translation language code of the entity.
   * @param string $form_op
   *   (optional) The entity form operation.
   * @param int $uid
   *   If set, verify that a lock belongs to this user prior to release.
   * @param string $entity_type
   *   The entity type.
   */
  public function release($entity_id, $langcode, $form_op = NULL, $uid = NULL, $entity_type = 'node') {
    if (!$this
      ->isTranslationLockEnabled($entity_type)) {
      $langcode = LanguageInterface::LANGCODE_NOT_SPECIFIED;
    }
    if (!$this
      ->isFormOperationLockEnabled($entity_type)) {
      $form_op = '*';
    }

    // Delete locking item from database.
    $this
      ->lockingDelete($entity_id, $langcode, $form_op, $uid, $entity_type);
    $this->moduleHandler
      ->invokeAll('content_lock_release', [
      $entity_id,
      $langcode,
      $form_op,
      $entity_type,
    ]);
  }

  /**
   * Release all locks set by a user.
   *
   * @param int $uid
   *   The user uid.
   */
  public function releaseAllUserLocks($uid) {
    $this->database
      ->delete('content_lock')
      ->condition('uid', $uid)
      ->execute();
  }

  /**
   * Save locking into database.
   *
   * @param int $entity_id
   *   The entity id.
   * @param string $langcode
   *   The translation language of the entity.
   * @param string $form_op
   *   The entity form operation.
   * @param int $uid
   *   The user uid.
   * @param string $entity_type
   *   The entity type.
   *
   * @return bool
   *   The result of the merge query.
   */
  protected function lockingSave($entity_id, $langcode, $form_op, $uid, $entity_type = 'node') {
    if (!$this
      ->isTranslationLockEnabled($entity_type)) {
      $langcode = LanguageInterface::LANGCODE_NOT_SPECIFIED;
    }
    if (!$this
      ->isFormOperationLockEnabled($entity_type)) {
      $form_op = '*';
    }
    $result = $this->database
      ->merge('content_lock')
      ->key([
      'entity_id' => $entity_id,
      'entity_type' => $entity_type,
      'langcode' => $langcode,
      'form_op' => $form_op,
    ])
      ->fields([
      'entity_id' => $entity_id,
      'entity_type' => $entity_type,
      'langcode' => $langcode,
      'form_op' => $form_op,
      'uid' => $uid,
      'timestamp' => REQUEST_TIME,
    ])
      ->execute();
    return $result;
  }

  /**
   * Delete locking item from database.
   *
   * @param int $entity_id
   *   The entity id.
   * @param string $langcode
   *   The translation language of the entity.
   * @param string $form_op
   *   (optional) The entity form operation.
   * @param int $uid
   *   The user uid.
   * @param string $entity_type
   *   The entity type.
   *
   * @return bool
   *   The result of the delete query.
   */
  protected function lockingDelete($entity_id, $langcode, $form_op = NULL, $uid = NULL, $entity_type = 'node') {
    if (!$this
      ->isTranslationLockEnabled($entity_type)) {
      $langcode = LanguageInterface::LANGCODE_NOT_SPECIFIED;
    }
    if (!$this
      ->isFormOperationLockEnabled($entity_type)) {
      $form_op = '*';
    }
    $query = $this->database
      ->delete('content_lock')
      ->condition('entity_type', $entity_type)
      ->condition('entity_id', $entity_id)
      ->condition('langcode', $langcode);
    if (isset($form_op)) {
      $query
        ->condition('form_op', $form_op);
    }
    if (!empty($uid)) {
      $query
        ->condition('uid', $uid);
    }
    $result = $query
      ->execute();
    return $result;
  }

  /**
   * Check if locking is verbose.
   *
   * @return bool
   *   Return true if locking is verbose.
   */
  public function verbose() {
    return $this->config
      ->get('verbose');
  }

  /**
   * Try to lock a document for editing.
   *
   * @param int $entity_id
   *   The entity id.
   * @param string $langcode
   *   The translation language of the entity.
   * @param string $form_op
   *   The entity form operation.
   * @param int $uid
   *   The user id to lock the node for.
   * @param string $entity_type
   *   The entity type.
   * @param bool $quiet
   *   Suppress any normal user messages.
   * @param string $destination
   *   Destination to redirect when break. Defaults to current page.
   *
   * @return bool
   *   FALSE, if a document has already been locked by someone else.
   *
   * @throws \InvalidArgumentException
   *   An exception will be thrown if the
   */
  public function locking($entity_id, $langcode, $form_op, $uid, $entity_type = 'node', $quiet = FALSE, $destination = NULL) {
    $translation_lock = $this
      ->isTranslationLockEnabled($entity_type);
    if (!$translation_lock) {
      $langcode = LanguageInterface::LANGCODE_NOT_SPECIFIED;
    }
    if (!$this
      ->isFormOperationLockEnabled($entity_type)) {
      $form_op = '*';
    }

    // Check locking status.
    $lock = $this
      ->fetchLock($entity_id, $langcode, $form_op, $entity_type);

    // No lock yet.
    if ($lock === FALSE || !is_object($lock)) {

      // Save locking into database.
      $this
        ->lockingSave($entity_id, $langcode, $form_op, $uid, $entity_type);
      if ($this
        ->verbose() && !$quiet) {
        if ($translation_lock) {
          $this->messenger
            ->addStatus($this
            ->t('This content translation is now locked against simultaneous editing. This content translation will remain locked if you navigate away from this page without saving or unlocking it.'));
        }
        else {
          $this->messenger
            ->addStatus($this
            ->t('This content is now locked against simultaneous editing. This content will remain locked if you navigate away from this page without saving or unlocking it.'));
        }
      }

      // Post locking hook.
      $this->moduleHandler
        ->invokeAll('content_lock_locked', [
        $entity_id,
        $langcode,
        $form_op,
        $uid,
        $entity_type,
      ]);

      // Send success flag.
      return TRUE;
    }
    else {

      // Currently locking by other user.
      if ($lock->uid != $uid) {

        // Send message.
        $message = $this
          ->displayLockOwner($lock, $translation_lock);
        $this->messenger
          ->addWarning($message);

        // Higher permission user can unblock.
        if ($this->currentUser
          ->hasPermission('break content lock')) {
          $link = Link::createFromRoute($this
            ->t('Break lock'), 'content_lock.break_lock.' . $entity_type, [
            'entity' => $entity_id,
            'langcode' => $langcode,
            'form_op' => $form_op,
          ], [
            'query' => [
              'destination' => isset($destination) ? $destination : $this->currentRequest
                ->getRequestUri(),
            ],
          ])
            ->toString();

          // Let user break lock.
          $this->messenger
            ->addWarning($this
            ->t('Click here to @link', [
            '@link' => $link,
          ]));
        }

        // Return FALSE flag.
        return FALSE;
      }
      else {

        // Save locking into database.
        $this
          ->lockingSave($entity_id, $langcode, $form_op, $uid, $entity_type);

        // Locked by current user.
        if ($this
          ->verbose() && !$quiet) {
          if ($translation_lock) {
            $this->messenger
              ->addStatus($this
              ->t('This content translation is now locked by you against simultaneous editing. This content translation will remain locked if you navigate away from this page without saving or unlocking it.'));
          }
          else {
            $this->messenger
              ->addStatus($this
              ->t('This content is now locked by you against simultaneous editing. This content will remain locked if you navigate away from this page without saving or unlocking it.'));
          }
        }

        // Send success flag.
        return TRUE;
      }
    }
  }

  /**
   * Check whether a node is configured to be protected by content_lock.
   *
   * @param \Drupal\Core\Entity\EntityInterface $entity
   *   The entity to check.
   * @param string $form_op
   *   (optional) The entity form operation.
   *
   * @return bool
   *   TRUE is entity is lockable
   */
  public function isLockable(EntityInterface $entity, $form_op = NULL) {
    $entity_id = $entity
      ->id();
    $entity_type = $entity
      ->getEntityTypeId();
    $bundle = $entity
      ->bundle();
    $config = $this->config
      ->get("types.{$entity_type}");
    $this->moduleHandler
      ->invokeAll('content_lock_entity_lockable', [
      $entity,
      $entity_id,
      $entity
        ->language()
        ->getId(),
      $form_op,
      $entity_type,
      $bundle,
      $config,
    ]);
    if (is_array($config) && (in_array($bundle, $config) || in_array('*', $config))) {
      if (isset($form_op) && $this
        ->isFormOperationLockEnabled($entity_type)) {
        $mode = $this->config
          ->get("form_op_lock.{$entity_type}.mode");
        $values = $this->config
          ->get("form_op_lock.{$entity_type}.values");
        if ($mode == self::FORM_OP_MODE_BLACKLIST) {
          return !in_array($form_op, $values);
        }
        elseif ($mode == self::FORM_OP_MODE_WHITELIST) {
          return in_array($form_op, $values);
        }
      }
      return TRUE;
    }

    // Always return FALSE.
    return FALSE;
  }

  /**
   * Check if for this entity_type content lock over JS is enabled.
   *
   * @param string $entity_type_id
   *   The entity type id.
   *
   * @return bool
   */
  public function isJsLock($entity_type_id) {
    return in_array($entity_type_id, $this->config
      ->get("types_js_lock") ?: []);
  }

  /**
   * Builds a button class, link type form element to unlock the content.
   *
   * @param string $entity_type
   *   The entity type of the content.
   * @param int $entity_id
   *   The entity id of the content.
   * @param string $langcode
   *   The translation language code of the entity.
   * @param string $form_op
   *   The entity form operation.
   * @param string $destination
   *   The destination query parameter to build the link with.
   *
   * @return array
   *   The link form element.
   */
  public function unlockButton($entity_type, $entity_id, $langcode, $form_op, $destination) {
    $unlock_url_options = [];
    if ($destination) {
      $unlock_url_options['query'] = [
        'destination' => $destination,
      ];
    }
    $route_parameters = [
      'entity' => $entity_id,
      'langcode' => $this
        ->isTranslationLockEnabled($entity_type) ? $langcode : LanguageInterface::LANGCODE_NOT_SPECIFIED,
      'form_op' => $this
        ->isFormOperationLockEnabled($entity_type) ? $form_op : '*',
    ];
    return [
      '#type' => 'link',
      '#title' => $this
        ->t('Unlock'),
      '#access' => TRUE,
      '#attributes' => [
        'class' => [
          'button',
        ],
      ],
      '#url' => Url::fromRoute('content_lock.break_lock.' . $entity_type, $route_parameters, $unlock_url_options),
      '#weight' => 99,
    ];
  }

  /**
   * Checks whether the entity type is lockable on translation level.
   *
   * @param string $entity_type_id
   *   The entity type ID.
   *
   * @return bool
   *   TRUE if the entity type should be locked on translation level, FALSE if
   *   it should be locked on entity level.
   */
  public function isTranslationLockEnabled($entity_type_id) {
    return $this->moduleHandler
      ->moduleExists('conflict') && in_array($entity_type_id, $this->config
      ->get("types_translation_lock"));
  }

  /**
   * Checks whether the entity type is lockable on translation level.
   *
   * @param string $entity_type_id
   *   The entity type ID.
   *
   * @return bool
   *   TRUE if the entity type should be locked on translation level, FALSE if
   *   it should be locked on entity level.
   */
  public function isFormOperationLockEnabled($entity_type_id) {
    return $this->config
      ->get("form_op_lock.{$entity_type_id}.mode") != self::FORM_OP_MODE_DISABLED;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
ContentLock::$config	protected	property	The config.factory service.
ContentLock::$currentRequest	protected	property	The redirect.destination service.
ContentLock::$currentUser	protected	property	The current_user service.
ContentLock::$database	protected	property	The database service.
ContentLock::$dateFormatter	protected	property	The date.formatter service.
ContentLock::$entityTypeManager	protected	property	The entity_type.manager service.
ContentLock::$messenger	protected	property	The messenger service.
ContentLock::$moduleHandler	protected	property	The module_handler service.
ContentLock::displayLockOwner	public	function	Tell who has locked node.
ContentLock::fetchLock	public	function	Fetch the lock for an entity.
ContentLock::FORM_OP_MODE_BLACKLIST		constant	Form operation mode blacklist.
ContentLock::FORM_OP_MODE_DISABLED		constant	Form operation mode disabled.
ContentLock::FORM_OP_MODE_WHITELIST		constant	Form operation mode whitelist.
ContentLock::isFormOperationLockEnabled	public	function	Checks whether the entity type is lockable on translation level.
ContentLock::isJsLock	public	function	Check if for this entity_type content lock over JS is enabled.
ContentLock::isLockable	public	function	Check whether a node is configured to be protected by content_lock.
ContentLock::isLockedBy	public	function	Check lock status.
ContentLock::isTranslationLockEnabled	public	function	Checks whether the entity type is lockable on translation level.
ContentLock::locking	public	function	Try to lock a document for editing.
ContentLock::lockingDelete	protected	function	Delete locking item from database.
ContentLock::lockingSave	protected	function	Save locking into database.
ContentLock::release	public	function	Release a locked entity.
ContentLock::releaseAllUserLocks	public	function	Release all locks set by a user.
ContentLock::unlockButton	public	function	Builds a button class, link type form element to unlock the content.
ContentLock::verbose	public	function	Check if locking is verbose.
ContentLock::__construct	public	function	Constructor.
ServiceProviderBase::alter	public	function	Modifies existing service definitions. Overrides ServiceModifierInterface::alter	5
ServiceProviderBase::register	public	function	Registers services to the container. Overrides ServiceProviderInterface::register	1
StringTranslationTrait::$stringTranslation	protected	property	The string translation service.	1
StringTranslationTrait::formatPlural	protected	function	Formats a string containing a count of items.
StringTranslationTrait::getNumberOfPlurals	protected	function	Returns the number of plurals supported by a given language.
StringTranslationTrait::getStringTranslation	protected	function	Gets the string translation service.
StringTranslationTrait::setStringTranslation	public	function	Sets the string translation service to use.	2
StringTranslationTrait::t	protected	function	Translates a string to the current language or to a given language.

You are here

class ContentLock in Content locking (anti-concurrent editing) 8

Hierarchy

File

Namespace

Members

API Navigation