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

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. /**
  12.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  13.  */
  14. class RegisteredIndexerSubscriber implements EventSubscriberInterface
  15. {
  16.     private IndexerQueuer $indexerQueuer;
  18.     private EntityIndexerRegistry $indexerRegistry;
  20.     /**
  21.      * @internal
  22.      */
  23.     public function __construct(IndexerQueuer $indexerQueuer, EntityIndexerRegistry $indexerRegistry)
  24.     {
  25.         $this->indexerQueuer = $indexerQueuer;
  26.         $this->indexerRegistry = $indexerRegistry;
  27.     }
  29.     /**
  30.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  31.      */
  32.     public static function getSubscribedEvents()
  33.     {
  34.         return [
  35.             UpdatePreFinishEvent::class => 'runRegisteredIndexers',
  36.             FirstRunWizardFinishedEvent::class => 'runRegisteredIndexers',
  37.         ];
  38.     }
  40.     /**
  41.      * @internal
  42.      */
  43.     public function runRegisteredIndexers(): void
  44.     {
  45.         $queuedIndexers = $this->indexerQueuer->getIndexers();
  47.         if (empty($queuedIndexers)) {
  48.             return;
  49.         }
  51.         $this->indexerQueuer->finishIndexer(array_keys($queuedIndexers));
  53.         foreach ($queuedIndexers as $indexerName => $options) {
  54.             $indexer = $this->indexerRegistry->getIndexer($indexerName);
  56.             if ($indexer === null) {
  57.                 continue;
  58.             }
  60.             // If we don't have any required indexer, schedule all
  61.             if ($options === []) {
  62.                 $this->indexerRegistry->sendIndexingMessage([$indexerName]);
  64.                 continue;
  65.             }
  67.             $skipList = array_values(array_diff($indexer->getOptions(), $options));
  69.             $this->indexerRegistry->sendIndexingMessage([$indexerName], $skipList);
  70.         }
  71.     }
  72. }