vendor/shopware/storefront/Theme/Subscriber/UpdateSubscriber.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Storefront\Theme\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  8. use Shopware\Core\Framework\Plugin\PluginLifecycleService;
  9. use Shopware\Core\Framework\Update\Event\UpdatePostFinishEvent;
  10. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  11. use Shopware\Storefront\Theme\ThemeCollection;
  12. use Shopware\Storefront\Theme\ThemeLifecycleService;
  13. use Shopware\Storefront\Theme\ThemeService;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. /**
  17.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  18.  */
  19. class UpdateSubscriber implements EventSubscriberInterface
  20. {
  21.     private ThemeService $themeService;
  23.     private ThemeLifecycleService $themeLifecycleService;
  25.     private EntityRepositoryInterface $salesChannelRepository;
  27.     /**
  28.      * @internal
  29.      */
  30.     public function __construct(
  31.         ThemeService $themeService,
  32.         ThemeLifecycleService $themeLifecycleService,
  33.         EntityRepositoryInterface $salesChannelRepository
  34.     ) {
  35.         $this->themeService = $themeService;
  36.         $this->themeLifecycleService = $themeLifecycleService;
  37.         $this->salesChannelRepository = $salesChannelRepository;
  38.     }
  40.     /**
  41.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  42.      */
  43.     public static function getSubscribedEvents()
  44.     {
  45.         return [
  46.             UpdatePostFinishEvent::class => 'updateFinished',
  47.         ];
  48.     }
  50.     /**
  51.      * @internal
  52.      */
  53.     public function updateFinished(UpdatePostFinishEvent $event): void
  54.     {
  55.         $context = $event->getContext();
  56.         $this->themeLifecycleService->refreshThemes($context);
  58.         if ($context->hasState(PluginLifecycleService::STATE_SKIP_ASSET_BUILDING)) {
  59.             return;
  60.         }
  62.         $criteria = new Criteria();
  63.         $criteria->addFilter(new EqualsFilter('active', true));
  64.         $criteria->getAssociation('themes')
  65.             ->addFilter(new EqualsFilter('active', true));
  67.         $alreadyCompiled = [];
  68.         /** @var SalesChannelEntity $salesChannel */
  69.         foreach ($this->salesChannelRepository->search($criteria, $context) as $salesChannel) {
  70.             $themes = $salesChannel->getExtension('themes');
  71.             if (!$themes instanceof ThemeCollection) {
  72.                 continue;
  73.             }
  75.             foreach ($themes as $theme) {
  76.                 // NEXT-21735 - his is covered randomly
  77.                 // @codeCoverageIgnoreStart
  78.                 if (\in_array($theme->getId(), $alreadyCompiled, true) !== false) {
  79.                     continue;
  80.                 }
  81.                 // @codeCoverageIgnoreEnd
  83.                 $alreadyCompiled += $this->themeService->compileThemeById($theme->getId(), $context);
  84.             }
  85.         }
  86.     }
  87. }