vendor/shopware/elasticsearch/Admin/Subscriber/RefreshIndexSubscriber.php line 34

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Elasticsearch\Admin\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Event\RefreshIndexEvent;
  6. use Shopware\Core\Framework\Log\Package;
  7. use Shopware\Elasticsearch\Admin\AdminIndexingBehavior;
  8. use Shopware\Elasticsearch\Admin\AdminSearchRegistry;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. /**
  12.  * @internal
  13.  */
  14. #[Package('system-settings')]
  15. final class RefreshIndexSubscriber implements EventSubscriberInterface
  16. {
  17.     private AdminSearchRegistry $registry;
  19.     public function __construct(AdminSearchRegistry $registry)
  20.     {
  21.         $this->registry = $registry;
  22.     }
  24.     /**
  25.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  26.      */
  27.     public static function getSubscribedEvents()
  28.     {
  29.         return [
  30.             RefreshIndexEvent::class => 'handled',
  31.         ];
  32.     }
  34.     public function handled(RefreshIndexEvent $event): void
  35.     {
  36.         $this->registry->iterate(
  37.             new AdminIndexingBehavior(
  38.                 $event->getNoQueue(),
  39.                 $event->getSkipEntities(),
  40.                 $event->getOnlyEntities()
  41.             )
  42.         );
  43.     }
  44. }