3 namespace Drupal\aggregator;
5 use Drupal\Core\Entity\Query\QueryInterface;
6 use Drupal\Core\Entity\Sql\SqlContentEntityStorage;
9 * Controller class for aggregators items.
11 * This extends the Drupal\Core\Entity\Sql\SqlContentEntityStorage class, adding
12 * required special handling for feed item entities.
14 class ItemStorage extends SqlContentEntityStorage implements ItemStorageInterface {
19 public function getItemCount(FeedInterface $feed) {
20 $query = \Drupal::entityQuery('aggregator_item')
21 ->condition('fid', $feed->id())
24 return $query->execute();
30 public function loadAll($limit = NULL) {
31 $query = \Drupal::entityQuery('aggregator_item');
32 return $this->executeFeedItemQuery($query, $limit);
38 public function loadByFeed($fid, $limit = NULL) {
39 $query = \Drupal::entityQuery('aggregator_item')
40 ->condition('fid', $fid);
41 return $this->executeFeedItemQuery($query, $limit);
45 * Helper method to execute an item query.
47 * @param \Drupal\Core\Entity\Query\QueryInterface $query
48 * The query to execute.
50 * (optional) The number of items to return.
52 * @return \Drupal\aggregator\ItemInterface[]
53 * An array of the feed items.
55 protected function executeFeedItemQuery(QueryInterface $query, $limit) {
56 $query->sort('timestamp', 'DESC')
57 ->sort('iid', 'DESC');
59 $query->pager($limit);
62 return $this->loadMultiple($query->execute());