custom/plugins/SwagSocialShopping/src/EventListener/ProductStreamEventListener.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  *
  5.  * For the full copyright and license information, please view the LICENSE
  6.  * file that was distributed with this source code.
  7.  */
  9. namespace SwagSocialShopping\EventListener;
  11. use Shopware\Core\Content\ProductStream\ProductStreamDefinition;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  18. use Shopware\Core\Framework\Uuid\Uuid;
  19. use Shopware\Core\Framework\Validation\WriteConstraintViolationException;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\Validator\ConstraintViolation;
  22. use Symfony\Component\Validator\ConstraintViolationInterface;
  23. use Symfony\Component\Validator\ConstraintViolationList;
  25. class ProductStreamEventListener implements EventSubscriberInterface
  26. {
  27.     private EntityRepositoryInterface $socialShoppingRepository;
  29.     public function __construct(EntityRepositoryInterface $socialShoppingRepository)
  30.     {
  31.         $this->socialShoppingRepository = $socialShoppingRepository;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             PreWriteValidationEvent::class => 'preValidate',
  38.         ];
  39.     }
  41.     public function preValidate(PreWriteValidationEvent $event): void
  42.     {
  43.         $violations = new ConstraintViolationList();
  45.         foreach ($event->getCommands() as $command) {
  46.             if (!($command instanceof DeleteCommand) || $command->getDefinition()->getClass() !== ProductStreamDefinition::class) {
  47.                 continue;
  48.             }
  50.             $byteId = $command->getPrimaryKey()['id'];
  51.             $hexId = \mb_strtolower(Uuid::fromBytesToHex($byteId));
  53.             if (!$this->isProductStreamUsedBySocialShopping($hexId, $event->getContext())) {
  54.                 continue;
  55.             }
  57.             $violations->add(
  58.                 $this->buildViolation(
  59.                     'The product stream {{ id }} is used by one or more social shopping sales channels.',
  60.                     ['{{ id }}' => $hexId]
  61.                 )
  62.             );
  63.         }
  65.         if ($violations->count() > 0) {
  66.             $event->getExceptions()->add(new WriteConstraintViolationException($violations));
  67.         }
  68.     }
  70.     private function isProductStreamUsedBySocialShopping(string $productStreamId, Context $context): bool
  71.     {
  72.         $criteria = new Criteria();
  73.         $criteria->addFilter(new EqualsFilter('productStreamId', $productStreamId));
  74.         $criteria->setTotalCountMode(Criteria::TOTAL_COUNT_MODE_EXACT);
  76.         return $this->socialShoppingRepository->searchIds($criteria, $context)->getTotal() > 0;
  77.     }
  79.     private function buildViolation(string $messageTemplate, array $parameters): ConstraintViolationInterface
  80.     {
  81.         return new ConstraintViolation(
  82.             \str_replace(\array_keys($parameters), \array_values($parameters), $messageTemplate),
  83.             $messageTemplate,
  84.             $parameters,
  85.             null,
  86.             null,
  87.             null
  88.         );
  89.     }
  90. }