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

Open in your IDE?
  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Paginate;
  5. use Knp\Component\Pager\Event\ItemsEvent;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. /**
  9.  * Solarium query pagination.
  10.  *
  11.  * @author Paweł Jędrzejewski <pjedrzejewski@diweb.pl>
  12.  */
  13. class SolariumQuerySubscriber implements EventSubscriberInterface
  14. {
  15.     public function items(ItemsEvent $event)
  16.     {
  17.         if (is_array($event->target) && 2 == count($event->target)) {
  18.             $values = array_values($event->target);
  19.             list($client, $query) = $values;
  21.             if ($client instanceof \Solarium\Client && $query instanceof \Solarium\QueryType\Select\Query\Query) {
  22.                 $query->setStart($event->getOffset())->setRows($event->getLimit());
  23.                 $solrResult = $client->select($query);
  25.                 $event->items  = $solrResult->getIterator();
  26.                 $event->count  = $solrResult->getNumFound();
  27.                 $event->setCustomPaginationParameter('result', $solrResult);
  28.                 $event->stopPropagation();
  29.             }
  30.         }
  31.     }
  33.     public static function getSubscribedEvents()
  34.     {
  35.         return array(
  36.             'knp_pager.items' => array('items', 0) /* triggers before a standard array subscriber*/
  37.         );
  38.     }
  39. }