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

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\Migration\IndexerQueuer;
  7. use Shopware\Core\Framework\Store\Event\FirstRunWizardFinishedEvent;
  8. use Shopware\Core\Framework\Update\Event\UpdatePreFinishEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class RegisteredIndexerSubscriber implements EventSubscriberInterface
  12. {
  13.     private IndexerQueuer $indexerQueuer;
  15.     private EntityIndexerRegistry $indexerRegistry;
  17.     public function __construct(IndexerQueuer $indexerQueuer, EntityIndexerRegistry $indexerRegistry)
  18.     {
  19.         $this->indexerQueuer = $indexerQueuer;
  20.         $this->indexerRegistry = $indexerRegistry;
  21.     }
  23.     /**
  24.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  25.      */
  26.     public static function getSubscribedEvents()
  27.     {
  28.         return [
  29.             UpdatePreFinishEvent::class => 'runRegisteredIndexers',
  30.             FirstRunWizardFinishedEvent::class => 'runRegisteredIndexers',
  31.         ];
  32.     }
  34.     /**
  35.      * @internal
  36.      */
  37.     public function runRegisteredIndexers(): void
  38.     {
  39.         $queuedIndexers = $this->indexerQueuer->getIndexers();
  41.         if (empty($queuedIndexers)) {
  42.             return;
  43.         }
  45.         $this->indexerQueuer->finishIndexer(array_keys($queuedIndexers));
  47.         foreach ($queuedIndexers as $indexerName => $options) {
  48.             $indexer = $this->indexerRegistry->getIndexer($indexerName);
  50.             if ($indexer === null) {
  51.                 continue;
  52.             }
  54.             // If we don't have any required indexer, schedule all
  55.             if ($options === []) {
  56.                 $this->indexerRegistry->sendIndexingMessage([$indexerName]);
  58.                 continue;
  59.             }
  61.             $skipList = array_values(array_diff($indexer->getOptions(), $options));
  63.             $this->indexerRegistry->sendIndexingMessage([$indexerName], $skipList);
  64.         }
  65.     }
  66. }