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

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