vendor/monsieurbiz/sylius-search-plugin/src/Search/Response.php line 53

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of Monsieur Biz' Search plugin for Sylius.
  5.  *
  6.  * (c) Monsieur Biz <sylius@monsieurbiz.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE.txt
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace MonsieurBiz\SyliusSearchPlugin\Search;
  16. use Elastica\ResultSet;
  17. use JoliCode\Elastically\Result;
  18. use MonsieurBiz\SyliusSearchPlugin\Model\Documentable\DocumentableInterface;
  19. use MonsieurBiz\SyliusSearchPlugin\Search\Request\RequestConfiguration;
  20. use Pagerfanta\Adapter\AdapterInterface;
  21. use Pagerfanta\Pagerfanta;
  23. class Response implements ResponseInterface
  24. {
  25.     private RequestConfiguration $requestConfiguration;
  27.     private AdapterInterface $adapter;
  29.     private DocumentableInterface $documentable;
  31.     /**
  32.      * @var Pagerfanta<Result>|null
  33.      */
  34.     private ?Pagerfanta $paginator = null;
  36.     private array $filters = [];
  38.     private iterable $filterBuilders;
  40.     public function __construct(
  41.         RequestConfiguration $requestConfiguration,
  42.         AdapterInterface $adapter,
  43.         DocumentableInterface $documentable,
  44.         iterable $filterBuilders
  45.     ) {
  46.         $this->requestConfiguration = $requestConfiguration;
  47.         $this->adapter = $adapter;
  48.         $this->documentable = $documentable;
  49.         $this->filterBuilders = $filterBuilders;
  50.         $this->buildFilters();
  51.     }
  53.     public function getIterator()
  54.     {
  55.         return $this->getPaginator();
  56.     }
  58.     public function count()
  59.     {
  60.         return $this->getPaginator()->getNbResults();
  61.     }
  63.     public function getFilters(): array
  64.     {
  65.         return $this->filters;
  66.     }
  68.     public function getPaginator(): Pagerfanta
  69.     {
  70.         if (null === $this->paginator) {
  71.             $this->paginator = new Pagerfanta($this->adapter);
  72.             $this->paginator->setMaxPerPage($this->requestConfiguration->getLimit());
  73.             $this->paginator->setCurrentPage($this->requestConfiguration->getPage());
  74.         }
  76.         return $this->paginator;
  77.     }
  79.     public function getDocumentable(): DocumentableInterface
  80.     {
  81.         return $this->documentable;
  82.     }
  84.     private function buildFilters(): void
  85.     {
  86.         /** @var ResultSet $results */
  87.         $results = $this->getPaginator()->getCurrentPageResults();
  88.         $aggregations = $results->getAggregations();
  89.         // No aggregation so don't perform filters
  90.         if (0 === \count($aggregations)) {
  91.             return;
  92.         }
  94.         array_map(function ($aggregationCode, $aggregationData): void {
  95.             foreach ($this->filterBuilders as $filterBuilder) {
  96.                 if (null !== $filter = $filterBuilder->build($this->getDocumentable(), $this->requestConfiguration, $aggregationCode, $aggregationData)) {
  97.                     $this->filters[$filterBuilder->getPosition()][] = $filter;
  98.                 }
  99.             }
  100.         }, array_keys($aggregations), $aggregations);
  102.         $result = [];
  103.         ksort($this->filters);
  104.         foreach ($this->filters as $filters) {
  105.             foreach ($filters as $filter) {
  106.                 $result[] = $filter;
  107.             }
  108.         }
  109.         $this->filters = array_merge(...$result);
  110.     }
  111. }