Add rector CI and apply suggestions

.github/workflows/rector.yml

@@ -0,0 +1,23 @@
+on:
+  pull_request:
+    paths-ignore:
+      - 'docs/**'
+      - 'README.md'
+      - 'CHANGELOG.md'
+      - '.gitignore'
+      - '.gitattributes'
+      - 'infection.json.dist'
+      - 'psalm.xml'
+
+name: rector
+
+jobs:
+  rector:
+    uses: yiisoft/actions/.github/workflows/rector.yml@master
+    secrets:
+      token: ${{ secrets.YIISOFT_GITHUB_TOKEN }}
+    with:
+      os: >-
+        ['ubuntu-latest']
+      php: >-
+        ['8.2']

composer.json

@@ -38,6 +38,7 @@
     "require-dev": {
         "maglnet/composer-require-checker": "^4.2",
         "phpunit/phpunit": "^9.5",
+        "rector/rector": "^0.18.10",
         "roave/infection-static-analysis-plugin": "^1.16",
         "spatie/phpunit-watcher": "^1.23",
         "yiisoft/yii-debug": "dev-master",

rector.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+use Rector\CodeQuality\Rector\Class_\InlineConstructorDefaultToPropertyRector;
+use Rector\Config\RectorConfig;
+use Rector\Php73\Rector\FuncCall\JsonThrowOnErrorRector;
+use Rector\Php74\Rector\Closure\ClosureToArrowFunctionRector;
+use Rector\Set\ValueObject\LevelSetList;
+
+return static function (RectorConfig $rectorConfig): void {
+    $rectorConfig->paths([
+        __DIR__ . '/src',
+        __DIR__ . '/tests',
+    ]);
+
+    // register a single rule
+    $rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);
+
+    // define sets of rules
+    $rectorConfig->sets([
+        LevelSetList::UP_TO_PHP_80,
+    ]);
+
+    $rectorConfig->skip([
+        ClosureToArrowFunctionRector::class,
+        JsonThrowOnErrorRector::class,
+    ]);
+};

src/Adapter/AdapterInterface.php

@@ -30,8 +30,6 @@ public function status(string $id): JobStatus;
 
     /**
      * Pushing a message to the queue. Adapter sets message ID if available.
-     *
-     * @param MessageInterface $message
      */
     public function push(MessageInterface $message): void;
 

src/Cli/SignalLoop.php

@@ -14,27 +14,23 @@
     protected const SIGNALS_SUSPEND = [SIGTSTP];
     /** @psalm-suppress UndefinedConstant */
     protected const SIGNALS_RESUME = [SIGCONT];
-
-    protected int $memorySoftLimit;
     protected bool $pause = false;
     protected bool $exit = false;
 
     /**
      * @param int $memorySoftLimit Soft RAM limit in bytes. The loop won't let you continue to execute the program if
      *     soft limit is reached. Zero means no limit.
      */
-    public function __construct(int $memorySoftLimit = 0)
+    public function __construct(protected int $memorySoftLimit = 0)
     {
-        $this->memorySoftLimit = $memorySoftLimit;
-
         foreach (self::SIGNALS_EXIT as $signal) {
             pcntl_signal($signal, fn () => $this->exit = true);
         }
         foreach (self::SIGNALS_SUSPEND as $signal) {
             pcntl_signal($signal, fn () => $this->pause = true);
         }
         foreach (self::SIGNALS_RESUME as $signal) {
             pcntl_signal($signal, fn () => $this->pause = false);
         }
     }
 
