tests/Integration/Queue/QueueTestCase.php - 13.x - githubmirror/framework

tests/Integration/Queue/QueueTestCase.php
104 строки2 KB
Lucas Michot
Centralize per-test static state resets in AfterEachTestSubscriber (#61078)
07 авг 2026, 19:38
07 авг 2026, 19:383eef88d
<?php

namespace Illuminate\Tests\Integration\Queue;

use Illuminate\Foundation\Testing\Concerns\InteractsWithRedis;
use Illuminate\Foundation\Testing\DatabaseMigrations;
use Orchestra\Testbench\TestCase;

abstract class QueueTestCase extends TestCase
{
    use DatabaseMigrations, InteractsWithRedis;

    /**
     * The current database driver.
     *
     * @var string
     */
    protected $driver;

    /**
     * Define the test environment.
     *
     * @param  \Illuminate\Foundation\Application  $app
     * @return void
     */
    protected function defineEnvironment($app)
    {
        $this->driver = $app['config']->get('queue.default', 'sync');
    }

    protected function setUp(): void
    {
        $this->afterApplicationCreated(function () {
            if ($this->getQueueDriver() === 'redis') {
                $this->setUpRedis();
            }
        });

        $this->beforeApplicationDestroyed(function () {
            if ($this->getQueueDriver() === 'redis') {
                $this->tearDownRedis();
            }
        });

        parent::setUp();
    }

    /**
     * Run queue worker command.
     *
     * @param  array  $options
     * @param  int  $times
     * @return void
     */
    protected function runQueueWorkerCommand(array $options = [], int $times = 1): void
    {
        if ($this->getQueueDriver() !== 'sync' && $times > 0) {
            $count = 0;

            do {
                $this->artisan('queue:work', array_merge($options, [
                    '--memory' => 1024,
                ]))->assertSuccessful();

                $count++;
            } while ($count < $times);
        }
    }

    /**
     * Mark test as skipped when using given queue drivers.
     *
     * @param  array<int, string>  $drivers
     * @return void
     */
    protected function markTestSkippedWhenUsingQueueDrivers(array $drivers): void
    {
        foreach ($drivers as $driver) {
            if ($this->getQueueDriver() === $driver) {
                $this->markTestSkipped("Unable to use `{$driver}` queue driver for the test");
            }
        }
    }

    /**
     * Mark test as skipped when using "sync" queue driver.
     *
     * @return void
     */
    protected function markTestSkippedWhenUsingSyncQueueDriver(): void
    {
        $this->markTestSkippedWhenUsingQueueDrivers(['sync']);
    }

    /**
     * Get the queue driver.
     *
     * @return string
     */
    protected function getQueueDriver(): string
    {
        return $this->driver;
    }
}