vendor/sulu/sulu/src/Sulu/Component/DocumentManager/Collection/QueryResultCollection.php line 91

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of Sulu.
  5.  *
  6.  * (c) Sulu GmbH
  7.  *
  8.  * This source file is subject to the MIT license that is bundled
  9.  * with this source code in the file LICENSE.
  10.  */
  12. namespace Sulu\Component\DocumentManager\Collection;
  14. use PHPCR\Query\QueryResultInterface;
  15. use Sulu\Component\DocumentManager\Event\HydrateEvent;
  16. use Sulu\Component\DocumentManager\Events;
  17. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  19. /**
  20.  * Lazily hydrate query results.
  21.  */
  22. class QueryResultCollection extends AbstractLazyCollection
  23. {
  24.     /**
  25.      * @var EventDispatcherInterface
  26.      */
  27.     private $eventDispatcher;
  29.     /**
  30.      * @var QueryResultInterface
  31.      */
  32.     private $result;
  34.     /**
  35.      * @var string
  36.      */
  37.     private $locale;
  39.     /**
  40.      * @var array
  41.      */
  42.     private $options;
  44.     /**
  45.      * @var bool
  46.      */
  47.     private $initialized = false;
  49.     /**
  50.      * @var null|string
  51.      */
  52.     private $primarySelector = null;
  54.     /**
  55.      * @param string $locale
  56.      * @param array $options
  57.      * @param null|string $primarySelector
  58.      */
  59.     public function __construct(
  60.         QueryResultInterface $result,
  61.         EventDispatcherInterface $eventDispatcher,
  62.         $locale,
  63.         $options = [],
  64.         $primarySelector = null
  65.     ) {
  66.         $this->result = $result;
  67.         $this->eventDispatcher = $eventDispatcher;
  68.         $this->locale = $locale;
  69.         $this->options = $options;
  70.         $this->primarySelector = $primarySelector;
  71.     }
  73.     public function current()
  74.     {
  75.         $this->initialize();
  76.         $row = $this->documents->current();
  77.         $node = $row->getNode($this->primarySelector);
  79.         $hydrateEvent = new HydrateEvent($node, $this->locale, $this->options);
  80.         $this->eventDispatcher->dispatch($hydrateEvent, Events::HYDRATE);
  82.         return $hydrateEvent->getDocument();
  83.     }
  85.     protected function initialize()
  86.     {
  87.         if (true === $this->initialized) {
  88.             return;
  89.         }
  91.         $this->documents = $this->result->getRows();
  92.         $this->initialized = true;
  93.     }
  94. }