platform/src/Core/Content/Flow/Indexing/FlowIndexer.php line 64

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Indexing;
  5. use Shopware\Core\Content\Flow\Events\FlowIndexerEvent;
  6. use Shopware\Core\Content\Flow\FlowDefinition;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common\IteratorFactory;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexer;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexingMessage;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\MessageQueue\IterateEntityIndexerMessage;
  13. use Shopware\Core\Framework\Plugin\Event\PluginPostActivateEvent;
  14. use Shopware\Core\Framework\Plugin\Event\PluginPostDeactivateEvent;
  15. use Shopware\Core\Framework\Plugin\Event\PluginPostInstallEvent;
  16. use Shopware\Core\Framework\Plugin\Event\PluginPostUninstallEvent;
  17. use Shopware\Core\Framework\Plugin\Event\PluginPostUpdateEvent;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Messenger\MessageBusInterface;
  20. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  22. class FlowIndexer extends EntityIndexer implements EventSubscriberInterface
  23. {
  24.     private IteratorFactory $iteratorFactory;
  26.     private EntityRepositoryInterface $repository;
  28.     private FlowPayloadUpdater $payloadUpdater;
  30.     private EventDispatcherInterface $eventDispatcher;
  32.     private MessageBusInterface $messageBus;
  34.     public function __construct(
  35.         IteratorFactory $iteratorFactory,
  36.         EntityRepositoryInterface $repository,
  37.         FlowPayloadUpdater $payloadUpdater,
  38.         EventDispatcherInterface $eventDispatcher,
  39.         MessageBusInterface $messageBus
  40.     ) {
  41.         $this->iteratorFactory = $iteratorFactory;
  42.         $this->repository = $repository;
  43.         $this->payloadUpdater = $payloadUpdater;
  44.         $this->eventDispatcher = $eventDispatcher;
  45.         $this->messageBus = $messageBus;
  46.     }
  48.     public function getName(): string
  49.     {
  50.         return 'flow.indexer';
  51.     }
  53.     public static function getSubscribedEvents(): array
  54.     {
  55.         return [
  56.             PluginPostInstallEvent::class => 'refreshPlugin',
  57.             PluginPostActivateEvent::class => 'refreshPlugin',
  58.             PluginPostUpdateEvent::class => 'refreshPlugin',
  59.             PluginPostDeactivateEvent::class => 'refreshPlugin',
  60.             PluginPostUninstallEvent::class => 'refreshPlugin',
  61.         ];
  62.     }
  64.     public function refreshPlugin(): void
  65.     {
  66.         // Schedule indexer to update flows
  67.         $this->messageBus->dispatch(new IterateEntityIndexerMessage($this->getName(), null));
  68.     }
  70.     /**
  71.      * @param array|null $offset
  72.      *
  73.      * @deprecated tag:v6.5.0 The parameter $offset will be native typed
  74.      */
  75.     public function iterate(/*?array */$offset): ?EntityIndexingMessage
  76.     {
  77.         $iterator = $this->iteratorFactory->createIterator($this->repository->getDefinition(), $offset);
  79.         $ids = $iterator->fetch();
  81.         if (empty($ids)) {
  82.             return null;
  83.         }
  85.         return new FlowIndexingMessage(array_values($ids), $iterator->getOffset());
  86.     }
  88.     public function update(EntityWrittenContainerEvent $event): ?EntityIndexingMessage
  89.     {
  90.         $updates = $event->getPrimaryKeys(FlowDefinition::ENTITY_NAME);
  92.         if (empty($updates)) {
  93.             return null;
  94.         }
  96.         $this->handle(new FlowIndexingMessage(array_values($updates), null, $event->getContext()));
  98.         return null;
  99.     }
  101.     public function handle(EntityIndexingMessage $message): void
  102.     {
  103.         $ids = array_unique(array_filter($message->getData()));
  105.         if (empty($ids)) {
  106.             return;
  107.         }
  109.         $this->payloadUpdater->update($ids);
  111.         $this->eventDispatcher->dispatch(new FlowIndexerEvent($ids, $message->getContext()));
  112.     }
  113. }