View source
<?php
namespace Drupal\tracker\Controller;
use Drupal\comment\CommentStatisticsInterface;
use Drupal\Core\Access\AccessResult;
use Drupal\Core\Cache\CacheableMetadata;
use Drupal\Core\Controller\ControllerBase;
use Drupal\Core\Database\Connection;
use Drupal\Core\Database\Query\PagerSelectExtender;
use Drupal\Core\Datetime\DateFormatterInterface;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Session\AccountInterface;
use Drupal\user\UserInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
class TrackerController extends ControllerBase {
protected $database;
protected $databaseReplica;
protected $commentStatistics;
protected $dateFormatter;
protected $nodeStorage;
public function __construct(Connection $database, Connection $databaseReplica, CommentStatisticsInterface $commentStatistics, DateFormatterInterface $dateFormatter, EntityTypeManagerInterface $entityTypeManager) {
$this->database = $database;
$this->databaseReplica = $databaseReplica;
$this->commentStatistics = $commentStatistics;
$this->dateFormatter = $dateFormatter;
$this->entityTypeManager = $entityTypeManager;
$this->nodeStorage = $entityTypeManager
->getStorage('node');
}
public static function create(ContainerInterface $container) {
return new static($container
->get('database'), $container
->get('database.replica'), $container
->get('comment.statistics'), $container
->get('date.formatter'), $container
->get('entity_type.manager'));
}
public function getTitle(UserInterface $user) {
return $user
->getDisplayName();
}
public function checkAccess(UserInterface $user, AccountInterface $account) {
return AccessResult::allowedIf($account
->isAuthenticated() && $user
->id() == $account
->id())
->cachePerUser();
}
public function buildContent(UserInterface $user = NULL) {
if ($user) {
$query = $this->database
->select('tracker_user', 't')
->extend(PagerSelectExtender::class)
->addMetaData('base_table', 'tracker_user')
->condition('t.uid', $user
->id());
}
else {
$query = $this->databaseReplica
->select('tracker_node', 't')
->extend(PagerSelectExtender::class)
->addMetaData('base_table', 'tracker_node');
}
$tracker_data = $query
->addTag('node_access')
->fields('t', [
'nid',
'changed',
])
->condition('t.published', 1)
->orderBy('t.changed', 'DESC')
->limit(25)
->execute()
->fetchAllAssoc('nid');
$cacheable_metadata = new CacheableMetadata();
$rows = [];
if (!empty($tracker_data)) {
$nodes = $this->nodeStorage
->loadMultiple(array_keys($tracker_data));
$result = $this->commentStatistics
->read($nodes, 'node', FALSE);
foreach ($result as $statistics) {
$nid = $statistics->entity_id;
if (empty($nodes[$nid]->comment_count) || !is_numeric($tracker_data[$nid]->comment_count)) {
$tracker_data[$nid]->comment_count = $statistics->comment_count;
}
else {
$tracker_data[$nid]->comment_count += $statistics->comment_count;
}
if (!isset($tracker_data[$nid]->last_comment_timestamp)) {
$tracker_data[$nid]->last_comment_timestamp = $statistics->last_comment_timestamp;
}
else {
$tracker_data[$nid]->last_comment_timestamp = max($tracker_data[$nid]->last_comment_timestamp, $statistics->last_comment_timestamp);
}
}
foreach ($nodes as $node) {
$last_activity = $tracker_data[$node
->id()]->changed;
$owner = $node
->getOwner();
$row = [
'type' => node_get_type_label($node),
'title' => [
'data' => [
'#type' => 'link',
'#url' => $node
->toUrl(),
'#title' => $node
->getTitle(),
],
'data-history-node-id' => $node
->id(),
'data-history-node-timestamp' => $node
->getChangedTime(),
],
'author' => [
'data' => [
'#theme' => 'username',
'#account' => $owner,
],
],
'comments' => [
'class' => [
'comments',
],
'data' => $tracker_data[$node
->id()]->comment_count ?? 0,
'data-history-node-last-comment-timestamp' => $tracker_data[$node
->id()]->last_comment_timestamp ?? 0,
],
'last updated' => [
'data' => t('@time ago', [
'@time' => $this->dateFormatter
->formatTimeDiffSince($last_activity),
]),
],
];
$rows[] = $row;
$cacheable_metadata
->addCacheTags($node
->getCacheTags());
if ($owner) {
$cacheable_metadata
->addCacheTags($owner
->getCacheTags());
}
}
}
$cacheable_metadata
->addCacheTags($this->nodeStorage
->getEntityType()
->getListCacheTags());
$page['tracker'] = [
'#rows' => $rows,
'#header' => [
$this
->t('Type'),
$this
->t('Title'),
$this
->t('Author'),
$this
->t('Comments'),
$this
->t('Last updated'),
],
'#type' => 'table',
'#empty' => $this
->t('No content available.'),
];
$page['pager'] = [
'#type' => 'pager',
'#weight' => 10,
];
$page['#sorted'] = TRUE;
$cacheable_metadata
->addCacheContexts([
'user.node_grants:view',
]);
if ($this
->moduleHandler()
->moduleExists('history')) {
if ($this
->currentUser()
->isAuthenticated()) {
$page['#attached']['library'][] = 'tracker/history';
}
$cacheable_metadata
->addCacheContexts([
'user.roles:authenticated',
]);
}
$cacheable_metadata
->applyTo($page);
return $page;
}
}