Add more tests and allow partly run

composer.json

@@ -27,17 +27,14 @@
         "psr/event-dispatcher": "^1.0",
         "psr/log": "^1.1",
         "yiisoft/friendly-exception": "^1.0",
+        "yiisoft/injector": "^1.0",
         "yiisoft/serializer": "^3.0@dev"
     },
     "require-dev": {
-        "infection/infection": "^0.16.0",
-        "pda/pheanstalk": "*",
+        "infection/infection": "^0.17.0",
+        "phan/phan": "^3.0",
         "phpunit/phpunit": "^9.3",
-        "yiisoft/composer-config-plugin": "^1.0@dev",
-        "yiisoft/di": "^3.0@dev",
-        "yiisoft/log": "^3.0@dev",
-        "yiisoft/yii-console": "^3.0@dev",
-        "phan/phan": "^3.0"
+        "yiisoft/test-support": "3.0.x-dev"
     },
     "suggest": {
         "ext-pcntl": "Need for process signals"

config/common.php

@@ -3,9 +3,10 @@
 use Psr\Container\ContainerInterface;
 use Psr\EventDispatcher\EventDispatcherInterface;
 use Psr\EventDispatcher\ListenerProviderInterface;
-use Yiisoft\Di\Container;
 use Yiisoft\EventDispatcher\Dispatcher\Dispatcher;
 use Yiisoft\EventDispatcher\Provider\Provider;
+use Yiisoft\Serializer\JsonSerializer;
+use Yiisoft\Serializer\SerializerInterface;
 use Yiisoft\Factory\Definitions\Reference;
 use Yiisoft\Yii\Queue\Cli\LoopInterface;
 use Yiisoft\Yii\Queue\Cli\SignalLoop;
@@ -21,5 +22,6 @@
     WorkerInterface::class => Reference::to(QueueWorker::class),
     ListenerProviderInterface::class => Provider::class,
     ContainerInterface::class => fn (ContainerInterface $container) => $container,
-    LoopInterface::class => SignalLoop::class
+    LoopInterface::class => SignalLoop::class,
+    SerializerInterface::class => JsonSerializer::class,
 ];

infection.json.dist

@@ -5,12 +5,13 @@
         ]
     },
     "logs": {
-        "text": "php:\/\/stderr",
+        "text": "infection.log",
         "badge": {
             "branch": "master"
         }
     },
     "mutators": {
-        "@default": true
+        "@default": true,
+        "ProtectedVisibility": false
     }
 }

phpunit.xml.dist

@@ -1,19 +1,22 @@
 <?xml version="1.0" encoding="utf-8"?>
-<phpunit bootstrap="./tests/bootstrap.php"
-         colors="true"
-         convertErrorsToExceptions="true"
-         convertNoticesToExceptions="true"
-         convertWarningsToExceptions="true"
-         stopOnFailure="false">
+<phpunit
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    bootstrap="./tests/bootstrap.php"
+    colors="true"
+    convertErrorsToExceptions="true"
+    convertNoticesToExceptions="true"
+    convertWarningsToExceptions="true"
+    stopOnFailure="false"
+    xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/9.3/phpunit.xsd"
+>
+    <coverage>
+        <include>
+            <directory>./src</directory>
+        </include>
+    </coverage>
     <testsuites>
         <testsuite name="Test Suite">
-            <directory>./tests/unit</directory>
+            <directory>./tests/Unit</directory>
         </testsuite>
     </testsuites>
-
-    <filter>
-        <whitelist>
-            <directory>./src</directory>
-        </whitelist>
-    </filter>
 </phpunit>

src/Driver/DriverInterface.php

@@ -6,10 +6,10 @@
 
 use InvalidArgumentException;
 use Yiisoft\Yii\Queue\Enum\JobStatus;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
+use Yiisoft\Yii\Queue\Payload\AttemptsRestrictedPayloadInterface;
 use Yiisoft\Yii\Queue\Payload\DelayablePayloadInterface;
 use Yiisoft\Yii\Queue\Payload\PrioritisedPayloadInterface;
