src/Component/Elasticsearch/Form/Resolver/ListProductsFacetsResolver.php line 15

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace BitBag\OpenMarketplace\Component\Elasticsearch\Form\Resolver;
  7. use BitBag\OpenMarketplace\Component\Elasticsearch\QueryBuilder\ListProductsQueryBuilderInterface;
  8. use BitBag\SyliusElasticsearchPlugin\Facet\RegistryInterface;
  9. use Elastica\Aggregation\Filter as FilterAggregation;
  10. use Elastica\Query\BoolQuery;
  11. use FOS\ElasticaBundle\Finder\PaginatedFinderInterface;
  12. use Pagerfanta\Pagerfanta;
  13. use Symfony\Component\Form\FormEvent;
  15. final class ListProductsFacetsResolver implements ListProductsFacetsResolverInterface
  16. {
  17.     public function __construct(
  18.         private ListProductsQueryBuilderInterface $queryBuilder,
  19.         private RegistryInterface $facetRegistry,
  20.         private PaginatedFinderInterface $finder
  21.     ) {
  22.     }
  24.     public function resolveFacets(FormEvent $event): Pagerfanta
  25.     {
  26.         $query = $this->queryBuilder->getQuery($event);
  28.         $eventData = $event->getData() ?? [];
  29.         $rangeFilters = [];
  30.         foreach ($eventData['filters'] ?? [] as $facetId => $selectedBuckets) {
  31.             if (!empty($selectedBuckets) && is_array($selectedBuckets)
  32.                 && (array_key_exists('min', $selectedBuckets) || array_key_exists('max', $selectedBuckets))
  33.             ) {
  34.                 $rangeFilters[(string) $facetId] = $selectedBuckets;
  35.             }
  36.         }
  38.         foreach ($this->facetRegistry->getFacets() as $facetId => $facet) {
  39.             $aggregation = $facet->getAggregation()->setName((string) $facetId);
  41.             $otherRanges = array_diff_key($rangeFilters, [(string) $facetId => true]);
  43.             if (!empty($otherRanges)) {
  44.                 $filterBool = new BoolQuery();
  45.                 foreach ($otherRanges as $rfId => $rfBuckets) {
  46.                     try {
  47.                         $rangeFacet = $this->facetRegistry->getFacetById($rfId);
  48.                         $filterBool->addFilter($rangeFacet->getQuery($rfBuckets));
  49.                     } catch (\Exception $e) {
  50.                         continue;
  51.                     }
  52.                 }
  53.                 $aggregation->setName('_inner');
  54.                 $filterAgg = new FilterAggregation((string) $facetId, $filterBool);
  55.                 $filterAgg->addAggregation($aggregation);
  56.                 $query->addAggregation($filterAgg);
  57.             } else {
  58.                 $query->addAggregation($aggregation);
  59.             }
  60.         }
  62.         $query->setSize(0);
  64.         return $this->finder->findPaginated($query);
  65.     }
  66. }