<?php

declare(strict_types=1);

/**
 * This file is part of CodeIgniter Queue.
 *
 * (c) CodeIgniter Foundation <admin@codeigniter.com>
 *
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

namespace Tests;

use CodeIgniter\Exceptions\CriticalError;
use CodeIgniter\Queue\Entities\QueueJob;
use CodeIgniter\Queue\Handlers\RabbitMQHandler;
use CodeIgniter\Queue\QueuePushResult;
use PhpAmqpLib\Connection\AMQPConnectionFactory;
use Tests\Support\Config\Queue as QueueConfig;
use Tests\Support\TestCase;
use Throwable;

/**
 * Test RabbitMQ delay functionality with real timing.
 *
 * @internal
 */
final class RabbitMQDelayTest extends TestCase
{
    private ?RabbitMQHandler $handler = null;

    protected function setUp(): void
    {
        parent::setUp();

        $config = config(QueueConfig::class);

        // Skip tests if RabbitMQ is not available
        if (! $this->isRabbitMQAvailable()) {
            $this->markTestSkipped('RabbitMQ is not available for testing');
        }

        try {
            $this->handler = new RabbitMQHandler($config);
        } catch (CriticalError) {
            $this->markTestSkipped('Cannot connect to RabbitMQ server');
        }
    }

    protected function tearDown(): void
    {
        if ($this->handler !== null) {
            // Clear test queues
            try {
                $this->handler->clear('delay-test-queue');
            } catch (Throwable) {
                // Ignore cleanup errors
            }
        }

        parent::tearDown();
    }

    public function testDelayedMessageWithRealTiming(): void
    {
        // Use a short real delay (2 seconds) for testing
        $delaySeconds = 2;
        $startTime    = time();

        // Push a delayed job
        $result = $this->handler->setDelay($delaySeconds)->push('delay-test-queue', 'success', ['type' => 'delayed']);
        $this->assertInstanceOf(QueuePushResult::class, $result);
        $this->assertTrue($result->getStatus());

        // Push an immediate job
        $result = $this->handler->push('delay-test-queue', 'success', ['type' => 'immediate']);
        $this->assertInstanceOf(QueuePushResult::class, $result);
        $this->assertTrue($result->getStatus());

        // Should get immediate job first
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertInstanceOf(QueueJob::class, $job);
        $this->assertSame('immediate', $job->payload['data']['type']);
        $this->handler->done($job);

        // Should not get delayed job yet (within first second)
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertNull($job);

        // Wait for delay to expire (with a small buffer)
        $waitTime = $delaySeconds + 1;
        sleep($waitTime);

        // Should now get the delayed job
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertInstanceOf(QueueJob::class, $job);
        $this->assertSame('delayed', $job->payload['data']['type']);

        // Verify timing - job should have been delayed at least the specified time
        $elapsedTime = time() - $startTime;
        $this->assertGreaterThanOrEqual($delaySeconds, $elapsedTime);

        // Clean up
        $this->handler->done($job);
    }

    public function testMultipleDelayedJobsWithDifferentDelays(): void
    {
        // Push jobs with different delays
        $result1 = $this->handler->setDelay(1)->push('delay-test-queue', 'success', ['order' => 'first', 'delay' => 1]);
        $result2 = $this->handler->setDelay(3)->push('delay-test-queue', 'success', ['order' => 'second', 'delay' => 3]);
        $result3 = $this->handler->push('delay-test-queue', 'success', ['order' => 'immediate', 'delay' => 0]);

        $this->assertTrue($result1->getStatus());
        $this->assertTrue($result2->getStatus());
        $this->assertTrue($result3->getStatus());

        // Should get immediate job first
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertInstanceOf(QueueJob::class, $job);
        $this->assertSame('immediate', $job->payload['data']['order']);
        $this->handler->done($job);

        // Wait 2 seconds - should get first delayed job
        sleep(2);
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertInstanceOf(QueueJob::class, $job);
        $this->assertSame('first', $job->payload['data']['order']);
        $this->handler->done($job);

        // Should not get second job yet
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertNull($job);

        // Wait another 2 seconds - should get second delayed job
        sleep(2);
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertInstanceOf(QueueJob::class, $job);
        $this->assertSame('second', $job->payload['data']['order']);
        $this->handler->done($job);
    }

    public function testZeroDelayWorksImmediately(): void
    {
        // Jobs with 0 delay should work immediately
        $result = $this->handler->setDelay(0)->push('delay-test-queue', 'success', ['type' => 'zero-delay']);
        $this->assertTrue($result->getStatus());

        // Should be able to pop immediately
        $job = $this->handler->pop('delay-test-queue', ['default']);
        $this->assertInstanceOf(QueueJob::class, $job);
        $this->assertSame('zero-delay', $job->payload['data']['type']);

        $this->handler->done($job);
    }

    /**
     * Check if RabbitMQ is available for testing.
     */
    private function isRabbitMQAvailable(): bool
    {
        return class_exists(AMQPConnectionFactory::class);
    }
}