webshell

Ghost Exploiter Team Official

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

File / Folder	Size	Action
.	-
Broadcasters	--	ren
BroadcastController.php	1.146KB	edt ren
BroadcastEvent.php	3.792KB	edt ren
BroadcastException.php	0.124KB	edt ren
BroadcastManager.php	12.111KB	edt ren
BroadcastServiceProvide...	1.109KB	edt ren
Channel.php	0.673KB	edt ren
EncryptedPrivateChannel...	0.304KB	edt ren
InteractsWithBroadcasti...	0.832KB	edt ren
InteractsWithSockets.php	0.653KB	edt ren
LICENSE.md	1.05KB	edt ren
PendingBroadcast.php	1.467KB	edt ren
PresenceChannel.php	0.287KB	edt ren
PrivateChannel.php	0.486KB	edt ren
UniqueBroadcastEvent.php	1.498KB	edt ren
composer.json	1.273KB	edt ren

<?php

namespace Illuminate\Broadcasting;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Broadcasting\Factory as BroadcastingFactory;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Contracts\Support\Arrayable;
use Illuminate\Support\Arr;
use ReflectionClass;
use ReflectionProperty;

class BroadcastEvent implements ShouldQueue
{
    use Queueable;

/**
     * The event instance.
     *
     * @var mixed
     */
    public $event;

/**
     * The number of times the job may be attempted.
     *
     * @var int
     */
    public $tries;

/**
     * The number of seconds the job can run before timing out.
     *
     * @var int
     */
    public $timeout;

/**
     * The number of seconds to wait before retrying the job when encountering an uncaught exception.
     *
     * @var int
     */
    public $backoff;

/**
     * The maximum number of unhandled exceptions to allow before failing.
     *
     * @var int
     */
    public $maxExceptions;

/**
     * Create a new job handler instance.
     *
     * @param  mixed  $event
     * @return void
     */
    public function __construct($event)
    {
        $this->event = $event;
        $this->tries = property_exists($event, 'tries') ? $event->tries : null;
        $this->timeout = property_exists($event, 'timeout') ? $event->timeout : null;
        $this->backoff = property_exists($event, 'backoff') ? $event->backoff : null;
        $this->afterCommit = property_exists($event, 'afterCommit') ? $event->afterCommit : null;
        $this->maxExceptions = property_exists($event, 'maxExceptions') ? $event->maxExceptions : null;
    }

/**
     * Handle the queued job.
     *
     * @param  \Illuminate\Contracts\Broadcasting\Factory  $manager
     * @return void
     */
    public function handle(BroadcastingFactory $manager)
    {
        $name = method_exists($this->event, 'broadcastAs')
                ? $this->event->broadcastAs() : get_class($this->event);

$channels = Arr::wrap($this->event->broadcastOn());

if (empty($channels)) {
            return;
        }

$connections = method_exists($this->event, 'broadcastConnections')
                            ? $this->event->broadcastConnections()
                            : [null];

$payload = $this->getPayloadFromEvent($this->event);

foreach ($connections as $connection) {
            $manager->connection($connection)->broadcast(
                $channels, $name, $payload
            );
        }
    }

/**
     * Get the payload for the given event.
     *
     * @param  mixed  $event
     * @return array
     */
    protected function getPayloadFromEvent($event)
    {
        if (method_exists($event, 'broadcastWith') &&
            ! is_null($payload = $event->broadcastWith())) {
            return array_merge($payload, ['socket' => data_get($event, 'socket')]);
        }

$payload = [];

foreach ((new ReflectionClass($event))->getProperties(ReflectionProperty::IS_PUBLIC) as $property) {
            $payload[$property->getName()] = $this->formatProperty($property->getValue($event));
        }

unset($payload['broadcastQueue']);

return $payload;
    }

/**
     * Format the given value for a property.
     *
     * @param  mixed  $value
     * @return mixed
     */
    protected function formatProperty($value)
    {
        if ($value instanceof Arrayable) {
            return $value->toArray();
        }

return $value;
    }

/**
     * Get the display name for the queued job.
     *
     * @return string
     */
    public function displayName()
    {
        return get_class($this->event);
    }

/**
     * Prepare the instance for cloning.
     *
     * @return void
     */
    public function __clone()
    {
        $this->event = clone $this->event;
    }
}

<=Back