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

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\Persister\Listener;
  14. use FOS\ElasticaBundle\Persister\Event\PreInsertObjectsEvent;
  15. use FOS\ElasticaBundle\Provider\IndexableInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class FilterObjectsListener implements EventSubscriberInterface
  19. {
  20.     private IndexableInterface $indexable;
  22.     public function __construct(IndexableInterface $indexable)
  23.     {
  24.         $this->indexable = $indexable;
  25.     }
  27.     public function filterObjects(PreInsertObjectsEvent $event): void
  28.     {
  29.         $options = $event->getOptions();
  30.         if (false == empty($options['skip_indexable_check'])) {
  31.             return;
  32.         }
  34.         $objects = $event->getObjects();
  35.         $index = $options['indexName'];
  37.         $filtered = [];
  38.         foreach ($objects as $object) {
  39.             if (!$this->indexable->isObjectIndexable($index, $object)) {
  40.                 continue;
  41.             }
  43.             $filtered[] = $object;
  44.         }
  46.         $event->setFilteredObjectCount(\count($objects) - \count($filtered));
  47.         $event->setObjects($filtered);
  48.     }
  50.     public static function getSubscribedEvents(): array
  51.     {
  52.         return [
  53.             PreInsertObjectsEvent::class => 'filterObjects',
  54.         ];
  55.     }
  56. }