View source
<?php
namespace Drupal\aggregator\Controller;
use Drupal\Component\Utility\Xss;
use Drupal\Core\Controller\ControllerBase;
use Drupal\Core\Datetime\DateFormatterInterface;
use Drupal\aggregator\FeedInterface;
use Drupal\Core\Url;
use Symfony\Component\DependencyInjection\ContainerInterface;
class AggregatorController extends ControllerBase {
protected $dateFormatter;
public function __construct(DateFormatterInterface $date_formatter) {
$this->dateFormatter = $date_formatter;
}
public static function create(ContainerInterface $container) {
return new static($container
->get('date.formatter'));
}
public function feedAdd() {
$feed = $this
->entityTypeManager()
->getStorage('aggregator_feed')
->create();
return $this
->entityFormBuilder()
->getForm($feed);
}
protected function buildPageList(array $items, $feed_source = '') {
$build = [
'#type' => 'container',
'#attributes' => [
'class' => [
'aggregator-wrapper',
],
],
];
$build['feed_source'] = is_array($feed_source) ? $feed_source : [
'#markup' => $feed_source,
];
if ($items) {
$build['items'] = $this
->entityTypeManager()
->getViewBuilder('aggregator_item')
->viewMultiple($items, 'default');
$build['pager'] = [
'#type' => 'pager',
];
}
return $build;
}
public function feedRefresh(FeedInterface $aggregator_feed) {
$message = $aggregator_feed
->refreshItems() ? $this
->t('There is new syndicated content from %site.', [
'%site' => $aggregator_feed
->label(),
]) : $this
->t('There is no new syndicated content from %site.', [
'%site' => $aggregator_feed
->label(),
]);
$this
->messenger()
->addStatus($message);
return $this
->redirect('aggregator.admin_overview');
}
public function adminOverview() {
$entity_type_manager = $this
->entityTypeManager();
$feeds = $entity_type_manager
->getStorage('aggregator_feed')
->loadMultiple();
$header = [
$this
->t('Title'),
$this
->t('Items'),
$this
->t('Last update'),
$this
->t('Next update'),
$this
->t('Operations'),
];
$rows = [];
foreach ($feeds as $feed) {
$row = [];
$row[] = $feed
->toLink()
->toString();
$row[] = $this
->formatPlural($entity_type_manager
->getStorage('aggregator_item')
->getItemCount($feed), '1 item', '@count items');
$last_checked = $feed
->getLastCheckedTime();
$refresh_rate = $feed
->getRefreshRate();
$row[] = $last_checked ? $this
->t('@time ago', [
'@time' => $this->dateFormatter
->formatInterval(REQUEST_TIME - $last_checked),
]) : $this
->t('never');
if (!$last_checked && $refresh_rate) {
$next_update = $this
->t('imminently');
}
elseif ($last_checked && $refresh_rate) {
$next_update = $this
->t('%time left', [
'%time' => $this->dateFormatter
->formatInterval($last_checked + $refresh_rate - REQUEST_TIME),
]);
}
else {
$next_update = $this
->t('never');
}
$row[] = $next_update;
$links['edit'] = [
'title' => $this
->t('Edit'),
'url' => Url::fromRoute('entity.aggregator_feed.edit_form', [
'aggregator_feed' => $feed
->id(),
]),
];
$links['delete'] = [
'title' => $this
->t('Delete'),
'url' => Url::fromRoute('entity.aggregator_feed.delete_form', [
'aggregator_feed' => $feed
->id(),
]),
];
$links['delete_items'] = [
'title' => $this
->t('Delete items'),
'url' => Url::fromRoute('aggregator.feed_items_delete', [
'aggregator_feed' => $feed
->id(),
]),
];
$links['update'] = [
'title' => $this
->t('Update items'),
'url' => Url::fromRoute('aggregator.feed_refresh', [
'aggregator_feed' => $feed
->id(),
]),
];
$row[] = [
'data' => [
'#type' => 'operations',
'#links' => $links,
],
];
$rows[] = $row;
}
$build['feeds'] = [
'#prefix' => '<h3>' . $this
->t('Feed overview') . '</h3>',
'#type' => 'table',
'#header' => $header,
'#rows' => $rows,
'#empty' => $this
->t('No feeds available. <a href=":link">Add feed</a>.', [
':link' => Url::fromRoute('aggregator.feed_add')
->toString(),
]),
];
return $build;
}
public function pageLast() {
$items = $this
->entityTypeManager()
->getStorage('aggregator_item')
->loadAll(20);
$build = $this
->buildPageList($items);
$build['#attached']['feed'][] = [
'aggregator/rss',
$this
->config('system.site')
->get('name') . ' ' . $this
->t('aggregator'),
];
return $build;
}
public function feedTitle(FeedInterface $aggregator_feed) {
return [
'#markup' => $aggregator_feed
->label(),
'#allowed_tags' => Xss::getHtmlTagList(),
];
}
}