vendor/knplabs/knp-components/src/Knp/Component/Pager/Event/Subscriber/Filtration/PropelQuerySubscriber.php line 20

  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Filtration;
  5. use Knp\Component\Pager\ArgumentAccess\ArgumentAccessInterface;
  6. use Knp\Component\Pager\Event\ItemsEvent;
  7. use Knp\Component\Pager\Exception\InvalidValueException;
  8. use Knp\Component\Pager\PaginatorInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class PropelQuerySubscriber implements EventSubscriberInterface
  12. {
  13.     private ArgumentAccessInterface $argumentAccess;
  15.     public function __construct(ArgumentAccessInterface $argumentAccess)
  16.     {
  17.         $this->argumentAccess = $argumentAccess;
  18.     }
  20.     public function items(ItemsEvent $event): void
  21.     {
  22.         $query = $event->target;
  23.         if ($query instanceof \ModelCriteria) {
  24.             if (!$this->argumentAccess->has($event->options[PaginatorInterface::FILTER_VALUE_PARAMETER_NAME])) {
  25.                 return;
  26.             }
  27.             if ($this->argumentAccess->has($event->options[PaginatorInterface::FILTER_FIELD_PARAMETER_NAME])) {
  28.                 $columns = $this->argumentAccess->get($event->options[PaginatorInterface::FILTER_FIELD_PARAMETER_NAME]);
  29.             } elseif (!empty($event->options[PaginatorInterface::DEFAULT_FILTER_FIELDS])) {
  30.                 $columns = $event->options[PaginatorInterface::DEFAULT_FILTER_FIELDS];
  31.             } else {
  32.                 return;
  33.             }
  34.             if (is_string($columns) && false !== strpos($columns, ',')) {
  35.                 $columns = explode(',', $columns);
  36.             }
  37.             $columns = (array) $columns;
  38.             if (isset($event->options[PaginatorInterface::FILTER_FIELD_ALLOW_LIST])) {
  39.                 foreach ($columns as $column) {
  40.                     if (!in_array($column, $event->options[PaginatorInterface::FILTER_FIELD_ALLOW_LIST])) {
  41.                         throw new InvalidValueException("Cannot filter by: [{$column}] this field is not in allow list");
  42.                     }
  43.                 }
  44.             }
  45.             $value = $this->argumentAccess->get($event->options[PaginatorInterface::FILTER_VALUE_PARAMETER_NAME]);
  46.             $criteria = \Criteria::EQUAL;
  47.             if (false !== strpos($value, '*')) {
  48.                 $value = str_replace('*', '%', $value);
  49.                 $criteria = \Criteria::LIKE;
  50.             }
  51.             foreach ($columns as $column) {
  52.                 if (false !== strpos($column, '.')) {
  53.                     $query->where($column.$criteria.'?', $value);
  54.                 } else {
  55.                     $query->{'filterBy'.$column}($value, $criteria);
  56.                 }
  57.             }
  58.         }
  59.     }
  61.     public static function getSubscribedEvents(): array
  62.     {
  63.         return [
  64.             'knp_pager.items' => ['items', 0],
  65.         ];
  66.     }
  67. }