<form method="POST">
    <h3>Editing: PusherBroadcaster.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

namespace Illuminate\Broadcasting\Broadcasters;

use Illuminate\Broadcasting\BroadcastException;
use Illuminate\Support\Arr;
use Illuminate\Support\Str;
use Pusher\ApiErrorException;
use Pusher\Pusher;
use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;

class PusherBroadcaster extends Broadcaster
{
    use UsePusherChannelConventions;

    /**
     * The Pusher SDK instance.
     *
     * @var \Pusher\Pusher
     */
    protected $pusher;

    /**
     * Create a new broadcaster instance.
     *
     * @param  \Pusher\Pusher  $pusher
     * @return void
     */
    public function __construct(Pusher $pusher)
    {
        $this-&gt;pusher = $pusher;
    }

    /**
     * Authenticate the incoming request for a given channel.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return mixed
     *
     * @throws \Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException
     */
    public function auth($request)
    {
        $channelName = $this-&gt;normalizeChannelName($request-&gt;channel_name);

        if (empty($request-&gt;channel_name) ||
            ($this-&gt;isGuardedChannel($request-&gt;channel_name) &amp;&amp;
            ! $this-&gt;retrieveUser($request, $channelName))) {
            throw new AccessDeniedHttpException;
        }

        return parent::verifyUserCanAccessChannel(
            $request, $channelName
        );
    }

    /**
     * Return the valid authentication response.
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  mixed  $result
     * @return mixed
     */
    public function validAuthenticationResponse($request, $result)
    {
        if (Str::startsWith($request-&gt;channel_name, 'private')) {
            return $this-&gt;decodePusherResponse(
                $request, $this-&gt;pusher-&gt;socket_auth($request-&gt;channel_name, $request-&gt;socket_id)
            );
        }

        $channelName = $this-&gt;normalizeChannelName($request-&gt;channel_name);

        $user = $this-&gt;retrieveUser($request, $channelName);

        $broadcastIdentifier = method_exists($user, 'getAuthIdentifierForBroadcasting')
                        ? $user-&gt;getAuthIdentifierForBroadcasting()
                        : $user-&gt;getAuthIdentifier();

        return $this-&gt;decodePusherResponse(
            $request,
            $this-&gt;pusher-&gt;presence_auth(
                $request-&gt;channel_name, $request-&gt;socket_id,
                $broadcastIdentifier, $result
            )
        );
    }

    /**
     * Decode the given Pusher response.
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  mixed  $response
     * @return array
     */
    protected function decodePusherResponse($request, $response)
    {
        if (! $request-&gt;input('callback', false)) {
            return json_decode($response, true);
        }

        return response()-&gt;json(json_decode($response, true))
                    -&gt;withCallback($request-&gt;callback);
    }

    /**
     * Broadcast the given event.
     *
     * @param  array  $channels
     * @param  string  $event
     * @param  array  $payload
     * @return void
     *
     * @throws \Illuminate\Broadcasting\BroadcastException
     */
    public function broadcast(array $channels, $event, array $payload = [])
    {
        $socket = Arr::pull($payload, 'socket');

        if ($this-&gt;pusherServerIsVersionFiveOrGreater()) {
            $parameters = $socket !== null ? ['socket_id' =&gt; $socket] : [];

            try {
                $this-&gt;pusher-&gt;trigger(
                    $this-&gt;formatChannels($channels), $event, $payload, $parameters
                );
            } catch (ApiErrorException $e) {
                throw new BroadcastException(
                    sprintf('Pusher error: %s.', $e-&gt;getMessage())
                );
            }
        } else {
            $response = $this-&gt;pusher-&gt;trigger(
                $this-&gt;formatChannels($channels), $event, $payload, $socket, true
            );

            if ((is_array($response) &amp;&amp; $response['status'] &gt;= 200 &amp;&amp; $response['status'] &lt;= 299)
                || $response === true) {
                return;
            }

            throw new BroadcastException(
                ! empty($response['body'])
                    ? sprintf('Pusher error: %s.', $response['body'])
                    : 'Failed to connect to Pusher.'
            );
        }
    }

    /**
     * Determine if the Pusher PHP server is version 5.0 or greater.
     *
     * @return bool
     */
    protected function pusherServerIsVersionFiveOrGreater()
    {
        return class_exists(ApiErrorException::class);
    }

    /**
     * Get the Pusher SDK instance.
     *
     * @return \Pusher\Pusher
     */
    public function getPusher()
    {
        return $this-&gt;pusher;
    }

    /**
     * Set the Pusher SDK instance.
     *
     * @param  \Pusher\Pusher  $pusher
     * @return void
     */
    public function setPusher($pusher)
    {
        $this-&gt;pusher = $pusher;
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>