vendor/knplabs/knp-components/src/Knp/Component/Pager/Event/Subscriber/Paginate/ElasticaQuerySubscriber.php line 16

Open in your IDE?
  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Paginate;
  5. use Elastica\Query;
  6. use Elastica\SearchableInterface;
  7. use Knp\Component\Pager\Event\ItemsEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. /**
  11.  * Elastica query pagination.
  12.  *
  13.  */
  14. class ElasticaQuerySubscriber implements EventSubscriberInterface
  15. {
  16.     public function items(ItemsEvent $event): void
  17.     {
  18.         if (is_array($event->target) && 2 === count($event->target) && reset($event->target) instanceof SearchableInterface && end($event->target) instanceof Query) {
  19.             [$searchable, $query] = $event->target;
  21.             $query->setFrom($event->getOffset());
  22.             $query->setSize($event->getLimit());
  23.             $results = $searchable->search($query);
  25.             $event->count = $results->getTotalHits();
  27.             if ($results->hasAggregations()) {
  28.                 $event->setCustomPaginationParameter('aggregations', $results->getAggregations());
  29.             }
  31.             $event->setCustomPaginationParameter('resultSet', $results);
  32.             $event->items = $results->getResults();
  33.             $event->stopPropagation();
  34.         }
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             'knp_pager.items' => ['items', 0], /* triggers before a standard array subscriber*/
  41.         ];
  42.     }
  43. }