Updates the {forum_index} records for a given node.

Parameters

\Drupal\node\NodeInterface $node: The node for which the index records are to be updated.

Overrides ForumIndexStorageInterface::updateIndex

1 call to ForumIndexStorage::updateIndex()

ForumIndexStorage::createIndex in core/modules/forum/src/ForumIndexStorage.php

Creates a {forum_index} entry for the given node.

File

core/modules/forum/src/ForumIndexStorage.php, line 93

Class

ForumIndexStorage

Handles CRUD operations to {forum_index} table.

Namespace

Drupal\forum

Code

public function updateIndex(NodeInterface $node) {
  $nid = $node->id();
  $count = $this->database
    ->query("SELECT COUNT(cid) FROM {comment_field_data} c INNER JOIN {forum_index} i ON c.entity_id = i.nid WHERE c.entity_id = :nid AND c.field_name = 'comment_forum' AND c.entity_type = 'node' AND c.status = :status AND c.default_langcode = 1", [
    ':nid' => $nid,
    ':status' => CommentInterface::PUBLISHED,
  ])
    ->fetchField();
  if ($count > 0) {
    // Comments exist.
    $last_reply = $this->database
      ->queryRange("SELECT cid, name, created, uid FROM {comment_field_data} WHERE entity_id = :nid AND field_name = 'comment_forum' AND entity_type = 'node' AND status = :status AND default_langcode = 1 ORDER BY cid DESC", 0, 1, [
      ':nid' => $nid,
      ':status' => CommentInterface::PUBLISHED,
    ])
      ->fetchObject();
    $this->database
      ->update('forum_index')
      ->fields([
      'comment_count' => $count,
      'last_comment_timestamp' => $last_reply->created,
    ])
      ->condition('nid', $nid)
      ->execute();
  }
  else {
    // Comments do not exist.
    // @todo This should be actually filtering on the desired node language
    $this->database
      ->update('forum_index')
      ->fields([
      'comment_count' => 0,
      'last_comment_timestamp' => $node->getCreatedTime(),
    ])
      ->condition('nid', $nid)
      ->execute();
  }
}

---