39 lines
981 B
PHP
39 lines
981 B
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace BeyondCode\LaravelWebSockets\LaravelEcho\WebSocket;
|
||
|
|
|
||
|
|
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()
|
||
|
|
{
|
||
|
|
$channel = $this->channelManager->find($this->connection->appId, $this->payload->channel);
|
||
|
|
|
||
|
|
if (!$channel) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
$channel->broadcast($this->payload);
|
||
|
|
}
|
||
|
|
}
|