vendor/knplabs/knp-components/src/Knp/Component/Pager/Event/Subscriber/Paginate/Doctrine/ODM/MongoDB/QuerySubscriber.php line 11

Open in your IDE?
  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Paginate\Doctrine\ODM\MongoDB;
  5. use Doctrine\ODM\MongoDB\Query\Query;
  6. use Knp\Component\Pager\Event\ItemsEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. class QuerySubscriber implements EventSubscriberInterface
  10. {
  11.     public function items(ItemsEvent $event): void
  12.     {
  13.         if ($event->target instanceof Query) {
  14.             // items
  15.             $type = $event->target->getType();
  16.             if ($type !== Query::TYPE_FIND) {
  17.                 throw new \UnexpectedValueException('ODM query must be a FIND type query');
  18.             }
  19.             static $reflectionProperty;
  20.             if (is_null($reflectionProperty)) {
  21.                 $reflectionClass = new \ReflectionClass('Doctrine\ODM\MongoDB\Query\Query');
  22.                 $reflectionProperty = $reflectionClass->getProperty('query');
  23.                 $reflectionProperty->setAccessible(true);
  24.             }
  25.             $queryOptions = $reflectionProperty->getValue($event->target);
  26.             $resultCount = clone $event->target;
  27.             $queryOptions['type'] = Query::TYPE_COUNT;
  28.             $reflectionProperty->setValue($resultCount, $queryOptions);
  29.             $event->count = $resultCount->execute();
  31.             $queryOptions = $reflectionProperty->getValue($event->target);
  32.             $queryOptions['type'] = Query::TYPE_FIND;
  33.             $queryOptions['limit'] = $event->getLimit();
  34.             $queryOptions['skip'] = $event->getOffset();
  35.             $resultQuery = clone $event->target;
  36.             $reflectionProperty->setValue($resultQuery, $queryOptions);
  37.             $cursor = $resultQuery->execute();
  39.             $event->items = [];
  40.             // iterator_to_array for GridFS results in 1 item
  41.             foreach ($cursor as $item) {
  42.                 $event->items[] = $item;
  43.             }
  44.             $event->stopPropagation();
  45.         }
  46.     }
  48.     public static function getSubscribedEvents(): array
  49.     {
  50.         return [
  51.             'knp_pager.items' => ['items', 0],
  52.         ];
  53.     }
  54. }