<?php
namespace Knp\Component\Pager\Event\Subscriber\Sortable;
use Knp\Component\Pager\Event\ItemsEvent;
use Knp\Component\Pager\PaginatorInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\Request;
/**
* Solarium query sorting
*
* @author Marek Kalnik <marekk@theodo.fr>
*/
class SolariumQuerySubscriber implements EventSubscriberInterface
{
private Request $request;
public function __construct(Request $request)
{
$this->request = $request;
}
public function items(ItemsEvent $event): void
{
// Check if the result has already been sorted by an other sort subscriber
$customPaginationParameters = $event->getCustomPaginationParameters();
if (!empty($customPaginationParameters['sorted']) ) {
return;
}
if (is_array($event->target) && 2 === count($event->target)) {
$values = array_values($event->target);
[$client, $query] = $values;
if ($client instanceof \Solarium\Client && $query instanceof \Solarium\QueryType\Select\Query\Query) {
$event->setCustomPaginationParameter('sorted', true);
$sortField = $event->options[PaginatorInterface::SORT_FIELD_PARAMETER_NAME];
if (null !== $sortField && $this->request->query->has($sortField)) {
if (isset($event->options[PaginatorInterface::SORT_FIELD_ALLOW_LIST])) {
if (!in_array($this->request->query->get($sortField), $event->options[PaginatorInterface::SORT_FIELD_ALLOW_LIST])) {
throw new \UnexpectedValueException("Cannot sort by: [{$this->request->query->get($sortField)}] this field is not in allow list.");
}
}
$query->addSort($this->request->query->get($sortField), $this->getSortDirection($event));
}
}
}
}
public static function getSubscribedEvents(): array
{
return [
// trigger before the pagination subscriber
'knp_pager.items' => ['items', 1],
];
}
private function getSortDirection($event): string
{
$sortDir = $event->options[PaginatorInterface::SORT_DIRECTION_PARAMETER_NAME];
return null !== $sortDir && $this->request->query->has($sortDir) &&
strtolower($this->request->query->get($sortDir)) === 'asc' ? 'asc' : 'desc';
}
}