* Fix File Exceptions integration

CHANGELOG.md

@@ -1,3 +1,6 @@
+# Version 5.4.1
+* Fix File Exceptions integration
+
 # Version 5.4.0
 * Add possibility to save exceptions in file
 

src/CodeRhapsodieDataflowBundle.php

@@ -8,6 +8,7 @@
 use CodeRhapsodie\DataflowBundle\DependencyInjection\Compiler\BusCompilerPass;
 use CodeRhapsodie\DataflowBundle\DependencyInjection\Compiler\DataflowTypeCompilerPass;
 use CodeRhapsodie\DataflowBundle\DependencyInjection\Compiler\DefaultLoggerCompilerPass;
+use CodeRhapsodie\DataflowBundle\DependencyInjection\Compiler\ExceptionCompilerPass;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\DependencyInjection\Extension\ExtensionInterface;
 use Symfony\Component\HttpKernel\Bundle\Bundle;
@@ -30,6 +31,7 @@ public function build(ContainerBuilder $container): void
             ->addCompilerPass(new DataflowTypeCompilerPass())
             ->addCompilerPass(new DefaultLoggerCompilerPass())
             ->addCompilerPass(new BusCompilerPass())
+            ->addCompilerPass(new ExceptionCompilerPass())
         ;
     }
 }

src/DependencyInjection/Configuration.php

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

src/ExceptionsHandler/FilesystemExceptionHandler.php

@@ -25,7 +25,7 @@ public function save(?int $jobId, ?array $exceptions): void
     public function find(int $jobId): ?array
     {
         try {
-            if (!$this->filesystem->has(\sprintf('dataflow-job-%s.log', $jobId))) {
+            if (!$this->filesystem->fileExists(\sprintf('dataflow-job-%s.log', $jobId))) {
                 return [];
             }