src/Storefront/Theme/Subscriber/UpdateSubscriber.php line 43

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Storefront\Theme\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  8. use Shopware\Core\Framework\Log\Package;
  9. use Shopware\Core\Framework\Plugin\PluginLifecycleService;
  10. use Shopware\Core\Framework\Update\Event\UpdatePostFinishEvent;
  11. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  12. use Shopware\Storefront\Theme\ThemeCollection;
  13. use Shopware\Storefront\Theme\ThemeLifecycleService;
  14. use Shopware\Storefront\Theme\ThemeService;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. /**
  18.  * @internal
  19.  */
  20. #[Package('storefront')]
  21. class UpdateSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @internal
  25.      */
  26.     public function __construct(private readonly ThemeService $themeService, private readonly ThemeLifecycleService $themeLifecycleService, private readonly EntityRepository $salesChannelRepository)
  27.     {
  28.     }
  30.     /**
  31.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  32.      */
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             UpdatePostFinishEvent::class => 'updateFinished',
  37.         ];
  38.     }
  40.     /**
  41.      * @internal
  42.      */
  43.     public function updateFinished(UpdatePostFinishEvent $event): void
  44.     {
  45.         $context = $event->getContext();
  46.         $this->themeLifecycleService->refreshThemes($context);
  48.         if ($context->hasState(PluginLifecycleService::STATE_SKIP_ASSET_BUILDING)) {
  49.             return;
  50.         }
  52.         $criteria = new Criteria();
  53.         $criteria->addFilter(new EqualsFilter('active', true));
  54.         $criteria->getAssociation('themes')
  55.             ->addFilter(new EqualsFilter('active', true));
  57.         $alreadyCompiled = [];
  58.         /** @var SalesChannelEntity $salesChannel */
  59.         foreach ($this->salesChannelRepository->search($criteria, $context) as $salesChannel) {
  60.             $themes = $salesChannel->getExtension('themes');
  61.             if (!$themes instanceof ThemeCollection) {
  62.                 continue;
  63.             }
  65.             foreach ($themes as $theme) {
  66.                 // NEXT-21735 - his is covered randomly
  67.                 // @codeCoverageIgnoreStart
  68.                 if (\in_array($theme->getId(), $alreadyCompiled, true) !== false) {
  69.                     continue;
  70.                 }
  71.                 // @codeCoverageIgnoreEnd
  73.                 $alreadyCompiled += $this->themeService->compileThemeById($theme->getId(), $context);
  74.             }
  75.         }
  76.     }
  77. }