custom/plugins/SwkwebProductSet/src/Core/Content/ProductSet/Validation/ChangeSetValidator.php line 35

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swkweb\ProductSet\Core\Content\ProductSet\Validation;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\ChangeSetAware;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\InsertCommand;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\UpdateCommand;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\WriteCommand;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PostWriteValidationEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  11. use Shopware\Core\Framework\Validation\WriteConstraintViolationException;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\Validator\ConstraintViolation;
  14. use Symfony\Component\Validator\ConstraintViolationList;
  16. abstract class ChangeSetValidator implements EventSubscriberInterface
  17. {
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return [
  21.             PreWriteValidationEvent::class => 'preValidate',
  22.             PostWriteValidationEvent::class => 'postValidate',
  23.         ];
  24.     }
  26.     public function preValidate(PreWriteValidationEvent $event): void
  27.     {
  28.         foreach ($this->filterCommands($event->getCommands()) as $command) {
  29.             if ($command instanceof ChangeSetAware) {
  30.                 $command->requestChangeSet();
  31.             }
  32.         }
  33.     }
  35.     public function postValidate(PostWriteValidationEvent $event): void
  36.     {
  37.         foreach ($this->filterCommands($event->getCommands()) as $command) {
  38.             $violations = new ConstraintViolationList();
  39.             $this->validate($command, $violations);
  41.             if ($violations->count()) {
  42.                 $event->getExceptions()->add(
  43.                     new WriteConstraintViolationException($violations, $command->getPath())
  44.                 );
  45.             }
  46.         }
  47.     }
  49.     protected function isChanged(WriteCommand $command, string $field): bool
  50.     {
  51.         return isset($command->getPayload()[$field]);
  52.     }
  54.     /**
  55.      * @return array<string,mixed>|string|mixed|null
  56.      */
  57.     protected function getValue(WriteCommand $command, string $field)
  58.     {
  59.         if ($command instanceof ChangeSetAware) {
  60.             $changeSet = $command->getChangeSet();
  62.             if ($changeSet) {
  63.                 return $changeSet->getAfter($field) ?? $changeSet->getBefore($field);
  64.             }
  65.         }
  67.         return $command->getPayload()[$field] ?? null;
  68.     }
  70.     protected function getValueInt(WriteCommand $command, string $field): int
  71.     {
  72.         $value = $this->getValue($command, $field);
  74.         assert(is_numeric($value));
  76.         return (int) $value;
  77.     }
  79.     /**
  80.      * @param array<string,mixed> $parameters
  81.      * @param mixed $invalidValue
  82.      */
  83.     protected function buildViolation(string $template, array $parameters, string $path, $invalidValue, string $code): ConstraintViolation
  84.     {
  85.         return new ConstraintViolation(strtr($template, $parameters), $template, $parameters, null, $path, $invalidValue, null, $code);
  86.     }
  88.     /**
  89.      * @param WriteCommand[] $commands
  90.      *
  91.      * @return WriteCommand[]
  92.      */
  93.     private function filterCommands(array $commands): array
  94.     {
  95.         return array_filter($commands, function ($command) {
  96.             if (!($command instanceof InsertCommand || $command instanceof UpdateCommand)) {
  97.                 return false;
  98.             }
  100.             if ($command->getDefinition()->getClass() !== $this->getDefinitionClass()) {
  101.                 return false;
  102.             }
  104.             foreach ($this->getFields() as $field) {
  105.                 if ($this->isChanged($command, $field)) {
  106.                     return true;
  107.                 }
  108.             }
  110.             return false;
  111.         });
  112.     }
  114.     abstract protected function getDefinitionClass(): string;
  116.     /**
  117.      * @return string[]
  118.      */
  119.     abstract protected function getFields(): array;
  121.     abstract protected function validate(WriteCommand $command, ConstraintViolationList $violations): void;
  122. }