laravel-websockets/src/LaravelEcho/WebSocket/Message.php

<?php

namespace BeyondCode\LaravelWebSockets\LaravelEcho\WebSocket;

use BeyondCode\LaravelWebSockets\Events\ClientMessageSent;
use BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Channels\ChannelManager;
use Ratchet\ConnectionInterface;
use stdClass;

class Message implements RespondableMessage
{
    /** \stdClass */
    protected $payload;

    /** @var \Ratchet\ConnectionInterface */
    protected $connection;

    /** @var \BeyondCode\LaravelWebSockets\LaravelEcho\Pusher\Channels\ChannelManager */
    protected $channelManager;

    public function __construct(stdClass $payload, ConnectionInterface $connection, ChannelManager $channelManager)
    {
        $this->payload = $payload;

        $this->connection = $connection;

        $this->channelManager = $channelManager;
    }

    public function respond()
    {
        if (!starts_with($this->payload->event, 'client-')) {
            return;
        }

        event(new ClientMessageSent($this->connection, $this->payload));

        $channel = $this->channelManager->find($this->connection->client->appId, $this->payload->channel);

        optional($channel)->broadcast($this->payload);
    }
}