vendor/shopware/administration/System/SalesChannel/Subscriber/SalesChannelUserConfigSubscriber.php line 37

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Administration\System\SalesChannel\Subscriber;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\System\User\Aggregate\UserConfig\UserConfigCollection;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  15.  */
  16. class SalesChannelUserConfigSubscriber implements EventSubscriberInterface
  17. {
  18.     public const CONFIG_KEY = 'sales-channel-favorites';
  20.     private EntityRepository $userConfigRepository;
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(EntityRepository $userConfigRepository)
  26.     {
  27.         $this->userConfigRepository = $userConfigRepository;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             'sales_channel.deleted' => 'onSalesChannelDeleted',
  34.         ];
  35.     }
  37.     public function onSalesChannelDeleted(EntityDeletedEvent $deletedEvent): void
  38.     {
  39.         $context = $deletedEvent->getContext();
  41.         $deletedSalesChannelIds = $deletedEvent->getIds();
  43.         $writeUserConfigs = [];
  44.         foreach ($this->getAllFavoriteUserConfigs($context) as $userConfigEntity) {
  45.             $salesChannelIds = $userConfigEntity->getValue();
  47.             if ($salesChannelIds === null) {
  48.                 continue;
  49.             }
  51.             // Find matching IDs
  52.             $matchingIds = array_intersect($deletedSalesChannelIds, $salesChannelIds);
  54.             if (!$matchingIds) {
  55.                 continue;
  56.             }
  58.             // Removes the IDs from $matchingIds from the array
  59.             $newUserConfigArray = array_diff($salesChannelIds, $matchingIds);
  60.             $writeUserConfigs[] = [
  61.                 'id' => $userConfigEntity->getId(),
  62.                 'value' => array_values($newUserConfigArray),
  63.             ];
  64.         }
  66.         $this->userConfigRepository->upsert($writeUserConfigs, $context);
  67.     }
  69.     private function getAllFavoriteUserConfigs(Context $context): UserConfigCollection
  70.     {
  71.         $criteria = new Criteria();
  72.         $criteria->addFilter(new EqualsFilter('key', self::CONFIG_KEY));
  74.         /** @var UserConfigCollection $result */
  75.         $result = $this->userConfigRepository->search($criteria, $context)->getEntities();
  77.         return $result;
  78.     }
  79. }