fix: phpstan issues

phpstan.neon.dist

@@ -15,8 +15,6 @@ parameters:
 	        paths:
 	            - src/Handlers/RedisHandler.php
 	            - src/Handlers/PredisHandler.php
-	    -
-	        message: '#Access to an undefined property CodeIgniter\\I18n\\Time::\$timestamp.#'
 	    -
 	        message: '#Call to an undefined method CodeIgniter\\Queue\\Models\\QueueJobFailedModel::affectedRows\(\).#'
 	        paths:

src/Commands/Generators/JobGenerator.php

@@ -45,7 +45,7 @@ class JobGenerator extends BaseCommand
     /**
      * The Command's Arguments
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $arguments = [
         'name' => 'The job class name.',
@@ -54,7 +54,7 @@ class JobGenerator extends BaseCommand
     /**
      * The Command's Options
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $options = [
         '--namespace' => 'Set root namespace. Default: "APP_NAMESPACE".',

src/Commands/QueueClear.php

@@ -40,7 +40,7 @@ class QueueClear extends BaseCommand
     /**
      * The Command's Arguments
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $arguments = [
         'queueName' => 'Name of the queue we will work with.',

src/Commands/QueueFailed.php

@@ -41,7 +41,7 @@ class QueueFailed extends BaseCommand
     /**
      * The Command's Options
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $options = [
         '-queue' => 'Queue name.',

src/Commands/QueueFlush.php

@@ -40,7 +40,7 @@ class QueueFlush extends BaseCommand
     /**
      * The Command's Options
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $options = [
         '-hours' => 'Number of hours.',

src/Commands/QueueForget.php

@@ -40,7 +40,7 @@ class QueueForget extends BaseCommand
     /**
      * The Command's Arguments
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $arguments = [
         'id' => 'ID of the failed job.',

src/Commands/QueueRetry.php

@@ -40,7 +40,7 @@ class QueueRetry extends BaseCommand
     /**
      * The Command's Arguments
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $arguments = [
         'id' => 'ID of the failed job or "all" for all failed jobs.',
@@ -49,7 +49,7 @@ class QueueRetry extends BaseCommand
     /**
      * The Command's Options
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $options = [
         '-queue' => 'Queue name.',

src/Commands/QueueStop.php

@@ -40,7 +40,7 @@ class QueueStop extends BaseCommand
     /**
      * The Command's Arguments
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $arguments = [
         'queueName' => 'Name of the queue we will work with.',
@@ -49,7 +49,7 @@ class QueueStop extends BaseCommand
     /**
      * The Command's Options
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $options = [
     ];

src/Commands/QueueWork.php

@@ -44,7 +44,7 @@ class QueueWork extends BaseCommand
     /**
      * The Command's Arguments
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $arguments = [
         'queueName' => 'Name of the queue we will work with.',
@@ -53,7 +53,7 @@ class QueueWork extends BaseCommand
     /**
      * The Command's Options
      *
-     * @var array
+     * @var array<string, string>
      */
     protected $options = [
         '-sleep'            => 'Wait time between the next check for available job when the queue is empty. Default value: 10 (seconds).',

src/Handlers/DatabaseHandler.php

@@ -39,7 +39,7 @@ public function push(string $queue, string $job, array $data): bool
             'priority'     => $this->priority,
             'status'       => Status::PENDING->value,
             'attempts'     => 0,
-            'available_at' => Time::now()->timestamp,
+            'available_at' => Time::now(),
         ]);
 
         $this->priority = null;
@@ -75,7 +75,7 @@ public function pop(string $queue, array $priorities): ?QueueJob
     public function later(QueueJob $queueJob, int $seconds): bool
     {
         $queueJob->status       = Status::PENDING->value;
-        $queueJob->available_at = Time::now()->addSeconds($seconds)->timestamp;
+        $queueJob->available_at = Time::now()->addSeconds($seconds);
 
         return $this->jobModel->save($queueJob);
     }

src/Handlers/PredisHandler.php

@@ -45,7 +45,7 @@ public function push(string $queue, string $job, array $data): bool
             'priority'     => $this->priority,
             'status'       => Status::PENDING->value,
             'attempts'     => 0,
