Add validator

Author: mpysiak

.gitignore

@@ -1,7 +1,7 @@
 /vendor/
+/var/
 /node_modules/
 /composer.lock
-/drivers/
 
 /etc/build/*
 !/etc/build/.gitignore
@@ -12,5 +12,5 @@
 /tests/TestApplication/.env.*.local
 
 /.phpunit.result.cache
-/behat.yml
+/behat.yaml
 /phpunit.xml

config/services.xml

@@ -58,6 +58,7 @@
             <argument type="service" id="sylius_import_export.denormalizer.registry" />
             <argument type="service" id="doctrine.orm.entity_manager" />
             <argument type="service" id="sylius.resource_registry" />
+            <argument type="service" id="validator" />
 
             <tag name="messenger.message_handler" bus="sylius.command_bus" />
         </service>

src/Controller/ImportAction.php

@@ -16,6 +16,7 @@
 use Sylius\ImportExport\Messenger\Command\CreateImportProcess;
 use Sylius\ImportExport\Uploader\ImportFileUploader;
 use Sylius\Resource\Metadata\RegistryInterface;
+use Symfony\Component\Form\FormError;
 use Symfony\Component\Form\FormFactoryInterface;
 use Symfony\Component\HttpFoundation\File\UploadedFile;
 use Symfony\Component\HttpFoundation\RedirectResponse;
@@ -47,7 +48,9 @@ public function __invoke(Request $request, string $grid): Response
             if ($form->isSubmitted()) {
                 $errors = [];
                 foreach ($form->getErrors(true) as $error) {
-                    $errors[] = $error->getMessage();
+                    if ($error instanceof FormError) {
+                        $errors[] = $error->getMessage();
+                    }
                 }
                 $errorMessage = !empty($errors) ? implode(', ', $errors) : 'sylius_import_export.import_form_invalid';
                 $session->getFlashBag()->add('error', $errorMessage);

src/Messenger/Handler/ImportCommandHandler.php

@@ -20,6 +20,7 @@
 use Sylius\ImportExport\Messenger\Command\ImportCommand;
 use Sylius\Resource\Doctrine\Persistence\RepositoryInterface;
 use Sylius\Resource\Metadata\RegistryInterface;
+use Symfony\Component\Validator\Validator\ValidatorInterface;
 
 class ImportCommandHandler
 {
@@ -29,6 +30,7 @@ public function __construct(
         protected DenormalizerRegistryInterface $denormalizerRegistry,
         protected EntityManagerInterface $entityManager,
         protected RegistryInterface $metadataRegistry,
+        protected ValidatorInterface $validator,
     ) {
     }
 
@@ -47,6 +49,19 @@ public function __invoke(ImportCommand $command): void
 
             foreach ($command->batchData as $recordData) {
                 $entity = $denormalizer->denormalize($recordData, $resourceClass);
+
+                $validationGroups = $process->getParameters()['validation_groups'] ?? ['Default'];
+                $violations = $this->validator->validate($entity, groups: $validationGroups);
+
+                if (count($violations) > 0) {
+                    $errorMessages = [];
+                    foreach ($violations as $violation) {
+                        $errorMessages[] = sprintf('%s: %s', $violation->getPropertyPath(), $violation->getMessage());
+                    }
+
+                    throw new ImportFailedException(sprintf('Validation failed for record: %s', implode(', ', $errorMessages)));
+                }
+
                 $this->entityManager->persist($entity);
 
                 ++$importedCount;