| Server IP : 78.140.185.180 / Your IP : 18.219.224.246 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/public_html/vendor/laravel/horizon/src/ |
Upload File : |
<?php
namespace Laravel\Horizon;
use ArrayAccess;
use Illuminate\Broadcasting\BroadcastEvent;
use Illuminate\Events\CallQueuedListener;
use Illuminate\Mail\SendQueuedMailable;
use Illuminate\Notifications\SendQueuedNotifications;
use Illuminate\Support\Arr;
class JobPayload implements ArrayAccess
{
/**
* The raw payload string.
*
* @var string
*/
public $value;
/**
* The decoded payload array.
*
* @var array
*/
public $decoded;
/**
* Create a new raw job payload instance.
*
* @param string $value
* @return void
*/
public function __construct($value)
{
$this->value = $value;
$this->decoded = json_decode($value, true);
}
/**
* Get the job ID from the payload.
*
* @return string
*/
public function id()
{
return $this->decoded['uuid'] ?? $this->decoded['id'];
}
/**
* Get the job tags from the payload.
*
* @return array
*/
public function tags()
{
return Arr::get($this->decoded, 'tags', []);
}
/**
* Determine if the job is a retry of a previous job.
*
* @return bool
*/
public function isRetry()
{
return isset($this->decoded['retry_of']);
}
/**
* Get the ID of the job this job is a retry of.
*
* @return string|null
*/
public function retryOf()
{
return $this->decoded['retry_of'] ?? null;
}
/**
* Prepare the payload for storage on the queue by adding tags, etc.
*
* @param mixed $job
* @return $this
*/
public function prepare($job)
{
return $this->set([
'type' => $this->determineType($job),
'tags' => $this->determineTags($job),
'pushedAt' => str_replace(',', '.', microtime(true)),
]);
}
/**
* Get the "type" of job being queued.
*
* @param mixed $job
* @return string
*/
protected function determineType($job)
{
switch (true) {
case $job instanceof BroadcastEvent:
return 'broadcast';
case $job instanceof CallQueuedListener:
return 'event';
case $job instanceof SendQueuedMailable:
return 'mail';
case $job instanceof SendQueuedNotifications:
return 'notification';
default:
return 'job';
}
}
/**
* Get the appropriate tags for the job.
*
* @param mixed $job
* @return array
*/
protected function determineTags($job)
{
return array_merge(
$this->decoded['tags'] ?? [],
! $job || is_string($job) ? [] : Tags::for($job)
);
}
/**
* Set the given key / value pairs on the payload.
*
* @param array $values
* @return $this
*/
public function set(array $values)
{
$this->decoded = array_merge($this->decoded, $values);
$this->value = json_encode($this->decoded);
return $this;
}
/**
* Get the "command name" for the job.
*
* @return string
*/
public function commandName()
{
return Arr::get($this->decoded, 'data.commandName');
}
/**
* Get the "display name" for the job.
*
* @return string
*/
public function displayName()
{
return Arr::get($this->decoded, 'displayName');
}
/**
* Determine if the given offset exists.
*
* @param string $offset
* @return bool
*/
public function offsetExists($offset)
{
return array_key_exists($offset, $this->decoded);
}
/**
* Get the value at the current offset.
*
* @param string $offset
* @return mixed
*/
public function offsetGet($offset)
{
return $this->decoded[$offset];
}
/**
* Set the value at the current offset.
*
* @param string $offset
* @param mixed $value
* @return void
*/
public function offsetSet($offset, $value)
{
$this->decoded[$offset] = $value;
}
/**
* Unset the value at the current offset.
*
* @param string $offset
* @return void
*/
public function offsetUnset($offset)
{
unset($this->decoded[$offset]);
}
}