.-.-.-.-.-

<?php
/**
 * @link https://craftcms.com/
 * @copyright Copyright (c) Pixel & Tonic, Inc.
 * @license https://craftcms.github.io/license/
 */

namespace craft\queue;

use craft\console\ControllerTrait;
use craft\helpers\Console;
use yii\console\ExitCode;
use yii\db\Exception as YiiDbException;

/**
 * Manages the queue.
 *
 * @author Pixel & Tonic, Inc. <support@pixelandtonic.com>
 * @author Roman Zhuravlev <zhuravljov@gmail.com>
 * @since 3.0.0
 */
class Command extends \yii\queue\cli\Command
{
    use ControllerTrait;

/**
     * @var string The job ID to run
     * @since 4.8.0
     */
    public ?string $jobId = null;

/**
     * @var Queue
     */
    public $queue;

/**
     * @var string
     */
    public $defaultAction = 'info';

/**
     * @inheritdoc
     */
    public $verboseConfig = [
        'class' => VerboseBehavior::class,
    ];

/**
     * @inheritdoc
     */
    public function options($actionID)
    {
        $options = parent::options($actionID);
        if ($actionID === 'run') {
            $options[] = 'jobId';
        }
        return $options;
    }

/**
     * @inheritdoc
     */
    protected function isWorkerAction($actionID): bool
    {
        return in_array($actionID, ['run', 'listen'], true);
    }

/**
     * @inheritdoc
     */
    public function actions(): array
    {
        return [
            'info' => InfoAction::class,
        ];
    }

/**
     * Runs all jobs in the queue.
     *
     * @return int
     */
    public function actionRun(): int
    {
        if ($this->jobId) {
            return $this->queue->executeJob($this->jobId) ? ExitCode::OK : ExitCode::UNSPECIFIED_ERROR;
        }

return $this->queue->run() ?? ExitCode::OK;
    }

/**
     * Listens for new jobs added to the queue and runs them.
     *
     * @param int $timeout The number of seconds to wait between cycles.
     * @return int
     */
    public function actionListen(int $timeout = 3): int
    {
        return $this->queue->run(true, $timeout) ?? ExitCode::OK;
    }

/**
     * Re-adds a failed job(s) to the queue.
     *
     * @param int|string $job The job ID that should be retried, or `all` to retry all failed jobs.
     * @return int
     * @since 3.1.21
     */
    public function actionRetry(int|string $job): int
    {
        if (strtolower($job) === 'all') {
            $total = $this->queue->getTotalFailed();
            if ($total === 0) {
                $this->stdout('No failed jobs in the queue.' . PHP_EOL);
                return ExitCode::OK;
            }
            $this->stdout("Re-adding $total failed " . ($total === 1 ? 'job' : 'jobs') . ' back into the queue ... ');
            $this->queue->retryAll();
        } else {
            $this->stdout('Re-adding 1 failed job back into the queue ... ');
            $this->queue->retry($job);
        }

$this->stdout('done' . PHP_EOL, Console::FG_GREEN);
        return ExitCode::OK;
    }

/**
     * Releases job(s) from the queue.
     *
     * Example:
     *
     * ```
     * php craft queue/release all
     * ```
     *
     * @param string $job The job ID to release. Pass `all` to release all jobs.
     * @return int
     * @throws YiiDbException
     * @since 3.4.0
     */
    public function actionRelease(string $job): int
    {
        if (strtolower($job) === 'all') {
            $this->stdout('Releasing all queue jobs ... ');
            $this->queue->releaseAll();
        } else {
            $this->stdout('Releasing job ');
            $this->stdout($job, Console::FG_YELLOW);
            $this->stdout(' ... ');
            $this->queue->release($job);
        }

$this->stdout('done' . PHP_EOL, Console::FG_GREEN);
        return ExitCode::OK;
    }
}

/srv/users/craft4/apps/craft4-newsite-space/vendor/symfony/../craftcms/cms/src/queue/Command.php