Replace Serializer by SerializeInterface (#25)

src/Bundle/Command/AbstractImportCommand.php

@@ -27,7 +27,7 @@
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
 use Symfony\Component\Console\Style\SymfonyStyle;
-use Symfony\Component\Serializer\Serializer;
+use Symfony\Component\Serializer\SerializerInterface;
 
 abstract class AbstractImportCommand extends Command
 {
@@ -37,7 +37,7 @@ abstract class AbstractImportCommand extends Command
 
     abstract protected function handleItem(): callable;
 
-    abstract protected function getReader(?string $filename = null): ReaderInterface;
+    abstract protected function getReader(string $filename = null): ReaderInterface;
 
     protected function configure(): void
     {
@@ -105,7 +105,7 @@ protected function getArchiver(): ?ArchiverInterface
         return null;
     }
 
-    protected function getSerializer(): ?Serializer
+    protected function getSerializer(): ?SerializerInterface
     {
         return null;
     }

src/Bundle/Processor/CliProcessor.php

@@ -21,8 +21,10 @@
 use Symfony\Component\Console\Output\OutputInterface;
 use Symfony\Component\Console\Style\SymfonyStyle;
 use Symfony\Component\Serializer\NameConverter\CamelCaseToSnakeCaseNameConverter;
+use Symfony\Component\Serializer\Normalizer\NormalizableInterface;
 use Symfony\Component\Serializer\Normalizer\ObjectNormalizer;
 use Symfony\Component\Serializer\Serializer;
+use Symfony\Component\Serializer\SerializerInterface;
 
 class CliProcessor implements BatchProcessorInterface
 {
@@ -45,7 +47,7 @@ public function __construct(
         private readonly \Closure $handleItem,
         private readonly \Closure $handleBatch,
         private readonly \Closure $handleEnd,
-        private ?Serializer $serializer = null,
+        private ?SerializerInterface $serializer = null,
     ) {
         $this->serializer = $serializer ?? new Serializer([new ObjectNormalizer(null, new CamelCaseToSnakeCaseNameConverter())]);
 
@@ -144,7 +146,9 @@ private function formatDataToDebug(mixed $data): array
         if (\is_object($data)) {
             $this->serializer ??= new Serializer([new ObjectNormalizer(null, new CamelCaseToSnakeCaseNameConverter())]);
 
-            $data = $this->serializer->normalize($data);
+            if ($this->serializer instanceof NormalizableInterface) {
+                $data = $this->serializer->normalize($data);
+            }
         }
 
         $result = [];

src/DataImporter.php

@@ -25,16 +25,17 @@
 use Symfony\Component\Serializer\NameConverter\CamelCaseToSnakeCaseNameConverter;
 use Symfony\Component\Serializer\Normalizer\ObjectNormalizer;
 use Symfony\Component\Serializer\Serializer;
+use Symfony\Component\Serializer\SerializerInterface;
 
 class DataImporter
 {
-    private readonly Serializer $serializer;
+    private readonly SerializerInterface $serializer;
 
     public function __construct(
         private readonly ReaderInterface $reader,
         private readonly ProcessorInterface $processor,
         private readonly ?ArchiverInterface $archiver = null,
-        ?Serializer $serializer = null,
+        SerializerInterface $serializer = null,
         private readonly ?MessageBusInterface $bus = null,
     ) {
         $this->serializer = $serializer ?? new Serializer([new ObjectNormalizer(null, new CamelCaseToSnakeCaseNameConverter())]);
@@ -76,7 +77,10 @@ public function execute(): void
     private function serializeData(array $data): mixed
     {
         try {
-            return $this->serializer->denormalize($data, $this->reader->getDto());
+            /** @var Serializer $serializer */
+            $serializer = $this->serializer;
+
+            return $serializer->denormalize($data, $this->reader->getDto());
         } catch (\Exception $exception) {
             throw new \InvalidArgumentException('An error occurred while denormalizing data: '.$exception->getMessage(), $exception->getCode(), $exception);
         }

src/Exchange/MessageFactory.php

@@ -20,7 +20,7 @@ final class MessageFactory
     public static function create(
         ReaderInterface $reader,
         mixed $data = null,
-        ?string $archiveFilePath = null,
+        string $archiveFilePath = null,
     ): Message {
         return new Message(
             $reader->getFile()->getFilename(),

tests/fixtures/Command/BookImportCommand.php

@@ -28,7 +28,7 @@ protected function handleItem(): callable
         };
     }
 
-    protected function getReader(?string $filename = null): ReaderInterface
+    protected function getReader(string $filename = null): ReaderInterface
     {
         return new CsvReader($filename, null, [CsvReader::CONTEXT_DELIMITER => ';']);
     }