-            'available_at' => Time::now()->timestamp,
+            'available_at' => Time::now(),
         ]);
 
         $result = $this->predis->zadd("queues:{$queue}:{$this->priority}", [json_encode($queueJob) => Time::now()->timestamp]);
@@ -100,7 +100,7 @@ public function pop(string $queue, array $priorities): ?QueueJob
     public function later(QueueJob $queueJob, int $seconds): bool
     {
         $queueJob->status       = Status::PENDING->value;
-        $queueJob->available_at = Time::now()->addSeconds($seconds)->timestamp;
+        $queueJob->available_at = Time::now()->addSeconds($seconds);
 
         $result = $this->predis->zadd(
             "queues:{$queueJob->queue}:{$queueJob->priority}",

src/Handlers/RedisHandler.php

@@ -62,7 +62,7 @@ public function push(string $queue, string $job, array $data): bool
             'priority'     => $this->priority,
             'status'       => Status::PENDING->value,
             'attempts'     => 0,
-            'available_at' => Time::now()->timestamp,
+            'available_at' => Time::now(),
         ]);
 
         $result = (int) $this->redis->zAdd("queues:{$queue}:{$this->priority}", Time::now()->timestamp, json_encode($queueJob));
@@ -83,7 +83,7 @@ public function pop(string $queue, array $priorities): ?QueueJob
         $now   = Time::now()->timestamp;
 
         foreach ($priorities as $priority) {
-            if ($tasks = $this->redis->zRangeByScore("queues:{$queue}:{$priority}", '-inf', $now, ['limit' => [0, 1]])) {
+            if ($tasks = $this->redis->zRangeByScore("queues:{$queue}:{$priority}", '-inf', (string) $now, ['limit' => [0, 1]])) {
                 if ($this->redis->zRem("queues:{$queue}:{$priority}", ...$tasks)) {
                     break;
                 }
@@ -114,7 +114,7 @@ public function pop(string $queue, array $priorities): ?QueueJob
     public function later(QueueJob $queueJob, int $seconds): bool
     {
         $queueJob->status       = Status::PENDING->value;
-        $queueJob->available_at = Time::now()->addSeconds($seconds)->timestamp;
+        $queueJob->available_at = Time::now()->addSeconds($seconds);
 
         $result = (int) $this->redis->zAdd(
             "queues:{$queueJob->queue}:{$queueJob->priority}",

tests/DatabaseHandlerTest.php

@@ -4,6 +4,7 @@
 
 namespace Tests;
 
+use CodeIgniter\I18n\Time;
 use CodeIgniter\Queue\Entities\QueueJob;
 use CodeIgniter\Queue\Enums\Status;
 use CodeIgniter\Queue\Exceptions\QueueException;
@@ -70,13 +71,16 @@ public function testPriorityNameLengthException(): void
      */
     public function testPush(): void
     {
+        Time::setTestNow('2023-12-29 14:15:16');
+
         $handler = new DatabaseHandler($this->config);
         $result  = $handler->push('queue', 'success', ['key' => 'value']);
 
         $this->assertTrue($result);
         $this->seeInDatabase('queue_jobs', [
-            'queue'   => 'queue',
-            'payload' => json_encode(['job' => 'success', 'data' => ['key' => 'value']]),
+            'queue'        => 'queue',
+            'payload'      => json_encode(['job' => 'success', 'data' => ['key' => 'value']]),
+            'available_at' => '1703859316',
         ]);
     }
 
@@ -85,36 +89,43 @@ public function testPush(): void
      */
     public function testPushWithPriority(): void
     {
+        Time::setTestNow('2023-12-29 14:15:16');
+
         $handler = new DatabaseHandler($this->config);
         $result  = $handler->setPriority('high')->push('queue', 'success', ['key' => 'value']);
 
         $this->assertTrue($result);
         $this->seeInDatabase('queue_jobs', [
-            'queue'    => 'queue',
-            'payload'  => json_encode(['job' => 'success', 'data' => ['key' => 'value']]),
-            'priority' => 'high',
+            'queue'        => 'queue',
+            'payload'      => json_encode(['job' => 'success', 'data' => ['key' => 'value']]),
+            'priority'     => 'high',
+            'available_at' => '1703859316',
         ]);
     }
 
     public function testPushAndPopWithPriority(): void
     {
+        Time::setTestNow('2023-12-29 14:15:16');
+
         $handler = new DatabaseHandler($this->config);
         $result  = $handler->push('queue', 'success', ['key1' => 'value1']);
 
         $this->assertTrue($result);
         $this->seeInDatabase('queue_jobs', [
-            'queue'    => 'queue',
-            'payload'  => json_encode(['job' => 'success', 'data' => ['key1' => 'value1']]),
-            'priority' => 'low',
+            'queue'        => 'queue',
+            'payload'      => json_encode(['job' => 'success', 'data' => ['key1' => 'value1']]),
+            'priority'     => 'low',
+            'available_at' => '1703859316',
         ]);
 
         $result = $handler->setPriority('high')->push('queue', 'success', ['key2' => 'value2']);
 
         $this->assertTrue($result);
         $this->seeInDatabase('queue_jobs', [
-            'queue'    => 'queue',
-            'payload'  => json_encode(['job' => 'success', 'data' => ['key2' => 'value2']]),
-            'priority' => 'high',
+            'queue'        => 'queue',
+            'payload'      => json_encode(['job' => 'success', 'data' => ['key2' => 'value2']]),
+            'priority'     => 'high',
+            'available_at' => '1703859316',
         ]);
 
         $result = $handler->pop('queue', ['high', 'low']);
@@ -207,6 +218,8 @@ public function testPopEmpty(): void
      */
     public function testLater(): void
     {
+        Time::setTestNow('2023-12-29 14:15:16');
+
         $handler  = new DatabaseHandler($this->config);
         $queueJob = $handler->pop('queue1', ['default']);
 
@@ -219,8 +232,9 @@ public function testLater(): void
 
         $this->assertTrue($result);
         $this->seeInDatabase('queue_jobs', [
-            'id'     => 2,
-            'status' => Status::PENDING->value,
+            'id'           => 2,
+            'status'       => Status::PENDING->value,
+            'available_at' => Time::now()->addSeconds(60)->timestamp,
         ]);
     }
 
@@ -229,6 +243,8 @@ public function testLater(): void
      */
     public function testFailedAndKeepJob(): void
     {
+        Time::setTestNow('2023-12-29 14:15:16');
+
         $handler  = new DatabaseHandler($this->config);
         $queueJob = $handler->pop('queue1', ['default']);
 
@@ -243,6 +259,7 @@ public function testFailedAndKeepJob(): void
             'id'         => 2,
             'connection' => 'database',
             'queue'      => 'queue1',
+            'failed_at'  => '1703859316',
         ]);
     }
 

tests/_support/CLITestCase.php

@@ -5,27 +5,14 @@
 namespace Tests\Support;
 
 use CodeIgniter\CLI\CLI;
-use CodeIgniter\I18n\Time;
 use CodeIgniter\Test\ReflectionHelper;
-use Exception;
 
 abstract class CLITestCase extends TestCase
 {
     use ReflectionHelper;
 
     private array $lines = [];
 
-    /**
-     * @throws Exception
-     */
-    protected function tearDown(): void
-    {
-        parent::tearDown();
-
-        // Reset the current time.
-        Time::setTestNow();
-    }
-
     protected function parseOutput(string $output): string
     {
         $this->lines = [];

tests/_support/TestCase.php

@@ -4,8 +4,10 @@
 
 namespace Tests\Support;
 
+use CodeIgniter\I18n\Time;
 use CodeIgniter\Test\CIUnitTestCase;
 use CodeIgniter\Test\DatabaseTestTrait;
+use Exception;
 
 abstract class TestCase extends CIUnitTestCase
 {
@@ -19,4 +21,15 @@ protected function setUp(): void
 
         parent::setUp();
     }
+
+    /**
+     * @throws Exception
+     */
+    protected function tearDown(): void
+    {
+        parent::tearDown();
+
+        // Reset the current time.
+        Time::setTestNow();
+    }
 }