vendor/friendsofsymfony/elastica-bundle/src/Finder/TransformedFinder.php line 41

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the FOSElasticaBundle package.
  5.  *
  6.  * (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace FOS\ElasticaBundle\Finder;
  14. use Elastica\Query;
  15. use Elastica\Result;
  16. use Elastica\SearchableInterface;
  17. use FOS\ElasticaBundle\Paginator\FantaPaginatorAdapter;
  18. use FOS\ElasticaBundle\Paginator\HybridPaginatorAdapter;
  19. use FOS\ElasticaBundle\Paginator\RawPaginatorAdapter;
  20. use FOS\ElasticaBundle\Paginator\TransformedPaginatorAdapter;
  21. use FOS\ElasticaBundle\Transformer\ElasticaToModelTransformerInterface;
  22. use Pagerfanta\Pagerfanta;
  24. /**
  25.  * Finds elastica documents and map them to persisted objects.
  26.  *
  27.  * @phpstan-import-type TQuery from FinderInterface
  28.  * @phpstan-import-type TOptions from FinderInterface
  29.  */
  30. class TransformedFinder implements PaginatedFinderInterface, PaginatedRawFinderInterface, PaginatedHybridFinderInterface
  31. {
  32.     protected SearchableInterface $searchable;
  33.     protected ElasticaToModelTransformerInterface $transformer;
  35.     public function __construct(SearchableInterface $searchable, ElasticaToModelTransformerInterface $transformer)
  36.     {
  37.         $this->searchable = $searchable;
  38.         $this->transformer = $transformer;
  39.     }
  41.     public function find($query, ?int $limit = null, array $options = [])
  42.     {
  43.         $results = $this->search($query, $limit, $options);
  45.         return $this->transformer->transform($results);
  46.     }
  48.     public function findHybrid($query, ?int $limit = null, array $options = [])
  49.     {
  50.         $results = $this->search($query, $limit, $options);
  52.         return $this->transformer->hybridTransform($results);
  53.     }
  55.     public function findRaw($query, ?int $limit = null, array $options = []): array
  56.     {
  57.         return $this->search($query, $limit, $options);
  58.     }
  60.     public function findPaginated($query, array $options = [])
  61.     {
  62.         $paginatorAdapter = $this->createPaginatorAdapter($query, $options);
  64.         return new Pagerfanta(new FantaPaginatorAdapter($paginatorAdapter));
  65.     }
  67.     public function findHybridPaginated($query, array $options = [])
  68.     {
  69.         $paginatorAdapter = $this->createHybridPaginatorAdapter($query, $options);
  71.         return new Pagerfanta(new FantaPaginatorAdapter($paginatorAdapter));
  72.     }
  74.     public function findRawPaginated($query, array $options = [])
  75.     {
  76.         $paginatorAdapter = $this->createRawPaginatorAdapter($query, $options);
  78.         return new Pagerfanta(new FantaPaginatorAdapter($paginatorAdapter));
  79.     }
  81.     public function createPaginatorAdapter($query, array $options = [])
  82.     {
  83.         $query = Query::create($query);
  85.         return new TransformedPaginatorAdapter($this->searchable, $query, $options, $this->transformer);
  86.     }
  88.     public function createHybridPaginatorAdapter($query, array $options = [])
  89.     {
  90.         $query = Query::create($query);
  92.         return new HybridPaginatorAdapter($this->searchable, $query, $options, $this->transformer);
  93.     }
  95.     public function createRawPaginatorAdapter($query, array $options = [])
  96.     {
  97.         $query = Query::create($query);
  99.         return new RawPaginatorAdapter($this->searchable, $query, $options);
  100.     }
  102.     /**
  103.      * @phpstan-param TQuery $query
  104.      * @phpstan-param TOptions $options
  105.      *
  106.      * @param mixed $query
  107.      *
  108.      * @return Result[]
  109.      */
  110.     protected function search($query, ?int $limit = null, array $options = [])
  111.     {
  112.         $queryObject = Query::create($query);
  113.         if (null !== $limit) {
  114.             $queryObject->setSize($limit);
  115.         }
  117.         return $this->searchable->search($queryObject, $options)->getResults();
  118.     }
  119. }