130 lines
4.3 KiB
PHP
130 lines
4.3 KiB
PHP
<?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' => 'processing',
|
|
'reserved_at' => time() - 60, // Started 1 minute ago
|
|
'payload' => json_encode(['displayName' => 'TestJob']),
|
|
]);
|
|
|
|
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();
|
|
});
|