-use Yiisoft\Yii\Queue\Payload\AttemptsRestrictedPayloadInterface;
-use Yiisoft\Yii\Queue\MessageInterface;
 
 interface DriverInterface
 {

src/Driver/SynchronousDriver.php

@@ -7,8 +7,8 @@
 use InvalidArgumentException;
 use Yiisoft\Yii\Queue\Cli\LoopInterface;
 use Yiisoft\Yii\Queue\Enum\JobStatus;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Payload\PayloadInterface;
-use Yiisoft\Yii\Queue\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 use Yiisoft\Yii\Queue\QueueDependentInterface;
 use Yiisoft\Yii\Queue\Worker\WorkerInterface;

src/Event/AfterExecution.php

@@ -4,7 +4,7 @@
 
 namespace Yiisoft\Yii\Queue\Event;
 
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 final class AfterExecution

src/Event/AfterPush.php

@@ -4,7 +4,7 @@
 
 namespace Yiisoft\Yii\Queue\Event;
 
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 final class AfterPush

src/Event/BeforeExecution.php

@@ -4,7 +4,7 @@
 
 namespace Yiisoft\Yii\Queue\Event;
 
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 final class BeforeExecution

src/Event/BeforePush.php

@@ -4,7 +4,7 @@
 
 namespace Yiisoft\Yii\Queue\Event;
 
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 final class BeforePush

src/Event/JobFailure.php

@@ -6,7 +6,7 @@
 
 use Psr\EventDispatcher\StoppableEventInterface;
 use Throwable;
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 final class JobFailure implements StoppableEventInterface

src/Exception/JobFailureException.php

@@ -6,7 +6,7 @@
 
 use RuntimeException;
 use Throwable;
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 
 class JobFailureException extends RuntimeException
 {

src/Exception/PayloadNotSupportedException.php

@@ -68,7 +68,7 @@ public function getSolution(): ?string
             The solution is in one of these:
             - Check which interfaces does $driverClass support and remove not supported interfaces from $payloadName.
             - Use another driver which supports all interfaces you need. Officially supported drivers are:
-                - None yet :) Work is in progress.
+                - yiisoft/yii-queue-amqp
             SOLUTION;
     }
 }

src/Message.php → src/Message/Message.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Yii\Queue;
+namespace Yiisoft\Yii\Queue\Message;
 
 class Message implements MessageInterface
 {

src/MessageInterface.php → src/Message/MessageInterface.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Yii\Queue;
+namespace Yiisoft\Yii\Queue\Message;
 
 interface MessageInterface
 {

src/Payload/BasicPayload.php

@@ -7,6 +7,9 @@
 class BasicPayload implements PayloadInterface
 {
     protected string $name;
+    /**
+     * @var mixed $data It can be anything what can be serialized with the queue driver serializer
+     */
     protected $data;
     protected array $meta;
 

src/Queue.php

@@ -12,11 +12,13 @@
 use Yiisoft\Yii\Queue\Event\BeforePush;
 use Yiisoft\Yii\Queue\Event\JobFailure;
 use Yiisoft\Yii\Queue\Exception\PayloadNotSupportedException;
+use Yiisoft\Yii\Queue\Message\Message;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
+use Yiisoft\Yii\Queue\Payload\AttemptsRestrictedPayloadInterface;
 use Yiisoft\Yii\Queue\Payload\BasicPayload;
 use Yiisoft\Yii\Queue\Payload\DelayablePayloadInterface;
 use Yiisoft\Yii\Queue\Payload\PayloadInterface;
 use Yiisoft\Yii\Queue\Payload\PrioritisedPayloadInterface;
-use Yiisoft\Yii\Queue\Payload\AttemptsRestrictedPayloadInterface;
 use Yiisoft\Yii\Queue\Worker\WorkerInterface;
 
 /**
@@ -107,13 +109,19 @@ public function push(PayloadInterface $payload): ?string
 
     /**
      * Execute all existing jobs and exit
+     *
+     * @param int $max
      */
-    public function run(): void
+    public function run(int $max = 0): void
     {
         $this->logger->debug('Start processing queue messages.');
         $count = 0;
 
-        while ($this->loop->canContinue() && $message = $this->driver->nextMessage()) {
+        while (
+            ($max <= 0 || $max > $count)
+            && $this->loop->canContinue()
+            && $message = $this->driver->nextMessage()
+        ) {
             $this->handle($message);
             $count++;
         }

src/Worker/Worker.php

@@ -14,7 +14,7 @@
 use Yiisoft\Yii\Queue\Event\BeforeExecution;
 use Yiisoft\Yii\Queue\Event\JobFailure;
 use Yiisoft\Yii\Queue\Exception\JobFailureException;
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 final class Worker implements WorkerInterface

src/Worker/WorkerInterface.php

@@ -4,7 +4,7 @@
 
 namespace Yiisoft\Yii\Queue\Worker;
 
-use Yiisoft\Yii\Queue\MessageInterface;
+use Yiisoft\Yii\Queue\Message\MessageInterface;
 use Yiisoft\Yii\Queue\Queue;
 
 interface WorkerInterface

tests/App/DelayablePayload.php

@@ -8,6 +8,8 @@
 
 class DelayablePayload extends SimplePayload implements DelayablePayloadInterface
 {
+    protected string $name = 'delayable';
+
     public function getDelay(): int
     {
         return 1;

tests/App/DummyInterface.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace Yiisoft\Yii\Queue\Tests\App;
+
+interface DummyInterface
+{
+}