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

  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\UpdatePostFinishEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. /**
  13.  * @internal
  14.  */
  15. #[Package('core')]
  16. class RegisteredIndexerSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @internal
  20.      */
  21.     public function __construct(private readonly IndexerQueuer $indexerQueuer, private readonly EntityIndexerRegistry $indexerRegistry)
  22.     {
  23.     }
  25.     /**
  26.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  27.      */
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             UpdatePostFinishEvent::class => 'runRegisteredIndexers',
  32.             FirstRunWizardFinishedEvent::class => 'runRegisteredIndexers',
  33.         ];
  34.     }
  36.     /**
  37.      * @internal
  38.      */
  39.     public function runRegisteredIndexers(): void
  40.     {
  41.         $queuedIndexers = $this->indexerQueuer->getIndexers();
  43.         if (empty($queuedIndexers)) {
  44.             return;
  45.         }
  47.         $this->indexerQueuer->finishIndexer(array_keys($queuedIndexers));
  49.         foreach ($queuedIndexers as $indexerName => $options) {
  50.             $indexer = $this->indexerRegistry->getIndexer($indexerName);
  52.             if ($indexer === null) {
  53.                 continue;
  54.             }
  56.             // If we don't have any required indexer, schedule all
  57.             if ($options === []) {
  58.                 $this->indexerRegistry->sendIndexingMessage([$indexerName]);
  60.                 continue;
  61.             }
  63.             $skipList = array_values(array_diff($indexer->getOptions(), $options));
  65.             $this->indexerRegistry->sendIndexingMessage([$indexerName], $skipList);
  66.         }
  67.     }
  68. }