webshell

Ghost Exploiter Team Official

Directory >> /home/whitjouh/public_html/core/vendor/laravel/framework/src/Illuminate/Queue/Console/

File / Folder	Size	Action
.	-
stubs	--	ren
BatchesTableCommand.php	0.931KB	edt ren
ClearCommand.php	2.729KB	edt ren
FailedTableCommand.php	0.923KB	edt ren
FlushFailedCommand.php	0.984KB	edt ren
ForgetFailedCommand.php	0.886KB	edt ren
ListFailedCommand.php	2.895KB	edt ren
ListenCommand.php	4.033KB	edt ren
MonitorCommand.php	3.749KB	edt ren
PruneBatchesCommand.php	1.994KB	edt ren
PruneFailedJobsCommand.php	1.206KB	edt ren
RestartCommand.php	1.259KB	edt ren
RetryBatchCommand.php	1.645KB	edt ren
RetryCommand.php	5.46KB	edt ren
TableCommand.php	0.903KB	edt ren
WorkCommand.php	9.65KB	edt ren

<?php

namespace Illuminate\Queue\Console;

use Illuminate\Console\Command;
use Illuminate\Support\Arr;
use Symfony\Component\Console\Attribute\AsCommand;

#[AsCommand(name: 'queue:failed')]
class ListFailedCommand extends Command
{
    /**
     * The console command name.
     *
     * @var string
     */
    protected $name = 'queue:failed';

/**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'List all of the failed queue jobs';

/**
     * The table headers for the command.
     *
     * @var string[]
     */
    protected $headers = ['ID', 'Connection', 'Queue', 'Class', 'Failed At'];

/**
     * Execute the console command.
     *
     * @return void
     */
    public function handle()
    {
        if (count($jobs = $this->getFailedJobs()) === 0) {
            return $this->components->info('No failed jobs found.');
        }

$this->newLine();
        $this->displayFailedJobs($jobs);
        $this->newLine();
    }

/**
     * Compile the failed jobs into a displayable format.
     *
     * @return array
     */
    protected function getFailedJobs()
    {
        $failed = $this->laravel['queue.failer']->all();

return collect($failed)->map(function ($failed) {
            return $this->parseFailedJob((array) $failed);
        })->filter()->all();
    }

/**
     * Parse the failed job row.
     *
     * @param  array  $failed
     * @return array
     */
    protected function parseFailedJob(array $failed)
    {
        $row = array_values(Arr::except($failed, ['payload', 'exception']));

array_splice($row, 3, 0, $this->extractJobName($failed['payload']) ?: '');

return $row;
    }

/**
     * Extract the failed job name from payload.
     *
     * @param  string  $payload
     * @return string|null
     */
    private function extractJobName($payload)
    {
        $payload = json_decode($payload, true);

if ($payload && (! isset($payload['data']['command']))) {
            return $payload['job'] ?? null;
        } elseif ($payload && isset($payload['data']['command'])) {
            return $this->matchJobName($payload);
        }
    }

/**
     * Match the job name from the payload.
     *
     * @param  array  $payload
     * @return string|null
     */
    protected function matchJobName($payload)
    {
        preg_match('/"([^"]+)"/', $payload['data']['command'], $matches);

return $matches[1] ?? $payload['job'] ?? null;
    }

/**
     * Display the failed jobs in the console.
     *
     * @param  array  $jobs
     * @return void
     */
    protected function displayFailedJobs(array $jobs)
    {
        collect($jobs)->each(
            fn ($job) => $this->components->twoColumnDetail(
                sprintf('<fg=gray>%s</> %s</>', $job[4], $job[0]),
                sprintf('<fg=gray>%s@%s</> %s', $job[1], $job[2], $job[3])
            ),
        );
    }
}

<=Back