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

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.     /**
  18.      * @internal
  19.      */
  20.     public function __construct(IndexerQueuer $indexerQueuer, EntityIndexerRegistry $indexerRegistry)
  21.     {
  22.         $this->indexerQueuer = $indexerQueuer;
  23.         $this->indexerRegistry = $indexerRegistry;
  24.     }
  26.     /**
  27.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  28.      */
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             UpdatePreFinishEvent::class => 'runRegisteredIndexers',
  33.             FirstRunWizardFinishedEvent::class => 'runRegisteredIndexers',
  34.         ];
  35.     }
  37.     /**
  38.      * @internal
  39.      */
  40.     public function runRegisteredIndexers(): void
  41.     {
  42.         $queuedIndexers = $this->indexerQueuer->getIndexers();
  44.         if (empty($queuedIndexers)) {
  45.             return;
  46.         }
  48.         $this->indexerQueuer->finishIndexer(array_keys($queuedIndexers));
  50.         foreach ($queuedIndexers as $indexerName => $options) {
  51.             $indexer = $this->indexerRegistry->getIndexer($indexerName);
  53.             if ($indexer === null) {
  54.                 continue;
  55.             }
  57.             // If we don't have any required indexer, schedule all
  58.             if ($options === []) {
  59.                 $this->indexerRegistry->sendIndexingMessage([$indexerName]);
  61.                 continue;
  62.             }
  64.             $skipList = array_values(array_diff($indexer->getOptions(), $options));
  66.             $this->indexerRegistry->sendIndexingMessage([$indexerName], $skipList);
  67.         }
  68.     }
  69. }