diff --git a/CHANGELOG.md b/CHANGELOG.md index 5e8db49..4bc8f7c 100644 --- a/CHANGELOG.md +++ b/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 diff --git a/src/CodeRhapsodieDataflowBundle.php b/src/CodeRhapsodieDataflowBundle.php index fd84009..9c5f562 100644 --- a/src/CodeRhapsodieDataflowBundle.php +++ b/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()) ; } } diff --git a/src/DependencyInjection/Configuration.php b/src/DependencyInjection/Configuration.php index bd0a67b..12a6df0 100644 --- a/src/DependencyInjection/Configuration.php +++ b/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() diff --git a/src/ExceptionsHandler/FilesystemExceptionHandler.php b/src/ExceptionsHandler/FilesystemExceptionHandler.php index 1fd5bac..9176cf7 100644 --- a/src/ExceptionsHandler/FilesystemExceptionHandler.php +++ b/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 []; }