fix(CleanupRedis): guard against scan() returning false and use lowercase option keys

- Change Redis scan() option keys from uppercase (MATCH, COUNT) to lowercase (match, count) to comply with PhpRedis requirements
- Add guard to handle scan() returning false and display error message
- Add comprehensive test coverage for scan() error handling scenarios

app/Console/Commands/CleanupRedis.php

@@ -359,7 +359,14 @@ private function cleanupStuckJobs($redis, string $prefix, bool $dryRun, bool $is
         $cursor = 0;
         $keys = [];
         do {
-            $result = $redis->scan($cursor, ['MATCH' => '*', 'COUNT' => 100]);
+            $result = $redis->scan($cursor, ['match' => '*', 'count' => 100]);
+
+            // Guard against scan() returning false
+            if ($result === false) {
+                $this->error('Redis scan failed, stopping key retrieval');
+                break;
+            }
+
             $cursor = $result[0];
             $keys = array_merge($keys, $result[1]);
         } while ($cursor !== 0);

tests/Feature/CleanupRedisTest.php

@@ -0,0 +1,126 @@
+<?php
+
+use App\Console\Commands\CleanupRedis;
+use Illuminate\Support\Facades\Redis;
+
+beforeEach(function () {
+    config(['horizon.prefix' => 'horizon:']);
+});
+
+it('handles Redis scan returning false gracefully', function () {
+    // Mock Redis connection
+    $redisMock = Mockery::mock();
+
+    // Mock scan() returning false (error case)
+    $redisMock->shouldReceive('scan')
+        ->once()
+        ->with(0, ['match' => '*', 'count' => 100])
+        ->andReturn(false);
+
+    // Mock keys() for initial scan and overlapping queues cleanup
+    $redisMock->shouldReceive('keys')
+        ->with('*')
+        ->andReturn([]);
+
+    Redis::shouldReceive('connection')
+        ->with('horizon')
+        ->andReturn($redisMock);
+
+    // Run the command in dry-run mode with restart flag to trigger cleanupStuckJobs
+    // Use skip-overlapping to avoid additional keys() calls
+    $this->artisan(CleanupRedis::class, ['--dry-run' => true, '--restart' => true, '--skip-overlapping' => true])
+        ->expectsOutput('DRY RUN MODE - No data will be deleted')
+        ->expectsOutputToContain('Redis scan failed, stopping key retrieval')
+        ->assertSuccessful();
+});
+
+it('successfully scans Redis keys when scan returns valid results', function () {
+    // Mock Redis connection
+    $redisMock = Mockery::mock();
+
+    // Mock successful scan() that returns keys
+    // First iteration returns cursor 1 and some keys
+    $redisMock->shouldReceive('scan')
+        ->once()
+        ->with(0, ['match' => '*', 'count' => 100])
+        ->andReturn([1, ['horizon:job:1', 'horizon:job:2']]);
+
+    // Second iteration returns cursor 0 (end of scan) and more keys
+    $redisMock->shouldReceive('scan')
+        ->once()
+        ->with(1, ['match' => '*', 'count' => 100])
+        ->andReturn([0, ['horizon:job:3']]);
+
+    // Mock keys() for initial scan
+    $redisMock->shouldReceive('keys')
+        ->with('*')
+        ->andReturn([]);
+
+    // Mock command() for type checking on each key
+    $redisMock->shouldReceive('command')
+        ->with('type', Mockery::any())
+        ->andReturn(5); // Hash type
+
+    // Mock command() for hgetall to get job data
+    $redisMock->shouldReceive('command')
+        ->with('hgetall', Mockery::any())
+        ->andReturn(['status' => 'pending', 'payload' => '{}']);
+
+    Redis::shouldReceive('connection')
+        ->with('horizon')
+        ->andReturn($redisMock);
+
+    // Run the command with restart flag to trigger cleanupStuckJobs
+    $this->artisan(CleanupRedis::class, ['--dry-run' => true, '--restart' => true, '--skip-overlapping' => true])
+        ->expectsOutput('DRY RUN MODE - No data will be deleted')
+        ->assertSuccessful();
+});
+
+it('handles empty scan results gracefully', function () {
+    // Mock Redis connection
+    $redisMock = Mockery::mock();
+
+    // Mock scan() returning empty results
+    $redisMock->shouldReceive('scan')
+        ->once()
+        ->with(0, ['match' => '*', 'count' => 100])
+        ->andReturn([0, []]); // Cursor 0 and no keys
+
+    // Mock keys() for initial scan
+    $redisMock->shouldReceive('keys')
+        ->with('*')
+        ->andReturn([]);
+
+    Redis::shouldReceive('connection')
+        ->with('horizon')
+        ->andReturn($redisMock);
+
+    // Run the command with restart flag
+    $this->artisan(CleanupRedis::class, ['--dry-run' => true, '--restart' => true, '--skip-overlapping' => true])
+        ->expectsOutput('DRY RUN MODE - No data will be deleted')
+        ->assertSuccessful();
+});
+
+it('uses lowercase option keys for scan', function () {
+    // Mock Redis connection
+    $redisMock = Mockery::mock();
+
+    // Verify that scan is called with lowercase keys: 'match' and 'count'
+    $redisMock->shouldReceive('scan')
+        ->once()
+        ->with(0, ['match' => '*', 'count' => 100])
+        ->andReturn([0, []]);
+
+    // Mock keys() for initial scan
+    $redisMock->shouldReceive('keys')
+        ->with('*')
+        ->andReturn([]);
+
+    Redis::shouldReceive('connection')
+        ->with('horizon')
+        ->andReturn($redisMock);
+
+    // Run the command with restart flag
+    $this->artisan(CleanupRedis::class, ['--dry-run' => true, '--restart' => true, '--skip-overlapping' => true])
+        ->assertSuccessful();
+});