Skip to content
Aggregation.php 1.55 KiB
Newer Older
<?php

declare(strict_types=1);

namespace IQDEV\ElasticSearch\Converter\Request\Aggregation;

use IQDEV\ElasticSearch\Configuration;
Nikita Chernykh's avatar
Nikita Chernykh committed
use IQDEV\ElasticSearch\Criteria\Criteria;
use IQDEV\ElasticSearch\Criteria\Filter\FilterType;
use IQDEV\ElasticSearch\Search\Aggs\AggsCollection;
use IQDEV\ElasticSearch\Search\Aggs\AggsFacetStats;
use IQDEV\ElasticSearch\Search\Aggs\AggsFacetTerms;

class Aggregation
{
    public function __construct(
        private readonly Configuration $configuration,
        private readonly Criteria $criteria,
        private readonly AggsCollection $aggregations = new AggsCollection(),
    ) {
        $this->convertToQuery();
    }

    public function convertToQuery(): void
    {
        $this->aggregations->add(
            AggsFacetTerms::create(
                'keyword_facet',
                'keyword_facet'
            )
        );

        $this->aggregations->add(
            AggsFacetStats::create(
                'number_facet',
                'number_facet'
            )
        );

       $postFilterCollection = $this->criteria->getFilters()->getFilterCollectionByType(FilterType::POST);

Nikita Chernykh's avatar
Nikita Chernykh committed
       $filterAggregation = new FilterAggregation($this->configuration, $postFilterCollection);
Nikita Chernykh's avatar
Nikita Chernykh committed
       $filterAggregation->updateRequestAggregation($this->aggregations);
Nikita Chernykh's avatar
Nikita Chernykh committed
       $fullAggregation = new FullAggregation($this->configuration, $postFilterCollection);
       $fullAggregation->updateRequestAggregation($this->aggregations);
    }

    public function getAggregation(): AggsCollection
    {
        return $this->aggregations;
    }
}