vendor/shopware/core/Framework/DataAbstractionLayer/Indexing/Subscriber/RegisteredIndexerSubscriber.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\DataAbstractionLayer\Indexing\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexerRegistry;
  6. use Shopware\Core\Framework\Log\Package;
  7. use Shopware\Core\Framework\Migration\IndexerQueuer;
  8. use Shopware\Core\Framework\Store\Event\FirstRunWizardFinishedEvent;
  9. use Shopware\Core\Framework\Update\Event\UpdatePreFinishEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. /**
  13.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  14.  */
  15. #[Package('core')]
  16. class RegisteredIndexerSubscriber implements EventSubscriberInterface
  17. {
  18.     private IndexerQueuer $indexerQueuer;
  20.     private EntityIndexerRegistry $indexerRegistry;
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(IndexerQueuer $indexerQueuer, EntityIndexerRegistry $indexerRegistry)
  26.     {
  27.         $this->indexerQueuer = $indexerQueuer;
  28.         $this->indexerRegistry = $indexerRegistry;
  29.     }
  31.     /**
  32.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  33.      */
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             UpdatePreFinishEvent::class => 'runRegisteredIndexers',
  38.             FirstRunWizardFinishedEvent::class => 'runRegisteredIndexers',
  39.         ];
  40.     }
  42.     /**
  43.      * @internal
  44.      */
  45.     public function runRegisteredIndexers(): void
  46.     {
  47.         $queuedIndexers = $this->indexerQueuer->getIndexers();
  49.         if (empty($queuedIndexers)) {
  50.             return;
  51.         }
  53.         $this->indexerQueuer->finishIndexer(array_keys($queuedIndexers));
  55.         foreach ($queuedIndexers as $indexerName => $options) {
  56.             $indexer = $this->indexerRegistry->getIndexer($indexerName);
  58.             if ($indexer === null) {
  59.                 continue;
  60.             }
  62.             // If we don't have any required indexer, schedule all
  63.             if ($options === []) {
  64.                 $this->indexerRegistry->sendIndexingMessage([$indexerName]);
  66.                 continue;
  67.             }
  69.             $skipList = array_values(array_diff($indexer->getOptions(), $options));
  71.             $this->indexerRegistry->sendIndexingMessage([$indexerName], $skipList);
  72.         }
  73.     }
  74. }