function ForumManager::getTopics

Overrides ForumManagerInterface::getTopics

File

core/modules/forum/src/ForumManager.php, line 155

Class

ForumManager

Provides forum manager service.

Namespace

Code

public function getTopics($tid, AccountInterface $account) {
    $config = $this->configFactory
        ->get('forum.settings');
    $forum_per_page = $config->get('topics.page_limit');
    $sortby = $config->get('topics.order');
    $header = [
        [
            'data' => $this->t('Topic'),
            'field' => 'f.title',
        ],
        [
            'data' => $this->t('Replies'),
            'field' => 'f.comment_count',
        ],
        [
            'data' => $this->t('Last reply'),
            'field' => 'f.last_comment_timestamp',
        ],
    ];
    $order = $this->getTopicOrder($sortby);
    for ($i = 0; $i < count($header); $i++) {
        if ($header[$i]['field'] == $order['field']) {
            $header[$i]['sort'] = $order['sort'];
        }
    }
    $query = $this->connection
        ->select('forum_index', 'f')
        ->extend('Drupal\\Core\\Database\\Query\\PagerSelectExtender')
        ->extend('Drupal\\Core\\Database\\Query\\TableSortExtender');
    $query->fields('f');
    $query->condition('f.tid', $tid)
        ->addTag('node_access')
        ->addMetaData('base_table', 'forum_index')
        ->orderBy('f.sticky', 'DESC')
        ->orderByHeader($header)
        ->limit($forum_per_page);
    $count_query = $this->connection
        ->select('forum_index', 'f');
    $count_query->condition('f.tid', $tid);
    $count_query->addExpression('COUNT(*)');
    $count_query->addTag('node_access');
    $count_query->addMetaData('base_table', 'forum_index');
    $query->setCountQuery($count_query);
    $result = $query->execute();
    $nids = [];
    foreach ($result as $record) {
        $nids[] = $record->nid;
    }
    if ($nids) {
        $nodes = $this->entityTypeManager
            ->getStorage('node')
            ->loadMultiple($nids);
        $query = $this->connection
            ->select('node_field_data', 'n')
            ->extend('Drupal\\Core\\Database\\Query\\TableSortExtender');
        $query->fields('n', [
            'nid',
        ]);
        $query->join('comment_entity_statistics', 'ces', "n.nid = ces.entity_id AND ces.field_name = 'comment_forum' AND ces.entity_type = 'node'");
        $query->fields('ces', [
            'cid',
            'last_comment_uid',
            'last_comment_timestamp',
            'comment_count',
        ]);
        $query->join('forum_index', 'f', 'f.nid = n.nid');
        $query->addField('f', 'tid', 'forum_tid');
        $query->join('users_field_data', 'u', 'n.uid = u.uid AND u.default_langcode = 1');
        $query->addField('u', 'name');
        $query->join('users_field_data', 'u2', 'ces.last_comment_uid = u2.uid AND u.default_langcode = 1');
        $query->addExpression('CASE ces.last_comment_uid WHEN 0 THEN ces.last_comment_name ELSE u2.name END', 'last_comment_name');
        $query->orderBy('f.sticky', 'DESC')
            ->orderByHeader($header)
            ->condition('n.nid', $nids, 'IN')
            ->condition('n.default_langcode', 1);
        $result = [];
        foreach ($query->execute() as $row) {
            $topic = $nodes[$row->nid];
            $topic->comment_mode = $topic->comment_forum->status;
            foreach ($row as $key => $value) {
                $topic->{$key} = $value;
            }
            $result[] = $topic;
        }
    }
    else {
        $result = [];
    }
    $topics = [];
    $first_new_found = FALSE;
    foreach ($result as $topic) {
        if ($account->isAuthenticated()) {
            // A forum is new if the topic is new, or if there are new comments since
            // the user's last visit.
            if ($topic->forum_tid != $tid) {
                $topic->new = 0;
            }
            else {
                $history = $this->lastVisit($topic->id(), $account);
                $topic->new_replies = $this->commentManager
                    ->getCountNewComments($topic, 'comment_forum', $history);
                $topic->new = $topic->new_replies || $topic->last_comment_timestamp > $history;
            }
        }
        else {
            // Do not track "new replies" status for topics if the user is anonymous.
            $topic->new_replies = 0;
            $topic->new = 0;
        }
        // Make sure only one topic is indicated as the first new topic.
        $topic->first_new = FALSE;
        if ($topic->new != 0 && !$first_new_found) {
            $topic->first_new = TRUE;
            $first_new_found = TRUE;
        }
        if ($topic->comment_count > 0) {
            $last_reply = new \stdClass();
            $last_reply->created = $topic->last_comment_timestamp;
            $last_reply->name = $topic->last_comment_name;
            $last_reply->uid = $topic->last_comment_uid;
            $topic->last_reply = $last_reply;
        }
        $topics[$topic->id()] = $topic;
    }
    return [
        'topics' => $topics,
        'header' => $header,
    ];
}