vendor/dvdw/events/src/Content/Product/ProductUrlValidator.php line 36

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Dvdw\Events\Content\Product;
  5. use Dvdw\Events\Content\Product\Exception\ProductUrlAlreadyExistsException;
  6. use Dvdw\Events\Content\Product\Exception\ProductUrlInvalidException;
  7. use Shopware\Core\Content\Product\Aggregate\ProductTranslation\ProductTranslationDefinition;
  8. use Shopware\Core\Defaults;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\PrefixFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  17. use Shopware\Core\Framework\Uuid\Uuid;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class ProductUrlValidator implements EventSubscriberInterface
  21. {
  22.     private EntityRepository $repo;
  24.     public function __construct(
  25.         EntityRepository $repo
  26.     )
  27.     {
  28.         $this->repo = $repo;
  29.     }
  31.     public static function getSubscribedEvents(): iterable
  32.     {
  33.         return [PreWriteValidationEvent::class => 'validate'];
  34.     }
  36.     public function validate(PreWriteValidationEvent $event): void
  37.     {
  38.         $context = $event->getContext();
  40.         if ($context->getVersionId() !== Defaults::LIVE_VERSION) {
  41.             return;
  42.         }
  44.         foreach ($event->getCommands() as $command) {
  45.             $payload = $command->getPayload();
  47.             if (!$command->getDefinition() instanceof ProductTranslationDefinition
  48.                 || ($url = $this->getUrlFromPayload($payload)) === null)
  49.             {
  50.                 continue;
  51.             }
  53.             $this->validateUrl($url, $context, Uuid::fromBytesToHexList($command->getPrimaryKey()));
  54.         }
  55.     }
  57.     private function getUrlFromPayload(array $payload): ?string
  58.     {
  59.         if (isset($payload[ProductCustomFields::WEBSITE_FIELD_NAME])) {
  60.             return $payload[ProductCustomFields::WEBSITE_FIELD_NAME];
  61.         }
  63.         if (!isset($payload['custom_fields'])) {
  64.             return null;
  65.         }
  67.         $customFields = json_decode($payload['custom_fields'], true);
  69.         return $customFields[ProductCustomFields::WEBSITE_FIELD_NAME] ?? null;
  70.     }
  72.     private function validateUrl(string $url, Context $context, array $primaryKey): void
  73.     {
  74.         $parsedUrl = parse_url($url);
  76.         if (!isset($parsedUrl['host']) || !isset($parsedUrl['scheme']) || $parsedUrl['scheme'] !== 'https') {
  77.             throw new ProductUrlInvalidException($url, $primaryKey);
  78.         }
  80.         $criteria = new Criteria();
  81.         $criteria->setLimit(1);
  82.         $criteria->addFilter(new PrefixFilter(
  83.             'customFields.' . ProductCustomFields::WEBSITE_FIELD_NAME,
  84.             'https://' . $parsedUrl['host']
  85.         ));
  87.         $languageId = $primaryKey['language_id'] ?? null;
  88.         if ($languageId !== null) {
  89.             $criteria->addFilter(new EqualsFilter('languageId', $languageId));
  90.         }
  92.         $productId = $primaryKey['product_id'] ?? null;
  93.         if ($productId !== null) {
  94.             $criteria->addFilter(new NotFilter(
  95.                 MultiFilter::CONNECTION_AND,
  96.                 [new EqualsFilter('productId', $productId)]
  97.             ));
  98.         }
  100.         if (empty($this->repo->search($criteria, $context)->getElements())) {
  101.             return;
  102.         }
  104.         throw new ProductUrlAlreadyExistsException($url, $primaryKey);
  105.     }
  106. }