refactor(core): code adapted for 8.1

rector.php

@@ -10,7 +10,7 @@
 use Rector\Symfony\Set\SymfonySetList;
 
 return static function (RectorConfig $rectorConfig): void {
-    $rectorConfig->phpVersion(phpVersion: PhpVersion::PHP_80);
+    $rectorConfig->phpVersion(phpVersion: PhpVersion::PHP_81);
     $rectorConfig->importNames();
     $rectorConfig->importShortClasses();
     $rectorConfig->parallel(seconds: 600, maxNumberOfProcess: 32);
@@ -54,6 +54,7 @@
         SetList::PHP_73,
         SetList::PHP_74,
         SetList::PHP_80,
+        SetList::PHP_81,
         SetList::UNWRAP_COMPAT,
     ]);
 

src/Bridge/Doctrine/Connection/AbstractDoctrineConnection.php

@@ -16,7 +16,7 @@
  */
 abstract class AbstractDoctrineConnection
 {
-    public function __construct(private DBALConnection $driverConnection)
+    public function __construct(private readonly DBALConnection $driverConnection)
     {
     }
 

src/Bridge/Doctrine/Transport/Configuration/DoctrineConfigurationFactory.php

@@ -19,7 +19,7 @@
  */
 final class DoctrineConfigurationFactory implements ConfigurationFactoryInterface
 {
-    public function __construct(private ConnectionRegistry $registry)
+    public function __construct(private readonly ConnectionRegistry $registry)
     {
     }
 

src/Bridge/Doctrine/Transport/DoctrineTransportFactory.php

@@ -21,7 +21,7 @@
  */
 final class DoctrineTransportFactory implements TransportFactoryInterface
 {
-    public function __construct(private ConnectionRegistry $registry)
+    public function __construct(private readonly ConnectionRegistry $registry)
     {
     }
 

src/Bridge/Redis/Transport/Connection.php

@@ -27,13 +27,13 @@ final class Connection implements ConnectionInterface
 
     public function __construct(
         ConfigurationInterface $configuration,
-        private SerializerInterface $serializer,
+        private readonly SerializerInterface $serializer,
         ?Redis $redis = null
     ) {
         $this->connection = $redis ?? new Redis();
         $this->connection->connect($configuration->get('host'), $configuration->get('port'), $configuration->get('timeout'));
 
-        if (!str_starts_with($this->list = $configuration->get('list'), '_')) {
+        if (!str_starts_with((string) ($this->list = $configuration->get('list')), '_')) {
             throw new InvalidArgumentException('The list name must start with an underscore');
         }
 

src/Command/ConsumeTasksCommand.php

@@ -41,12 +41,12 @@
 )]
 final class ConsumeTasksCommand extends Command
 {
-    private LoggerInterface $logger;
+    private readonly LoggerInterface $logger;
 
     public function __construct(
-        private SchedulerInterface $scheduler,
-        private WorkerInterface $worker,
-        private EventDispatcherInterface $eventDispatcher,
+        private readonly SchedulerInterface $scheduler,
+        private readonly WorkerInterface $worker,
+        private readonly EventDispatcherInterface $eventDispatcher,
         LoggerInterface $logger = null
     ) {
         $this->logger = $logger ?? new NullLogger();

src/Command/DebugConfigurationCommand.php

@@ -22,7 +22,7 @@
 )]
 final class DebugConfigurationCommand extends Command
 {
-    public function __construct(private ConfigurationInterface $configuration)
+    public function __construct(private readonly ConfigurationInterface $configuration)
     {
         parent::__construct();
     }

src/Command/DebugMiddlewareCommand.php

@@ -33,8 +33,8 @@
 final class DebugMiddlewareCommand extends Command
 {
     public function __construct(
-        private SchedulerMiddlewareStackInterface $schedulerMiddlewareStack,
-        private WorkerMiddlewareStackInterface $workerMiddlewareStack
+        private readonly SchedulerMiddlewareStackInterface $schedulerMiddlewareStack,
+        private readonly WorkerMiddlewareStackInterface $workerMiddlewareStack
     ) {
         parent::__construct();
     }

src/Command/DebugProbeCommand.php

@@ -29,8 +29,8 @@
 final class DebugProbeCommand extends Command
 {
     public function __construct(
-        private ProbeInterface $probe,
-        private SchedulerInterface $scheduler
+        private readonly ProbeInterface $probe,
+        private readonly SchedulerInterface $scheduler
     ) {
         parent::__construct();
     }

src/Command/ExecuteExternalProbeCommand.php

@@ -28,8 +28,8 @@
 final class ExecuteExternalProbeCommand extends Command
 {
     public function __construct(
-        private SchedulerInterface $scheduler,
-        private WorkerInterface $worker
+        private readonly SchedulerInterface $scheduler,
+        private readonly WorkerInterface $worker
     ) {
         parent::__construct();
     }

src/Command/ExecuteTaskCommand.php

@@ -41,16 +41,12 @@
 )]
 final class ExecuteTaskCommand extends Command
 {
-    private LoggerInterface $logger;
-
     public function __construct(
-        private EventDispatcherInterface $eventDispatcher,
-        private SchedulerInterface $scheduler,
-        private WorkerInterface $worker,
-        ?LoggerInterface $logger = null
+        private readonly EventDispatcherInterface $eventDispatcher,
+        private readonly SchedulerInterface $scheduler,
+        private readonly WorkerInterface $worker,
+        private readonly LoggerInterface $logger = new NullLogger()
     ) {
-        $this->logger = $logger ?? new NullLogger();
-
         parent::__construct();
     }
 

src/Command/ListFailedTasksCommand.php

@@ -25,7 +25,7 @@
 )]
 final class ListFailedTasksCommand extends Command
 {
-    public function __construct(private WorkerInterface $worker)
+    public function __construct(private readonly WorkerInterface $worker)
     {
         parent::__construct();
     }

src/Command/ListTasksCommand.php

@@ -39,7 +39,7 @@ final class ListTasksCommand extends Command
     /**
      * {@inheritdoc}
      */
-    public function __construct(private SchedulerInterface $scheduler)
+    public function __construct(private readonly SchedulerInterface $scheduler)
     {
         parent::__construct();
     }

src/Command/RebootSchedulerCommand.php

@@ -32,16 +32,12 @@
 )]
 final class RebootSchedulerCommand extends Command
 {
-    private LoggerInterface $logger;
-
     public function __construct(
-        private SchedulerInterface $scheduler,
-        private WorkerInterface $worker,
-        private EventDispatcherInterface $eventDispatcher,
-        ?LoggerInterface $logger = null
+        private readonly SchedulerInterface $scheduler,
+        private readonly WorkerInterface $worker,
+        private readonly EventDispatcherInterface $eventDispatcher,
+        private readonly LoggerInterface $logger = new NullLogger()
     ) {
-        $this->logger = $logger ?? new NullLogger();
-
         parent::__construct();
     }
 

src/Command/RemoveFailedTaskCommand.php

@@ -31,8 +31,8 @@
 final class RemoveFailedTaskCommand extends Command
 {
     public function __construct(
-        private SchedulerInterface $scheduler,
-        private WorkerInterface $worker
+        private readonly SchedulerInterface $scheduler,
+        private readonly WorkerInterface $worker
     ) {
         parent::__construct();
     }

src/Command/RetryFailedTaskCommand.php

@@ -34,11 +34,11 @@
 )]
 final class RetryFailedTaskCommand extends Command
 {
-    private LoggerInterface $logger;
+    private readonly LoggerInterface $logger;
 
     public function __construct(
-        private WorkerInterface $worker,
-        private EventDispatcherInterface $eventDispatcher,
+        private readonly WorkerInterface $worker,
+        private readonly EventDispatcherInterface $eventDispatcher,
         LoggerInterface $logger = null
     ) {
         $this->logger = $logger ?? new NullLogger();

src/Command/YieldTaskCommand.php

@@ -27,7 +27,7 @@
 )]
 final class YieldTaskCommand extends Command
 {
-    public function __construct(private SchedulerInterface $scheduler)
+    public function __construct(private readonly SchedulerInterface $scheduler)
     {
         parent::__construct();
     }

src/DataCollector/SchedulerDataCollector.php

@@ -25,11 +25,11 @@ final class SchedulerDataCollector extends DataCollector implements LateDataColl
      */
     public const NAME = 'scheduler';
 
-    private TaskEventList $events;
+    private readonly TaskEventList $events;
 
     public function __construct(
         TaskLoggerSubscriber $taskLoggerSubscriber,
-        private ?ProbeInterface $probe = null
+        private readonly ?ProbeInterface $probe = null
     ) {
         $this->events = $taskLoggerSubscriber->getEvents();
     }

src/DependencyInjection/SchedulerPass.php

@@ -17,8 +17,8 @@
 final class SchedulerPass implements CompilerPassInterface
 {
     public function __construct(
-        private string $schedulerExtraTag = 'scheduler.extra',
-        private string $schedulerEntryPointTag = 'scheduler.entry_point'
+        private readonly string $schedulerExtraTag = 'scheduler.extra',
+        private readonly string $schedulerEntryPointTag = 'scheduler.entry_point'
     ) {
     }
 

src/Event/SchedulerRebootedEvent.php

@@ -12,7 +12,7 @@
  */
 final class SchedulerRebootedEvent extends Event
 {
-    public function __construct(private SchedulerInterface $scheduler)
+    public function __construct(private readonly SchedulerInterface $scheduler)
     {
     }
 

src/Event/TaskExecutedEvent.php

@@ -13,7 +13,7 @@
  */
 final class TaskExecutedEvent extends Event implements TaskEventInterface
 {
-    public function __construct(private TaskInterface $task, private Output $output)
+    public function __construct(private readonly TaskInterface $task, private readonly Output $output)
     {
     }
 

src/Event/TaskExecutingEvent.php

@@ -14,7 +14,7 @@
  */
 final class TaskExecutingEvent extends Event implements TaskEventInterface, WorkerEventInterface
 {
-    public function __construct(private TaskInterface $task, private WorkerInterface $worker, private TaskListInterface $currentTasks)
+    public function __construct(private readonly TaskInterface $task, private readonly WorkerInterface $worker, private readonly TaskListInterface $currentTasks)
     {
     }
 

src/Event/TaskFailedEvent.php

@@ -12,7 +12,7 @@
  */
 final class TaskFailedEvent extends Event implements TaskEventInterface
 {
-    public function __construct(private FailedTask $task)
+    public function __construct(private readonly FailedTask $task)
     {
     }
 

src/Event/TaskScheduledEvent.php

@@ -12,7 +12,7 @@
  */
 final class TaskScheduledEvent extends Event implements TaskEventInterface
 {
-    public function __construct(private TaskInterface $task)
+    public function __construct(private readonly TaskInterface $task)
     {
     }
 

src/Event/TaskUnscheduledEvent.php

@@ -11,7 +11,7 @@
  */
 final class TaskUnscheduledEvent extends Event implements TaskEventInterface
 {
-    public function __construct(private string $task)
+    public function __construct(private readonly string $task)
     {
     }
 

src/Event/WorkerForkedEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerForkedEvent extends Event
 {
-    public function __construct(private WorkerInterface $forkedWorker, private WorkerInterface $newWorker)
+    public function __construct(private readonly WorkerInterface $forkedWorker, private readonly WorkerInterface $newWorker)
     {
     }
 

src/Event/WorkerPausedEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerPausedEvent extends Event
 {
-    public function __construct(private WorkerInterface $worker)
+    public function __construct(private readonly WorkerInterface $worker)
     {
     }
 

src/Event/WorkerRestartedEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerRestartedEvent extends Event
 {
-    public function __construct(private WorkerInterface $worker)
+    public function __construct(private readonly WorkerInterface $worker)
     {
     }
 

src/Event/WorkerRunningEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerRunningEvent extends Event implements WorkerEventInterface
 {
-    public function __construct(private WorkerInterface $worker, private bool $isIdle = false)
+    public function __construct(private readonly WorkerInterface $worker, private readonly bool $isIdle = false)
     {
     }
 

src/Event/WorkerSleepingEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerSleepingEvent extends Event implements WorkerEventInterface
 {
-    public function __construct(private int $sleepDuration, private WorkerInterface $worker)
+    public function __construct(private readonly int $sleepDuration, private readonly WorkerInterface $worker)
     {
     }
 

src/Event/WorkerStartedEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerStartedEvent extends Event implements WorkerEventInterface
 {
-    public function __construct(private WorkerInterface $worker)
+    public function __construct(private readonly WorkerInterface $worker)
     {
     }
 

src/Event/WorkerStoppedEvent.php

@@ -12,7 +12,7 @@
  */
 final class WorkerStoppedEvent extends Event
 {
-    public function __construct(private WorkerInterface $worker)
+    public function __construct(private readonly WorkerInterface $worker)
     {
     }
 

src/EventListener/ProbeStateSubscriber.php

@@ -19,7 +19,7 @@
  */
 final class ProbeStateSubscriber implements EventSubscriberInterface
 {
-    public function __construct(private ProbeInterface $probe, private string $path = '/_probe')
+    public function __construct(private readonly ProbeInterface $probe, private readonly string $path = '/_probe')
     {
     }
 

src/EventListener/StopWorkerOnFailureLimitSubscriber.php

@@ -17,15 +17,12 @@
  */
 final class StopWorkerOnFailureLimitSubscriber implements EventSubscriberInterface
 {
-    private LoggerInterface $logger;
     private int $failedTasks = 0;
 
     public function __construct(
-        private int $maximumFailedTasks,
-        ?LoggerInterface $logger = null
+        private readonly int $maximumFailedTasks,
+        private readonly LoggerInterface $logger = new NullLogger()
     ) {
-        $this->logger = $logger ?? new NullLogger();
-
         if ($maximumFailedTasks <= 0) {
             throw new InvalidArgumentException(sprintf('The failure limit must be greater than 0, given %d', $maximumFailedTasks));
         }

src/EventListener/StopWorkerOnSignalSubscriber.php

@@ -26,11 +26,8 @@
  */
 final class StopWorkerOnSignalSubscriber implements EventSubscriberInterface
 {
-    private LoggerInterface $logger;
-
-    public function __construct(?LoggerInterface $logger = null)
+    public function __construct(private readonly LoggerInterface $logger = new NullLogger())
     {
-        $this->logger = $logger ?? new NullLogger();
     }
 
     public function onTaskExecuting(TaskExecutingEvent $taskExecutingEvent): void