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. }