diff --git a/src/WebSockets/Messages/PusherMessage.php b/src/WebSockets/Messages/PusherChannelProtocolMessage.php similarity index 96% rename from src/WebSockets/Messages/PusherMessage.php rename to src/WebSockets/Messages/PusherChannelProtocolMessage.php index d861ba7..e19bfcf 100644 --- a/src/WebSockets/Messages/PusherMessage.php +++ b/src/WebSockets/Messages/PusherChannelProtocolMessage.php @@ -6,7 +6,7 @@ use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager; use Ratchet\ConnectionInterface; use stdClass; -class PusherMessage implements RespondableMessage +class PusherChannelProtocolMessage implements RespondableMessage { /** @var \stdClass */ protected $payload; diff --git a/src/WebSockets/Messages/Message.php b/src/WebSockets/Messages/PusherClientMessage.php similarity index 95% rename from src/WebSockets/Messages/Message.php rename to src/WebSockets/Messages/PusherClientMessage.php index f3a3166..9d50a10 100644 --- a/src/WebSockets/Messages/Message.php +++ b/src/WebSockets/Messages/PusherClientMessage.php @@ -8,7 +8,7 @@ use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager; use Ratchet\ConnectionInterface; use stdClass; -class Message implements RespondableMessage +class PusherClientMessage implements RespondableMessage { /** \stdClass */ protected $payload; diff --git a/src/WebSockets/Messages/RespondableMessageFactory.php b/src/WebSockets/Messages/RespondableMessageFactory.php index 1ffd7fe..bd8f7f8 100644 --- a/src/WebSockets/Messages/RespondableMessageFactory.php +++ b/src/WebSockets/Messages/RespondableMessageFactory.php @@ -16,7 +16,7 @@ class RespondableMessageFactory $payload = json_decode($message->getPayload()); return starts_with($payload->event, 'pusher:') - ? new PusherMessage($payload, $connection, $channelManager) - : new Message($payload, $connection, $channelManager); + ? new PusherChannelProtocolMessage($payload, $connection, $channelManager) + : new PusherClientMessage($payload, $connection, $channelManager); } } \ No newline at end of file