vendor/knplabs/knp-components/src/Knp/Component/Pager/Event/Subscriber/Sortable/ArraySubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace Knp\Component\Pager\Event\Subscriber\Sortable;
  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;
  10. use Symfony\Component\PropertyAccess\Exception\UnexpectedTypeException;
  11. use Symfony\Component\PropertyAccess\PropertyAccess;
  12. use Symfony\Component\PropertyAccess\PropertyAccessorInterface;
  14. class ArraySubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var string the field used to sort current object array list
  18.      */
  19.     private string $currentSortingField;
  21.     /**
  22.      * @var string the sorting direction
  23.      */
  24.     private string $sortDirection;
  26.     private ?PropertyAccessorInterface $propertyAccessor;
  28.     private ArgumentAccessInterface $argumentAccess;
  30.     public function __construct(ArgumentAccessInterface $argumentAccess, PropertyAccessorInterface $accessor = null)
  31.     {
  32.         if (!$accessor && class_exists(PropertyAccess::class)) {
  33.             $accessor = PropertyAccess::createPropertyAccessorBuilder()->enableMagicCall()->getPropertyAccessor();
  34.         }
  36.         $this->propertyAccessor = $accessor;
  37.         $this->argumentAccess = $argumentAccess;
  38.     }
  40.     public function items(ItemsEvent $event): void
  41.     {
  42.         // Check if the result has already been sorted by another sort subscriber
  43.         $customPaginationParameters = $event->getCustomPaginationParameters();
  44.         if (!empty($customPaginationParameters['sorted']) ) {
  45.             return;
  46.         }
  47.         $sortField = $event->options[PaginatorInterface::SORT_FIELD_PARAMETER_NAME];
  48.         if (!is_array($event->target) || null === $sortField || !$this->argumentAccess->has($sortField)) {
  49.             return;
  50.         }
  52.         $event->setCustomPaginationParameter('sorted', true);
  54.         if (isset($event->options[PaginatorInterface::SORT_FIELD_ALLOW_LIST]) && !in_array($this->argumentAccess->get($sortField), $event->options[PaginatorInterface::SORT_FIELD_ALLOW_LIST])) {
  55.             throw new InvalidValueException("Cannot sort by: [{$this->argumentAccess->get($sortField)}] this field is not in allow list.");
  56.         }
  58.         $sortFunction = $event->options['sortFunction'] ?? [$this, 'proxySortFunction'];
  59.         $sortField = $this->argumentAccess->get($sortField);
  61.         // compatibility layer
  62.         if ($sortField[0] === '.') {
  63.             $sortField = substr($sortField, 1);
  64.         }
  66.         call_user_func_array($sortFunction, [
  67.             &$event->target,
  68.             $sortField,
  69.             $this->getSortDirection($event->options),
  70.         ]);
  71.     }
  73.     private function getSortDirection(array $options): string
  74.     {
  75.         if (!$this->argumentAccess->has($options[PaginatorInterface::SORT_DIRECTION_PARAMETER_NAME])) {
  76.             return 'desc';
  77.         }
  78.         $direction = $this->argumentAccess->get($options[PaginatorInterface::SORT_DIRECTION_PARAMETER_NAME]);
  79.         if (strtolower($direction) === 'asc') {
  80.             return 'asc';
  81.         }
  83.         return 'desc';
  84.     }
  86.     private function proxySortFunction(&$target, $sortField, $sortDirection): bool
  87.     {
  88.         $this->currentSortingField = $sortField;
  89.         $this->sortDirection = $sortDirection;
  91.         return usort($target, [$this, 'sortFunction']);
  92.     }
  94.     private function sortFunction(object|array $object1, object|array $object2): int
  95.     {
  96.         if (null === $this->propertyAccessor) {
  97.             throw new \UnexpectedValueException('You need symfony/property-access component to use this sorting function');
  98.         }
  100.         if (!$this->propertyAccessor->isReadable($object1, $this->currentSortingField) || !$this->propertyAccessor->isReadable($object2, $this->currentSortingField)) {
  101.             return 0;
  102.         }
  104.         try {
  105.             $fieldValue1 = $this->propertyAccessor->getValue($object1, $this->currentSortingField);
  106.         } catch (UnexpectedTypeException) {
  107.             return -1 * $this->getSortCoefficient();
  108.         }
  110.         try {
  111.             $fieldValue2 = $this->propertyAccessor->getValue($object2, $this->currentSortingField);
  112.         } catch (UnexpectedTypeException) {
  113.             return $this->getSortCoefficient();
  114.         }
  116.         if (is_string($fieldValue1)) {
  117.             $fieldValue1 = mb_strtolower($fieldValue1);
  118.         }
  120.         if (is_string($fieldValue2)) {
  121.             $fieldValue2 = mb_strtolower($fieldValue2);
  122.         }
  124.         if ($fieldValue1 === $fieldValue2) {
  125.             return 0;
  126.         }
  128.         return ($fieldValue1 > $fieldValue2 ? 1 : -1) * $this->getSortCoefficient();
  129.     }
  131.     private function getSortCoefficient(): int
  132.     {
  133.         return $this->sortDirection === 'asc' ? 1 : -1;
  134.     }
  136.     public static function getSubscribedEvents(): array
  137.     {
  138.         return [
  139.             'knp_pager.items' => ['items', 1],
  140.         ];
  141.     }
  142. }