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

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the FOSElasticaBundle package.
  5.  *
  6.  * (c) FriendsOfSymfony <http://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\SearchableInterface;
  16. use FOS\ElasticaBundle\Paginator\FantaPaginatorAdapter;
  17. use FOS\ElasticaBundle\Paginator\HybridPaginatorAdapter;
  18. use FOS\ElasticaBundle\Paginator\RawPaginatorAdapter;
  19. use FOS\ElasticaBundle\Paginator\TransformedPaginatorAdapter;
  20. use FOS\ElasticaBundle\Transformer\ElasticaToModelTransformerInterface;
  21. use Pagerfanta\Pagerfanta;
  23. /**
  24.  * Finds elastica documents and map them to persisted objects.
  25.  */
  26. class TransformedFinder implements PaginatedFinderInterface
  27. {
  28.     /**
  29.      * @var SearchableInterface
  30.      */
  31.     protected $searchable;
  33.     /**
  34.      * @var ElasticaToModelTransformerInterface
  35.      */
  36.     protected $transformer;
  38.     /**
  39.      * @param SearchableInterface                 $searchable
  40.      * @param ElasticaToModelTransformerInterface $transformer
  41.      */
  42.     public function __construct(SearchableInterface $searchable, ElasticaToModelTransformerInterface $transformer)
  43.     {
  44.         $this->searchable = $searchable;
  45.         $this->transformer = $transformer;
  46.     }
  48.     /**
  49.      * {@inheritdoc}
  50.      */
  51.     public function find($query, $limit = null, $options = [])
  52.     {
  53.         $results = $this->search($query, $limit, $options);
  55.         return $this->transformer->transform($results);
  56.     }
  58.     /**
  59.      * @param $query
  60.      * @param null|int $limit
  61.      * @param array    $options
  62.      *
  63.      * @return array
  64.      */
  65.     public function findHybrid($query, $limit = null, $options = [])
  66.     {
  67.         $results = $this->search($query, $limit, $options);
  69.         return $this->transformer->hybridTransform($results);
  70.     }
  72.     /**
  73.      * {@inheritdoc}
  74.      */
  75.     public function findPaginated($query, $options = [])
  76.     {
  77.         $queryObject = Query::create($query);
  78.         $paginatorAdapter = $this->createPaginatorAdapter($queryObject, $options);
  80.         return new Pagerfanta(new FantaPaginatorAdapter($paginatorAdapter));
  81.     }
  83.     /**
  84.      * {@inheritdoc}
  85.      */
  86.     public function createPaginatorAdapter($query, $options = [])
  87.     {
  88.         $query = Query::create($query);
  90.         return new TransformedPaginatorAdapter($this->searchable, $query, $options, $this->transformer);
  91.     }
  93.     /**
  94.      * {@inheritdoc}
  95.      */
  96.     public function createHybridPaginatorAdapter($query)
  97.     {
  98.         $query = Query::create($query);
  100.         return new HybridPaginatorAdapter($this->searchable, $query, $this->transformer);
  101.     }
  103.     /**
  104.      * {@inheritdoc}
  105.      */
  106.     public function createRawPaginatorAdapter($query, $options = [])
  107.     {
  108.         $query = Query::create($query);
  110.         return new RawPaginatorAdapter($this->searchable, $query, $options);
  111.     }
  113.     /**
  114.      * @param $query
  115.      * @param null|int $limit
  116.      * @param array    $options
  117.      *
  118.      * @return array
  119.      */
  120.     protected function search($query, $limit = null, $options = [])
  121.     {
  122.         $queryObject = Query::create($query);
  123.         if (null !== $limit) {
  124.             $queryObject->setSize($limit);
  125.         }
  126.         $results = $this->searchable->search($queryObject, $options)->getResults();
  128.         return $results;
  129.     }
  130. }