REDROOM

Navigation

Breadcrumbs

/ / home / getspomw / royalsquad.us / vendor / laravel / framework / src / Illuminate / Queue

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 9.25 KB

/home/getspomw/royalsquad.us/vendor/laravel/framework/src/Illuminate/Queue/CallQueuedHandler.php

Text Base64

<?php

namespace Illuminate\Queue;

use Exception;
use Illuminate\Bus\Batchable;
use Illuminate\Bus\UniqueLock;
use Illuminate\Contracts\Bus\Dispatcher;
use Illuminate\Contracts\Cache\Factory as CacheFactory;
use Illuminate\Contracts\Cache\Repository as Cache;
use Illuminate\Contracts\Container\Container;
use Illuminate\Contracts\Encryption\Encrypter;
use Illuminate\Contracts\Queue\Job;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldBeUniqueUntilProcessing;
use Illuminate\Database\Eloquent\ModelNotFoundException;
use Illuminate\Log\Context\Repository as ContextRepository;
use Illuminate\Pipeline\Pipeline;
use Illuminate\Queue\Attributes\DeleteWhenMissingModels;
use ReflectionClass;
use RuntimeException;

class CallQueuedHandler
{
    /**
     * The bus dispatcher implementation.
     *
     * @var \Illuminate\Contracts\Bus\Dispatcher
     */
    protected $dispatcher;

/**
     * The container instance.
     *
     * @var \Illuminate\Contracts\Container\Container
     */
    protected $container;

/**
     * Create a new handler instance.
     *
     * @param  \Illuminate\Contracts\Bus\Dispatcher  $dispatcher
     * @param  \Illuminate\Contracts\Container\Container  $container
     * @return void
     */
    public function __construct(Dispatcher $dispatcher, Container $container)
    {
        $this->container = $container;
        $this->dispatcher = $dispatcher;
    }

/**
     * Handle the queued job.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  array  $data
     * @return void
     */
    public function call(Job $job, array $data)
    {
        try {
            $command = $this->setJobInstanceIfNecessary(
                $job, $this->getCommand($data)
            );
        } catch (ModelNotFoundException $e) {
            return $this->handleModelNotFound($job, $e);
        }

$this->dispatchThroughMiddleware($job, $command);

if (! $job->isReleased() && ! $command instanceof ShouldBeUniqueUntilProcessing) {
            $this->ensureUniqueJobLockIsReleased($command);
        }

if (! $job->hasFailed() && ! $job->isReleased()) {
            $this->ensureNextJobInChainIsDispatched($command);
            $this->ensureSuccessfulBatchJobIsRecorded($command);
        }

if (! $job->isDeletedOrReleased()) {
            $job->delete();
        }
    }

/**
     * Get the command from the given payload.
     *
     * @param  array  $data
     * @return mixed
     *
     * @throws \RuntimeException
     */
    protected function getCommand(array $data)
    {
        if (str_starts_with($data['command'], 'O:')) {
            return unserialize($data['command']);
        }

if ($this->container->bound(Encrypter::class)) {
            return unserialize($this->container[Encrypter::class]->decrypt($data['command']));
        }

throw new RuntimeException('Unable to extract job payload.');
    }

/**
     * Dispatch the given job / command through its specified middleware.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  mixed  $command
     * @return mixed
     */
    protected function dispatchThroughMiddleware(Job $job, $command)
    {
        if ($command instanceof \__PHP_Incomplete_Class) {
            throw new Exception('Job is incomplete class: '.json_encode($command));
        }

return (new Pipeline($this->container))->send($command)
            ->through(array_merge(method_exists($command, 'middleware') ? $command->middleware() : [], $command->middleware ?? []))
            ->then(function ($command) use ($job) {
                if ($command instanceof ShouldBeUniqueUntilProcessing) {
                    $this->ensureUniqueJobLockIsReleased($command);
                }

return $this->dispatcher->dispatchNow(
                    $command, $this->resolveHandler($job, $command)
                );
            });
    }

/**
     * Resolve the handler for the given command.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  mixed  $command
     * @return mixed
     */
    protected function resolveHandler($job, $command)
    {
        $handler = $this->dispatcher->getCommandHandler($command) ?: null;

if ($handler) {
            $this->setJobInstanceIfNecessary($job, $handler);
        }

return $handler;
    }

/**
     * Set the job instance of the given class if necessary.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  mixed  $instance
     * @return mixed
     */
    protected function setJobInstanceIfNecessary(Job $job, $instance)
    {
        if (in_array(InteractsWithQueue::class, class_uses_recursive($instance))) {
            $instance->setJob($job);
        }

return $instance;
    }

/**
     * Ensure the next job in the chain is dispatched if applicable.
     *
     * @param  mixed  $command
     * @return void
     */
    protected function ensureNextJobInChainIsDispatched($command)
    {
        if (method_exists($command, 'dispatchNextJobInChain')) {
            $command->dispatchNextJobInChain();
        }
    }

/**
     * Ensure the batch is notified of the successful job completion.
     *
     * @param  mixed  $command
     * @return void
     */
    protected function ensureSuccessfulBatchJobIsRecorded($command)
    {
        $uses = class_uses_recursive($command);

if (! in_array(Batchable::class, $uses) ||
            ! in_array(InteractsWithQueue::class, $uses)) {
            return;
        }

if ($batch = $command->batch()) {
            $batch->recordSuccessfulJob($command->job->uuid());
        }
    }

/**
     * Ensure the lock for a unique job is released.
     *
     * @param  mixed  $command
     * @return void
     */
    protected function ensureUniqueJobLockIsReleased($command)
    {
        if ($command instanceof ShouldBeUnique) {
            (new UniqueLock($this->container->make(Cache::class)))->release($command);
        }
    }

/**
     * Handle a model not found exception.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  \Throwable  $e
     * @return void
     */
    protected function handleModelNotFound(Job $job, $e)
    {
        $class = $job->resolveName();

try {
            $reflectionClass = new ReflectionClass($class);

$shouldDelete = $reflectionClass->getDefaultProperties()['deleteWhenMissingModels']
                ?? count($reflectionClass->getAttributes(DeleteWhenMissingModels::class)) !== 0;
        } catch (Exception) {
            $shouldDelete = false;
        }

$this->ensureUniqueJobLockIsReleasedViaContext();

if ($shouldDelete) {
            return $job->delete();
        }

return $job->fail($e);
    }

/**
     * Ensure the lock for a unique job is released via context.
     *
     * This is required when we can't unserialize the job due to missing models.
     *
     * @return void
     */
    protected function ensureUniqueJobLockIsReleasedViaContext()
    {
        if (! $this->container->bound(ContextRepository::class) ||
            ! $this->container->bound(CacheFactory::class)) {
            return;
        }

$context = $this->container->make(ContextRepository::class);

[$store, $key] = [
            $context->getHidden('laravel_unique_job_cache_store'),
            $context->getHidden('laravel_unique_job_key'),
        ];

if ($store && $key) {
            $this->container->make(CacheFactory::class)
                ->store($store)
                ->lock($key)
                ->forceRelease();
        }
    }

/**
     * Call the failed method on the job instance.
     *
     * The exception that caused the failure will be passed.
     *
     * @param  array  $data
     * @param  \Throwable|null  $e
     * @param  string  $uuid
     * @return void
     */
    public function failed(array $data, $e, string $uuid)
    {
        $command = $this->getCommand($data);

if (! $command instanceof ShouldBeUniqueUntilProcessing) {
            $this->ensureUniqueJobLockIsReleased($command);
        }

if ($command instanceof \__PHP_Incomplete_Class) {
            return;
        }

$this->ensureFailedBatchJobIsRecorded($uuid, $command, $e);
        $this->ensureChainCatchCallbacksAreInvoked($uuid, $command, $e);

if (method_exists($command, 'failed')) {
            $command->failed($e);
        }
    }

/**
     * Ensure the batch is notified of the failed job.
     *
     * @param  string  $uuid
     * @param  mixed  $command
     * @param  \Throwable  $e
     * @return void
     */
    protected function ensureFailedBatchJobIsRecorded(string $uuid, $command, $e)
    {
        if (! in_array(Batchable::class, class_uses_recursive($command))) {
            return;
        }

if ($batch = $command->batch()) {
            $batch->recordFailedJob($uuid, $e);
        }
    }

/**
     * Ensure the chained job catch callbacks are invoked.
     *
     * @param  string  $uuid
     * @param  mixed  $command
     * @param  \Throwable  $e
     * @return void
     */
    protected function ensureChainCatchCallbacksAreInvoked(string $uuid, $command, $e)
    {
        if (method_exists($command, 'invokeChainCatchCallbacks')) {
            $command->invokeChainCatchCallbacks($e);
        }
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 8 Ã— Files: 26

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
Attributes DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Capsule DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Connectors DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Console DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Events DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Failed DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Jobs DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
Middleware DIR	-	drwxrwxrwx	2025-09-17 06:52:57	Edit Download recursive recursive
BeanstalkdQueue.php	5.92 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
CallQueuedClosure.php	2.50 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
CallQueuedHandler.php	9.25 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
composer.json	1.79 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
DatabaseQueue.php	11.60 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
InteractsWithQueue.php	6.90 KB	lrw-rw-rw-	2025-09-17 06:52:56	Edit Download recursive recursive
InvalidPayloadException.php	552 B	lrw-rw-rw-	2025-09-17 06:52:56	Edit Download recursive recursive
LICENSE.md	1.05 KB	lrw-rw-rw-	2025-09-17 06:52:56	Edit Download recursive recursive
Listener.php	5.62 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
ListenerOptions.php	902 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
LuaScripts.php	4.34 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
ManuallyFailedException.php	125 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
MaxAttemptsExceededException.php	587 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
NullQueue.php	1.39 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
Queue.php	12.11 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
QueueManager.php	6.86 KB	lrw-rw-rw-	2025-09-17 06:52:56	Edit Download recursive recursive
QueueServiceProvider.php	9.91 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
README.md	1.19 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
RedisQueue.php	10.17 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
SerializesAndRestoresModelIdentifiers.php	3.84 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
SerializesModels.php	2.65 KB	lrw-rw-rw-	2025-09-17 06:52:56	Edit Download recursive recursive
SqsQueue.php	5.97 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
SyncQueue.php	4.72 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
TimeoutExceededException.php	437 B	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
Worker.php	25.79 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive
WorkerOptions.php	2.43 KB	lrw-rw-rw-	2025-09-17 06:52:57	Edit Download recursive recursive