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

  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Sortable\Doctrine\ODM\MongoDB;
  5. use Doctrine\ODM\MongoDB\Query\Query;
  6. use Knp\Component\Pager\ArgumentAccess\ArgumentAccessInterface;
  7. use Knp\Component\Pager\Event\ItemsEvent;
  8. use Knp\Component\Pager\Exception\InvalidValueException;
  9. use Knp\Component\Pager\PaginatorInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class QuerySubscriber implements EventSubscriberInterface
  13. {
  14.     private ArgumentAccessInterface $argumentAccess;
  16.     public function __construct(ArgumentAccessInterface $argumentAccess)
  17.     {
  18.         $this->argumentAccess = $argumentAccess;
  19.     }
  21.     public function items(ItemsEvent $event): void
  22.     {
  23.         // Check if the result has already been sorted by another sort subscriber
  24.         $customPaginationParameters = $event->getCustomPaginationParameters();
  25.         if (!empty($customPaginationParameters['sorted']) ) {
  26.             return;
  27.         }
  29.         if ($event->target instanceof Query) {
  30.             $event->setCustomPaginationParameter('sorted', true);
  31.             $sortField = $event->options[PaginatorInterface::SORT_FIELD_PARAMETER_NAME];
  32.             $sortDir = $event->options[PaginatorInterface::SORT_DIRECTION_PARAMETER_NAME];
  33.             if (null !== $sortField && $this->argumentAccess->has($sortField)) {
  34.                 $field = $this->argumentAccess->get($sortField);
  35.                 $dir = null !== $sortDir && strtolower($this->argumentAccess->get($sortDir)) === 'asc' ? 1 : -1;
  37.                 if (isset($event->options[PaginatorInterface::SORT_FIELD_ALLOW_LIST])) {
  38.                     if (!in_array($field, $event->options[PaginatorInterface::SORT_FIELD_ALLOW_LIST])) {
  39.                         throw new InvalidValueException("Cannot sort by: [{$field}] this field is not in allow list.");
  40.                     }
  41.                 }
  42.                 static $reflectionProperty;
  43.                 if (is_null($reflectionProperty)) {
  44.                     $reflectionClass = new \ReflectionClass(Query::class);
  45.                     $reflectionProperty = $reflectionClass->getProperty('query');
  46.                     $reflectionProperty->setAccessible(true);
  47.                 }
  48.                 $queryOptions = $reflectionProperty->getValue($event->target);
  50.                 // handle multi sort
  51.                 $sortFields = explode('+', $field);
  52.                 $sortOption = [];
  53.                 foreach ($sortFields as $sortField) {
  54.                     $sortOption[$sortField] = $dir;
  55.                 }
  57.                 $queryOptions['sort'] = $sortOption;
  58.                 $reflectionProperty->setValue($event->target, $queryOptions);
  59.             }
  60.         }
  61.     }
  63.     public static function getSubscribedEvents(): array
  64.     {
  65.         return [
  66.             'knp_pager.items' => ['items', 1],
  67.         ];
  68.     }
  69. }