platform/src/Storefront/Theme/Subscriber/UpdateSubscriber.php line 52

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\Update\Event\UpdatePostFinishEvent;
  9. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  10. use Shopware\Storefront\Theme\ThemeCollection;
  11. use Shopware\Storefront\Theme\ThemeLifecycleService;
  12. use Shopware\Storefront\Theme\ThemeService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class UpdateSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var ThemeService
  19.      */
  20.     private $themeService;
  22.     /**
  23.      * @var ThemeLifecycleService
  24.      */
  25.     private $themeLifecycleService;
  27.     /**
  28.      * @var EntityRepositoryInterface
  29.      */
  30.     private $salesChannelRepository;
  32.     public function __construct(
  33.         ThemeService $themeService,
  34.         ThemeLifecycleService $themeLifecycleService,
  35.         EntityRepositoryInterface $salesChannelRepository
  36.     ) {
  37.         $this->themeService = $themeService;
  38.         $this->themeLifecycleService = $themeLifecycleService;
  39.         $this->salesChannelRepository = $salesChannelRepository;
  40.     }
  42.     public static function getSubscribedEvents()
  43.     {
  44.         return [
  45.             UpdatePostFinishEvent::class => 'updateFinished',
  46.         ];
  47.     }
  49.     /**
  50.      * @internal
  51.      */
  52.     public function updateFinished(UpdatePostFinishEvent $event): void
  53.     {
  54.         $context = $event->getContext();
  55.         $this->themeLifecycleService->refreshThemes($context);
  57.         $criteria = new Criteria();
  58.         $criteria->addFilter(new EqualsFilter('active', true));
  59.         $criteria->getAssociation('themes')
  60.             ->addFilter(new EqualsFilter('active', true));
  62.         /** @var SalesChannelEntity $salesChannel */
  63.         foreach ($this->salesChannelRepository->search($criteria, $context) as $salesChannel) {
  64.             $themes = $salesChannel->getExtension('themes');
  65.             if (!$themes instanceof ThemeCollection) {
  66.                 continue;
  67.             }
  69.             foreach ($themes as $theme) {
  70.                 $salesChannelId = $salesChannel->getId();
  71.                 $this->themeService->compileTheme($salesChannelId, $theme->getId(), $context);
  72.             }
  73.         }
  74.     }
  75. }