vendor/friendsofsymfony/elastica-bundle/src/Persister/Listener/FilterObjectsListener.php line 31

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\Persister\Listener;
  14. use FOS\ElasticaBundle\Persister\Event\Events;
  15. use FOS\ElasticaBundle\Persister\Event\PreInsertObjectsEvent;
  16. use FOS\ElasticaBundle\Provider\IndexableInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class FilterObjectsListener implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var IndexableInterface
  23.      */
  24.     private $indexable;
  26.     public function __construct(IndexableInterface $indexable)
  27.     {
  28.         $this->indexable = $indexable;
  29.     }
  31.     public function filterObjects(PreInsertObjectsEvent $event)
  32.     {
  33.         $options = $event->getOptions();
  34.         if (false == empty($options['skip_indexable_check'])) {
  35.             return;
  36.         }
  37.         
  38.         $objects = $event->getObjects();
  39.         $index = $options['indexName'];
  40.         $type = $options['typeName'];
  42.         $filtered = array();
  43.         foreach ($objects as $object) {
  44.             if (!$this->indexable->isObjectIndexable($index, $type, $object)) {
  45.                 continue;
  46.             }
  48.             $filtered[] = $object;
  49.         }
  51.         $event->setObjects($filtered);
  52.     }
  54.     /**
  55.      * {@inheritdoc}
  56.      */
  57.     public static function getSubscribedEvents()
  58.     {
  59.         return [Events::PRE_INSERT_OBJECTS => 'filterObjects'];
  60.     }
  61. }