@@ -54,10 +50,10 @@
 
     protected function dispatchSignals(): bool
     {
         pcntl_signal_dispatch();
 
         // Wait for resume signal until loop is suspended
         while ($this->pause && !$this->exit) {
             usleep(10000);
             pcntl_signal_dispatch();
         }

src/Cli/SimpleLoop.php

@@ -8,16 +8,12 @@ class SimpleLoop implements LoopInterface
 {
     use SoftLimitTrait;
 
-    protected int $memorySoftLimit;
-
     /**
      * @param int $memorySoftLimit Soft RAM limit in bytes. The loop won't let you continue to execute the program if
      *     soft limit is reached. Zero means no limit.
      */
-    public function __construct(
-        int $memorySoftLimit = 0
-    ) {
-        $this->memorySoftLimit = $memorySoftLimit;
+    public function __construct(protected int $memorySoftLimit = 0)
+    {
     }
 
     public function canContinue(): bool

src/Command/ListenCommand.php

@@ -17,12 +17,9 @@ final class ListenCommand extends Command
     protected static $defaultName = 'queue:listen';
     protected static $defaultDescription = 'Listens the queue and executes messages as they come. Needs to be stopped manually.';
 
-    private QueueFactoryInterface $queueFactory;
-
-    public function __construct(QueueFactoryInterface $queueFactory)
+    public function __construct(private QueueFactoryInterface $queueFactory)
     {
         parent::__construct();
-        $this->queueFactory = $queueFactory;
     }
 
     public function configure(): void

src/Command/RunCommand.php

@@ -17,12 +17,9 @@ final class RunCommand extends Command
     protected static $defaultName = 'queue:run';
     protected static $defaultDescription = 'Runs all the existing messages in the queue. Exits once messages are over.';
 
-    private QueueFactoryInterface $queueFactory;
-
-    public function __construct(QueueFactoryInterface $queueFactory)
+    public function __construct(private QueueFactoryInterface $queueFactory)
     {
         parent::__construct();
-        $this->queueFactory = $queueFactory;
     }
 
     public function configure(): void

src/Exception/AdapterConfiguration/ChannelIncorrectlyConfigured.php

@@ -17,19 +17,17 @@
     /**
      * ChannelIncorrectlyConfigured constructor.
      *
-     * @param string $channel
      * @param mixed|object $definition
-     * @param int $code
      * @param Throwable|null $previous
      */
     public function __construct(string $channel, $definition, int $code = 0, ?Throwable $previous = null)
     {
         $adapterClass = AdapterInterface::class;
         $realType = get_debug_type($definition);
         $message = "Channel \"$channel\" is not properly configured: definition must return $adapterClass, $realType returned";
 
         $this->channel = $channel;
         parent::__construct($message, $code, $previous);
     }
 
     public function getName(): string

src/Exception/InvalidStatusException.php

@@ -40,8 +40,6 @@ public function getSolution(): ?string
 
     /**
      * Get the wrong status value
-     *
-     * @return int
      */
     public function getStatus(): int
     {

src/Exception/JobFailureException.php

@@ -10,14 +10,10 @@
 
 class JobFailureException extends RuntimeException
 {
-    private MessageInterface $queueMessage;
-
-    public function __construct(MessageInterface $message, Throwable $previous)
+    public function __construct(private MessageInterface $queueMessage, Throwable $previous)
     {
-        $this->queueMessage = $message;
-
         $error = $previous->getMessage();
-        $messageId = $message->getId() ?? 'null';
+        $messageId = $queueMessage->getId() ?? 'null';
         $messageText = "Processing of message #$messageId is stopped because of an exception:\n$error.";
 
         parent::__construct($messageText, 0, $previous);

src/Message/Message.php

@@ -7,7 +7,6 @@
 final class Message implements MessageInterface
 {
     /**
-     * @param string $handlerName
      * @param mixed $data Message data, encodable by a queue adapter
      * @param array $metadata Message metadata, encodable by a queue adapter
      * @param string|null $id Message id

src/Middleware/CallableFactory.php

@@ -19,11 +19,8 @@
  */
 final class CallableFactory
 {
-    private ContainerInterface $container;
-
-    public function __construct(ContainerInterface $container)
+    public function __construct(private ContainerInterface $container)
     {
-        $this->container = $container;
     }
 
     /**
@@ -64,13 +61,8 @@ public function create(mixed $definition): callable
     }
 
     /**
-     * @param string $className
-     * @param string $methodName
-     *
      * @throws ContainerExceptionInterface Error while retrieving the entry from container.
      * @throws NotFoundExceptionInterface
-     *
-     * @return callable|null
      */
     private function fromDefinition(string $className, string $methodName): ?callable
     {

src/Middleware/Consume/ConsumeRequest.php

@@ -13,9 +13,6 @@ public function __construct(private MessageInterface $message, private QueueInte
     {
     }
 
-    /**
-     * @return MessageInterface
-     */
     public function getMessage(): MessageInterface
     {
         return $this->message;

src/Middleware/Consume/MiddlewareFactoryConsume.php

@@ -87,13 +87,11 @@ private function getFromContainer(string $middlewareDefinition): MiddlewareConsu
     private function wrapCallable(callable $callback): MiddlewareConsumeInterface
     {
         return new class ($callback, $this->container) implements MiddlewareConsumeInterface {
-            private ContainerInterface $container;
             private $callback;
 
-            public function __construct(callable $callback, ContainerInterface $container)
+            public function __construct(callable $callback, private ContainerInterface $container)
             {
                 $this->callback = $callback;
-                $this->container = $container;
             }
 
             public function processConsume(ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest

src/Middleware/FailureHandling/FailureMiddlewareDispatcher.php

@@ -18,7 +18,6 @@ final class FailureMiddlewareDispatcher
     private array $stack = [];
 
     /**
-     * @param MiddlewareFactoryFailureInterface $middlewareFactory
      * @param array[][]|callable[][]|MiddlewareFailureInterface[][]|string[][] $middlewareDefinitions
      */
     public function __construct(

src/Middleware/FailureHandling/Implementation/ExponentialDelayMiddleware.php

@@ -28,7 +28,6 @@ final class ExponentialDelayMiddleware implements MiddlewareFailureInterface
      * @param float $delayInitial The first delay period
      * @param float $delayMaximum The maximum delay period
      * @param float $exponent Message handling delay will be increased by this multiplication each time it fails
-     * @param DelayMiddlewareInterface $delayMiddleware
      * @param QueueInterface|null $queue
      */
     public function __construct(

src/Middleware/FailureHandling/MiddlewareFactoryFailure.php

@@ -90,13 +90,11 @@ private function getFromContainer(string $middlewareDefinition): MiddlewareFailu
     private function wrapCallable(callable $callback): MiddlewareFailureInterface
     {
         return new class ($callback, $this->container) implements MiddlewareFailureInterface {
-            private ContainerInterface $container;
             private $callback;
 
-            public function __construct(callable $callback, ContainerInterface $container)
+            public function __construct(callable $callback, private ContainerInterface $container)
             {
                 $this->callback = $callback;
-                $this->container = $container;
             }
 
             public function processFailure(FailureHandlingRequest $request, MessageFailureHandlerInterface $handler): FailureHandlingRequest

src/Middleware/InvalidMiddlewareDefinitionException.php

@@ -8,7 +8,6 @@
 
 use Throwable;
 
-use function get_class;
 use function is_array;
 use function is_object;
 use function is_string;
@@ -31,14 +30,12 @@ public function __construct($middlewareDefinition, int $code = 0, ?Throwable $pr
     }
 
     /**
-     * @param mixed $middlewareDefinition
-     *
      * @return string|null
      */
     private function convertDefinitionToString(mixed $middlewareDefinition): ?string
     {
         if (is_object($middlewareDefinition)) {
-            return 'an instance of "' . get_class($middlewareDefinition) . '"';
+            return 'an instance of "' . $middlewareDefinition::class . '"';
         }
 
         if (is_string($middlewareDefinition)) {

src/Middleware/Push/MiddlewareFactoryPush.php

@@ -87,13 +87,11 @@ private function getFromContainer(string $middlewareDefinition): MiddlewarePushI
     private function wrapCallable(callable $callback): MiddlewarePushInterface
     {
         return new class ($callback, $this->container) implements MiddlewarePushInterface {
-            private ContainerInterface $container;
             private $callback;
 
-            public function __construct(callable $callback, ContainerInterface $container)
+            public function __construct(callable $callback, private ContainerInterface $container)
             {
                 $this->callback = $callback;
-                $this->container = $container;
             }
 
             public function processPush(PushRequest $request, MessageHandlerPushInterface $handler): PushRequest

src/Middleware/Push/PushRequest.php

@@ -13,9 +13,6 @@ public function __construct(private MessageInterface $message, private ?AdapterI
     {
     }
 
-    /**
-     * @return MessageInterface
-     */
     public function getMessage(): MessageInterface
     {
         return $this->message;

src/QueueFactory.php

@@ -29,9 +29,6 @@ final class QueueFactory implements QueueFactoryInterface
      * "Definition" here is a {@see Factory} definition
      * @param QueueInterface $queue A default queue implementation. `$queue->withAdapter()` will be returned
      * with the `get` method
-     * @param ContainerInterface $container
-     * @param CallableFactory $callableFactory
-     * @param Injector $injector
      * @param bool $enableRuntimeChannelDefinition A flag whether to enable a such behavior when there is no
      * explicit channel adapter definition: `return $this->queue->withAdapter($this->adapter->withChannel($channel)`
      * When this flag is set to false, only explicit definitions from the $definition parameter are used.
@@ -71,10 +68,7 @@ public function get(string $channel = self::DEFAULT_CHANNEL_NAME): QueueInterfac
     }
 
     /**
-     * @param string $channel
-     *
      * @throws ChannelIncorrectlyConfigured
-     *
      * @return QueueInterface
      */
     private function create(string $channel): QueueInterface

src/Worker/Worker.php

@@ -41,12 +41,7 @@ public function __construct(
     }
 
     /**
-     * @param MessageInterface $message
-     * @param QueueInterface $queue
-     *
      * @throws Throwable
-     *
-     * @return MessageInterface
      */
     public function process(MessageInterface $message, QueueInterface $queue): MessageInterface
     {
@@ -94,8 +89,6 @@ private function getHandler(string $name): ?callable
      *
      * @throws ContainerExceptionInterface
      * @throws NotFoundExceptionInterface
-     *
-     * @return callable|null
      */
     private function prepare(callable|object|array|string|null $definition): callable|null
     {

tests/Unit/JobStatusTest.php

@@ -43,10 +43,6 @@ public function getStatusPairs(): array
 
     /**
      * @dataProvider getStatusPairs
-     *
-     * @param string $statusName
-     * @param string $positiveMethod
-     * @param array $negatives
      */
     public function testInstanceValue(string $statusName, string $positiveMethod, array $negatives): void
     {

tests/Unit/Middleware/Consume/InvalidMiddlewareDefinitionExceptionTest.php

@@ -35,9 +35,6 @@ public function dataBase(): array
 
     /**
      * @dataProvider dataBase
-     *
-     * @param mixed $definition
-     * @param string $expected
      */
     public function testBase(mixed $definition, string $expected): void
     {
@@ -55,8 +52,6 @@ public function dataUnknownDefinition(): array
 
     /**
      * @dataProvider dataUnknownDefinition
-     *
-     * @param mixed $definition
      */
     public function testUnknownDefinition(mixed $definition): void
     {

tests/Unit/Middleware/Consume/MiddlewareDispatcherTest.php

@@ -162,7 +162,7 @@ public function handleConsume(ConsumeRequest $request): ConsumeRequest
     private function createDispatcher(
         ContainerInterface $container = null,
     ): ConsumeMiddlewareDispatcher {
-        $container = $container ?? $this->createContainer([AdapterInterface::class => new FakeAdapter()]);
+        $container ??= $this->createContainer([AdapterInterface::class => new FakeAdapter()]);
         $callableFactory = new CallableFactory($container);
 
         return new ConsumeMiddlewareDispatcher(