* Fix CI

Author: AUDUL

.php-cs-fixer.dist.php

@@ -9,6 +9,7 @@
 $config->setRules([
     '@Symfony' => true,
     '@Symfony:risky' => true,
+    '@PHP8x2Migration:risky' => true,
     '@PSR12' => true,
     'array_syntax' => [
         'syntax' => 'short',

src/DataflowType/AbstractDataflowType.php

@@ -5,12 +5,11 @@
 namespace CodeRhapsodie\DataflowBundle\DataflowType;
 
 use CodeRhapsodie\DataflowBundle\Repository\JobRepository;
-use Psr\Log\LoggerAwareInterface;
 use Psr\Log\LoggerAwareTrait;
 use Psr\Log\LoggerInterface;
 use Symfony\Component\OptionsResolver\OptionsResolver;
 
-abstract class AbstractDataflowType implements DataflowTypeInterface, LoggerAwareInterface, AutoUpdateCountInterface
+abstract class AbstractDataflowType implements DataflowTypeInterface, AutoUpdateCountInterface
 {
     use LoggerAwareTrait;
 
@@ -36,7 +35,7 @@ public function process(array $options, ?int $jobId = null): Result
 
         $builder = $this->createDataflowBuilder();
         $builder->setName($this->getLabel());
-        $builder->addAfterItemProcessor(function (int|string $index, mixed $item, int $count) use ($jobId) {
+        $builder->addAfterItemProcessor(function (int|string $index, mixed $item, int $count) use ($jobId): void {
             if ($jobId === null || $this->saveDate > new \DateTime()) {
                 return;
             }

src/DataflowType/Dataflow/AMPAsyncDataflow.php

@@ -122,7 +122,7 @@ private function processState(mixed $state, int &$count, int &$countExceptions):
                 $this->stepsJobs[$stepIndex][$readIndex] = true;
                 /** @var Promise<void> $promise */
                 $promise = coroutine($step)($item);
-                $promise->onResolve(function (?\Throwable $exception = null, $newItem = null) use ($stepIndex, $readIndex, &$countExceptions) {
+                $promise->onResolve(function (?\Throwable $exception = null, $newItem = null) use ($stepIndex, $readIndex, &$countExceptions): void {
                     if ($exception) {
                         ++$countExceptions;
                         $this->logException($exception, (string) $stepIndex);

src/DataflowType/Writer/CollectionWriter.php

@@ -18,12 +18,12 @@ public function __construct(private readonly WriterInterface $writer)
     {
     }
 
-    public function prepare()
+    public function prepare(): void
     {
         $this->writer->prepare();
     }
 
-    public function write($collection)
+    public function write($collection): void
     {
         if (!is_iterable($collection)) {
             throw new UnsupportedItemTypeException(\sprintf('Item to write was expected to be an iterable, received %s.', get_debug_type($collection)));
@@ -34,7 +34,7 @@ public function write($collection)
         }
     }
 
-    public function finish()
+    public function finish(): void
     {
         $this->writer->finish();
     }

src/DataflowType/Writer/DelegatorWriter.php

@@ -21,14 +21,14 @@ public function __construct()
     {
     }
 
-    public function prepare()
+    public function prepare(): void
     {
         foreach ($this->delegates as $delegate) {
             $delegate->prepare();
         }
     }
 
-    public function write($item)
+    public function write($item): void
     {
         foreach ($this->delegates as $delegate) {
             if (!$delegate->supports($item)) {
@@ -43,7 +43,7 @@ public function write($item)
         throw new UnsupportedItemTypeException(\sprintf('None of the registered delegate writers support the received item of type %s', get_debug_type($item)));
     }
 
-    public function finish()
+    public function finish(): void
     {
         foreach ($this->delegates as $delegate) {
             $delegate->finish();

src/DataflowType/Writer/PortWriterAdapter.php

@@ -10,17 +10,17 @@ public function __construct(private readonly \Port\Writer $writer)
     {
     }
 
-    public function prepare()
+    public function prepare(): void
     {
         $this->writer->prepare();
     }
 
-    public function write($item)
+    public function write($item): void
     {
         $this->writer->writeItem((array) $item);
     }
 
-    public function finish()
+    public function finish(): void
     {
         $this->writer->finish();
     }

src/Factory/ConnectionFactory.php

@@ -17,7 +17,7 @@ public function __construct(private readonly Container $container, private strin
     {
     }
 
-    public function setConnectionName(string $connectionName)
+    public function setConnectionName(string $connectionName): void
     {
         $this->connectionName = $connectionName;
     }

src/MessengerMode/JobMessageHandler.php

@@ -15,7 +15,7 @@ public function __construct(private readonly JobRepository $repository, private
     {
     }
 
-    public function __invoke(JobMessage $message)
+    public function __invoke(JobMessage $message): void
     {
         $this->processor->process($this->repository->find($message->getJobId()));
     }

src/Repository/JobRepository.php

@@ -116,7 +116,7 @@ public function findForScheduled(int $id): iterable
         }
     }
 
-    public function save(Job $job)
+    public function save(Job $job): void
     {
         $datas = $job->toArray();
         unset($datas['id']);

src/Repository/ScheduledDataflowRepository.php

@@ -85,7 +85,7 @@ public function listAllOrderedByLabel(): array
         return $query->executeQuery()->fetchAllAssociative();
     }
 
-    public function save(ScheduledDataflow $scheduledDataflow)
+    public function save(ScheduledDataflow $scheduledDataflow): void
     {
         $datas = $scheduledDataflow->toArray();
         unset($datas['id']);