src/Elasticsearch/Admin/Subscriber/RefreshIndexSubscriber.php line 31

  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.     public function __construct(private readonly AdminSearchRegistry $registry)
  18.     {
  19.     }
  21.     /**
  22.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  23.      */
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             RefreshIndexEvent::class => 'handled',
  28.         ];
  29.     }
  31.     public function handled(RefreshIndexEvent $event): void
  32.     {
  33.         $this->registry->iterate(
  34.             new AdminIndexingBehavior(
  35.                 $event->getNoQueue(),
  36.                 $event->getSkipEntities(),
  37.                 $event->getOnlyEntities()
  38.             )
  39.         );
  40.     }
  41. }