custom/plugins/SwagLanguagePack/src/Core/Framework/DataAbstractionLayer/Write/Validation/AbstractLanguageValidator.php line 44

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 Swag\LanguagePack\Core\Framework\DataAbstractionLayer\Write\Validation;
  10. use Doctrine\DBAL\Connection;
  11. use Doctrine\DBAL\Driver\ResultStatement;
  12. use Doctrine\DBAL\FetchMode;
  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\Uuid\Uuid;
  18. use Shopware\Core\Framework\Validation\WriteConstraintViolationException;
  19. use Shopware\Core\System\Language\LanguageDefinition;
  20. use Swag\LanguagePack\PackLanguage\PackLanguageDefinition;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use Symfony\Component\Validator\ConstraintViolation;
  23. use Symfony\Component\Validator\ConstraintViolationList;
  25. abstract class AbstractLanguageValidator implements EventSubscriberInterface
  26. {
  27.     /**
  28.      * @var Connection
  29.      */
  30.     protected $connection;
  32.     public function __construct(Connection $connection)
  33.     {
  34.         $this->connection = $connection;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             PostWriteValidationEvent::class => 'postValidate',
  41.         ];
  42.     }
  44.     public function postValidate(PostWriteValidationEvent $event): void
  45.     {
  46.         $violationList = new ConstraintViolationList();
  47.         foreach ($event->getCommands() as $command) {
  48.             if (!($command instanceof InsertCommand || $command instanceof UpdateCommand)
  49.                 || $command->getDefinition()->getClass() !== $this->getSupportedCommandDefinitionClass()
  50.             ) {
  51.                 continue;
  52.             }
  54.             $this->validate($command, $violationList);
  55.         }
  57.         if ($violationList->count() > 0) {
  58.             $event->getExceptions()->add(new WriteConstraintViolationException($violationList));
  59.         }
  60.     }
  62.     abstract protected function getSupportedCommandDefinitionClass(): string;
  64.     protected function validate(WriteCommand $command, ConstraintViolationList $violationList): void
  65.     {
  66.         $payload = $command->getPayload();
  67.         if (!isset($payload['language_id'])) {
  68.             return;
  69.         }
  71.         $languageId = $payload['language_id'];
  72.         if (!$this->isLanguageManagedByLanguagePack($languageId) || $this->isSalesChannelLanguageAvailable($languageId)) {
  73.             return;
  74.         }
  76.         $violationList->add(
  77.             new ConstraintViolation(
  78.                 \sprintf('The language with the id "%s" is disabled for all Sales Channels.', Uuid::fromBytesToHex($languageId)),
  79.                 'The language with the id "{{ languageId }}" is disabled for all Sales Channels.',
  80.                 [$languageId],
  81.                 null,
  82.                 $command->getPath(),
  83.                 $languageId
  84.             )
  85.         );
  86.     }
  88.     protected function isSalesChannelLanguageAvailable(string $languageId): bool
  89.     {
  90.         $statement = $this->connection->createQueryBuilder()
  91.             ->select('sales_channel_active')
  92.             ->from(PackLanguageDefinition::ENTITY_NAME)
  93.             ->where('language_id = :languageId')
  94.             ->setParameter('languageId', $languageId)
  95.             ->setMaxResults(1)
  96.             ->execute();
  98.         if (!$statement instanceof ResultStatement) {
  99.             return false;
  100.         }
  102.         return (bool) $statement->fetch(FetchMode::COLUMN);
  103.     }
  105.     protected function isLanguageManagedByLanguagePack(string $languageId): bool
  106.     {
  107.         $statement = $this->connection->createQueryBuilder()
  108.             ->select('swag_language_pack_language_id')
  109.             ->from(LanguageDefinition::ENTITY_NAME)
  110.             ->where('id = :languageId')
  111.             ->setParameter('languageId', $languageId)
  112.             ->setMaxResults(1)
  113.             ->execute();
  115.         if (!$statement instanceof ResultStatement) {
  116.             return false;
  117.         }
  119.         return (bool) $statement->fetch(FetchMode::COLUMN);
  120.     }
  121. }