* Add possibility to save exceptions in file

Author: AUDUL

src/Command/JobShowCommand.php

@@ -7,7 +7,6 @@
 use CodeRhapsodie\DataflowBundle\Entity\Job;
 use CodeRhapsodie\DataflowBundle\Factory\ConnectionFactory;
 use CodeRhapsodie\DataflowBundle\Gateway\JobGateway;
-use CodeRhapsodie\DataflowBundle\Repository\JobRepository;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;

src/DependencyInjection/Configuration.php

@@ -47,7 +47,7 @@ public function getConfigTreeBuilder(): TreeBuilder
                         ->scalarNode('flysystem_service')
                         ->end()
                         ->validate()
-                            ->ifTrue(static fn($v): bool => 'file' === $v['type'] && !interface_exists('\League\Flysystem\Filesystem'))
+                            ->ifTrue(static fn ($v): bool => $v['type'] === 'file' && !interface_exists('\League\Flysystem\Filesystem'))
                             ->thenInvalid('You need "league/flysystem" to use Dataflow file exception mode.')
                         ->end()
                     ->end()

src/ExceptionsHandler/ExceptionHandlerInterface.php

@@ -9,4 +9,4 @@ interface ExceptionHandlerInterface
     public function save(?int $jobId, ?array $exceptions): void;
 
     public function find(int $jobId): ?array;
-}
+}

src/ExceptionsHandler/FilesystemExceptionHandler.php

@@ -19,19 +19,19 @@ public function save(?int $jobId, ?array $exceptions): void
             return;
         }
 
-        $this->filesystem->write(sprintf('dataflow-job-%s.log', $jobId), json_encode($exceptions));
+        $this->filesystem->write(\sprintf('dataflow-job-%s.log', $jobId), json_encode($exceptions));
     }
 
     public function find(int $jobId): ?array
     {
         try {
-            if (!$this->filesystem->has(sprintf('dataflow-job-%s.log', $jobId))) {
+            if (!$this->filesystem->has(\sprintf('dataflow-job-%s.log', $jobId))) {
                 return [];
             }
 
-            return json_decode($this->filesystem->read(sprintf('dataflow-job-%s.log', $jobId)), true);
+            return json_decode($this->filesystem->read(\sprintf('dataflow-job-%s.log', $jobId)), true);
         } catch (FilesystemException) {
             return [];
         }
     }
-}
+}

src/ExceptionsHandler/NullExceptionHandler.php

@@ -6,7 +6,6 @@
 
 class NullExceptionHandler implements ExceptionHandlerInterface
 {
-
     public function save(?int $jobId, ?array $exceptions): void
     {
     }
@@ -15,4 +14,4 @@ public function find(int $jobId): ?array
     {
         return null;
     }
-}
+}

src/Gateway/JobGateway.php

@@ -49,4 +49,4 @@ private function loadExceptions(?Job $job): ?Job
 
         return $job->setExceptions($this->exceptionHandler->find($job->getId()));
     }
-}
+}

src/Processor/JobProcessor.php

@@ -14,7 +14,6 @@
 use CodeRhapsodie\DataflowBundle\Logger\DelegatingLogger;
 use CodeRhapsodie\DataflowBundle\Registry\DataflowTypeRegistryInterface;
 use CodeRhapsodie\DataflowBundle\Repository\JobRepository;
-use League\Flysystem\Filesystem;
 use Monolog\Logger;
 use Psr\Log\LoggerAwareInterface;
 use Psr\Log\LoggerAwareTrait;
@@ -29,8 +28,7 @@ public function __construct(
         private DataflowTypeRegistryInterface $registry,
         private EventDispatcherInterface $dispatcher,
         private JobGateway $jobGateway,
-    )
-    {
+    ) {
     }
 
     public function process(Job $job): void