vendor/shopware/core/Content/Flow/Indexing/FlowIndexer.php line 79

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\App\Event\AppActivatedEvent;
  8. use Shopware\Core\Framework\App\Event\AppDeactivatedEvent;
  9. use Shopware\Core\Framework\App\Event\AppDeletedEvent;
  10. use Shopware\Core\Framework\App\Event\AppInstalledEvent;
  11. use Shopware\Core\Framework\App\Event\AppUpdatedEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common\IteratorFactory;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexer;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexingMessage;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\MessageQueue\IterateEntityIndexerMessage;
  18. use Shopware\Core\Framework\Feature;
  19. use Shopware\Core\Framework\Plugin\Event\PluginPostActivateEvent;
  20. use Shopware\Core\Framework\Plugin\Event\PluginPostDeactivateEvent;
  21. use Shopware\Core\Framework\Plugin\Event\PluginPostInstallEvent;
  22. use Shopware\Core\Framework\Plugin\Event\PluginPostUninstallEvent;
  23. use Shopware\Core\Framework\Plugin\Event\PluginPostUpdateEvent;
  24. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\Messenger\MessageBusInterface;
  27. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  29. class FlowIndexer extends EntityIndexer implements EventSubscriberInterface
  30. {
  31.     private IteratorFactory $iteratorFactory;
  33.     private EntityRepositoryInterface $repository;
  35.     private FlowPayloadUpdater $payloadUpdater;
  37.     private EventDispatcherInterface $eventDispatcher;
  39.     private MessageBusInterface $messageBus;
  41.     /**
  42.      * @internal
  43.      */
  44.     public function __construct(
  45.         IteratorFactory $iteratorFactory,
  46.         EntityRepositoryInterface $repository,
  47.         FlowPayloadUpdater $payloadUpdater,
  48.         EventDispatcherInterface $eventDispatcher,
  49.         MessageBusInterface $messageBus
  50.     ) {
  51.         $this->iteratorFactory = $iteratorFactory;
  52.         $this->repository = $repository;
  53.         $this->payloadUpdater = $payloadUpdater;
  54.         $this->eventDispatcher = $eventDispatcher;
  55.         $this->messageBus = $messageBus;
  56.     }
  58.     public function getName(): string
  59.     {
  60.         return 'flow.indexer';
  61.     }
  63.     public static function getSubscribedEvents(): array
  64.     {
  65.         return [
  66.             PluginPostInstallEvent::class => 'refreshPlugin',
  67.             PluginPostActivateEvent::class => 'refreshPlugin',
  68.             PluginPostUpdateEvent::class => 'refreshPlugin',
  69.             PluginPostDeactivateEvent::class => 'refreshPlugin',
  70.             PluginPostUninstallEvent::class => 'refreshPlugin',
  71.             AppInstalledEvent::class => 'refreshPlugin',
  72.             AppUpdatedEvent::class => 'refreshPlugin',
  73.             AppActivatedEvent::class => 'refreshPlugin',
  74.             AppDeletedEvent::class => 'refreshPlugin',
  75.             AppDeactivatedEvent::class => 'refreshPlugin',
  76.         ];
  77.     }
  79.     public function refreshPlugin(): void
  80.     {
  81.         // Schedule indexer to update flows
  82.         $this->messageBus->dispatch(new IterateEntityIndexerMessage($this->getName(), null));
  83.     }
  85.     /**
  86.      * @param array|null $offset
  87.      *
  88.      * @deprecated tag:v6.5.0 The parameter $offset will be native typed
  89.      */
  90.     public function iterate(/*?array */$offset): ?EntityIndexingMessage
  91.     {
  92.         if ($offset !== null && !\is_array($offset)) {
  93.             Feature::triggerDeprecationOrThrow(
  94.                 'v6.5.0.0',
  95.                 'Parameter `$offset` of method "iterate()" in class "FlowIndexer" will be natively typed to `?array` in v6.5.0.0.'
  96.             );
  97.         }
  99.         $iterator = $this->iteratorFactory->createIterator($this->repository->getDefinition(), $offset);
  101.         $ids = $iterator->fetch();
  103.         if (empty($ids)) {
  104.             return null;
  105.         }
  107.         return new FlowIndexingMessage(array_values($ids), $iterator->getOffset());
  108.     }
  110.     public function update(EntityWrittenContainerEvent $event): ?EntityIndexingMessage
  111.     {
  112.         $updates = $event->getPrimaryKeys(FlowDefinition::ENTITY_NAME);
  114.         if (empty($updates)) {
  115.             return null;
  116.         }
  118.         $this->handle(new FlowIndexingMessage(array_values($updates), null, $event->getContext()));
  120.         return null;
  121.     }
  123.     public function handle(EntityIndexingMessage $message): void
  124.     {
  125.         $ids = array_unique(array_filter($message->getData()));
  127.         if (empty($ids)) {
  128.             return;
  129.         }
  131.         $this->payloadUpdater->update($ids);
  133.         $this->eventDispatcher->dispatch(new FlowIndexerEvent($ids, $message->getContext()));
  134.     }
  136.     public function getTotal(): int
  137.     {
  138.         return $this->iteratorFactory->createIterator($this->repository->getDefinition())->fetchCount();
  139.     }
  141.     public function getDecorated(): EntityIndexer
  142.     {
  143.         throw new DecorationPatternException(static::class);
  144.     }
  145. }