vendor/monsieurbiz/sylius-search-plugin/src/Search/Request/AggregationBuilder.php line 59

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\Request;
  16. use Elastica\Aggregation\AbstractAggregation;
  17. use MonsieurBiz\SyliusSearchPlugin\Search\Request\Aggregation\AggregationBuilderInterface;
  18. use RuntimeException;
  20. class AggregationBuilder
  21. {
  22.     /**
  23.      * @var iterable<AggregationBuilderInterface>
  24.      */
  25.     private iterable $aggregationBuilders;
  27.     public function __construct(iterable $aggregationBuilders)
  28.     {
  29.         $this->aggregationBuilders = $aggregationBuilders;
  30.     }
  32.     public function buildAggregations(array $aggregations, array $filters): array
  33.     {
  34.         $buckets = [];
  36.         foreach ($aggregations as $aggregation) {
  37.             $aggregationQuery = $this->buildAggregation($aggregation, $filters);
  38.             if (false === $aggregationQuery) {
  39.                 continue;
  40.             }
  41.             $buckets[] = $aggregationQuery;
  42.         }
  44.         return array_filter($buckets);
  45.     }
  47.     /**
  48.      * @param string|array $aggregation
  49.      *
  50.      * @return AbstractAggregation|bool
  51.      */
  52.     private function buildAggregation($aggregation, array $filters)
  53.     {
  54.         // Don't build aggregation if the given one is empty
  55.         if (empty($aggregation)) {
  56.             return false;
  57.         }
  59.         foreach ($this->aggregationBuilders as $aggregationBuilder) {
  60.             $aggregationQuery = $aggregationBuilder->build($aggregation, $filters);
  61.             if (null !== $aggregationQuery) {
  62.                 return $aggregationQuery;
  63.             }
  64.         }
  66.         throw new RuntimeException('Aggregation cannot be build'); // it's throw an exception if we have not filtreable attribute
  67.     }
  68. }