vendor/shopware/core/Content/Category/Validation/EntryPointValidator.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace Shopware\Core\Content\Category\Validation;
  10. use Doctrine\DBAL\Connection;
  11. use Doctrine\DBAL\Driver\ResultStatement;
  12. use Shopware\Core\Content\Category\CategoryDefinition;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\InsertCommand;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\UpdateCommand;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\WriteCommand;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PostWriteValidationEvent;
  17. use Shopware\Core\Framework\Validation\WriteConstraintViolationException;
  18. use Shopware\Core\System\SalesChannel\SalesChannelDefinition;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\Validator\ConstraintViolation;
  21. use Symfony\Component\Validator\ConstraintViolationList;
  22. use Symfony\Component\Validator\ConstraintViolationListInterface;
  24. class EntryPointValidator implements EventSubscriberInterface
  25. {
  26.     private const ERROR_CODE = 'CONTENT__INVALID_CATEGORY_TYPE_AS_ENTRY_POINT';
  28.     private const ALLOWED_TYPE_CHANGE = [
  29.         CategoryDefinition::TYPE_PAGE,
  30.         CategoryDefinition::TYPE_FOLDER,
  31.     ];
  33.     /**
  34.      * @var Connection
  35.      */
  36.     private $connection;
  38.     /**
  39.      * @internal
  40.      */
  41.     public function __construct(Connection $connection)
  42.     {
  43.         $this->connection = $connection;
  44.     }
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             PostWriteValidationEvent::class => 'postValidate',
  50.         ];
  51.     }
  53.     public function postValidate(PostWriteValidationEvent $event): void
  54.     {
  55.         $violationList = new ConstraintViolationList();
  56.         foreach ($event->getCommands() as $command) {
  57.             if (!($command instanceof InsertCommand || $command instanceof UpdateCommand)) {
  58.                 continue;
  59.             }
  61.             if ($command->getDefinition()->getClass() !== CategoryDefinition::class) {
  62.                 continue;
  63.             }
  65.             if (!isset($command->getPayload()['type'])) {
  66.                 continue;
  67.             }
  69.             $violationList->addAll($this->checkTypeChange($command, $event));
  70.         }
  72.         if ($violationList->count() > 0) {
  73.             $event->getExceptions()->add(new WriteConstraintViolationException($violationList));
  75.             return;
  76.         }
  77.     }
  79.     private function checkTypeChange(WriteCommand $command, PostWriteValidationEvent $event): ConstraintViolationListInterface
  80.     {
  81.         $violationList = new ConstraintViolationList();
  82.         $payload = $command->getPayload();
  84.         if (\in_array($payload['type'], self::ALLOWED_TYPE_CHANGE, true)) {
  85.             return $violationList;
  86.         }
  88.         if ($this->isCategoryEntryPoint($command->getPrimaryKey()['id'], $event)) {
  89.             return $violationList;
  90.         }
  92.         $messageTemplate = 'The type can not be assigned while category is entry point.';
  93.         $parameters = ['{{ value }}' => $payload['type']];
  95.         $violationList->add(new ConstraintViolation(
  96.             str_replace(array_keys($parameters), $parameters, $messageTemplate),
  97.             $messageTemplate,
  98.             $parameters,
  99.             null,
  100.             sprintf('%s/type', $command->getPath()),
  101.             $payload['type'],
  102.             null,
  103.             self::ERROR_CODE
  104.         ));
  106.         return $violationList;
  107.     }
  109.     private function isCategoryEntryPoint(string $categoryId, PostWriteValidationEvent $event): bool
  110.     {
  111.         foreach ($event->getCommands() as $salesChannelCommand) {
  112.             if ($salesChannelCommand->getDefinition()->getClass() !== SalesChannelDefinition::class) {
  113.                 continue;
  114.             }
  116.             $payload = $salesChannelCommand->getPayload();
  117.             if ((isset($payload['navigation_category_id']) && $payload['navigation_category_id'] === $categoryId)
  118.                 || (isset($payload['footer_category_id']) && $payload['footer_category_id'] === $categoryId)
  119.                 || (isset($payload['service_category_id']) && $payload['service_category_id'] === $categoryId)
  120.             ) {
  121.                 return false;
  122.             }
  123.         }
  125.         $query = $this->connection->createQueryBuilder()
  126.             ->select('id')
  127.             ->from(SalesChannelDefinition::ENTITY_NAME)
  128.             ->where('navigation_category_id = :navigation_id')
  129.             ->orWhere('footer_category_id = :footer_id')
  130.             ->orWhere('service_category_id = :service_id')
  131.             ->setParameter('navigation_id', $categoryId)
  132.             ->setParameter('footer_id', $categoryId)
  133.             ->setParameter('service_id', $categoryId)
  134.             ->setMaxResults(1)
  135.             ->execute();
  137.         if (!($query instanceof ResultStatement)) {
  138.             return true;
  139.         }
  141.         return !(bool) $query->fetchColumn();
  142.     }
  143. }