From b8c3ae6fe4a46914f40020aedfbc6bf25bb9bcff Mon Sep 17 00:00:00 2001 From: Marcel Pociot Date: Thu, 22 Nov 2018 09:30:11 +0100 Subject: [PATCH] wip --- src/LaravelEcho/Pusher/Channels/Channel.php | 2 +- src/LaravelEcho/WebSocket/RespondableMessageFactory.php | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/LaravelEcho/Pusher/Channels/Channel.php b/src/LaravelEcho/Pusher/Channels/Channel.php index 2e8d728..847e7b3 100644 --- a/src/LaravelEcho/Pusher/Channels/Channel.php +++ b/src/LaravelEcho/Pusher/Channels/Channel.php @@ -26,7 +26,7 @@ class Channel /* * @link https://pusher.com/docs/pusher_protocol#presence-channel-events */ - public function subscribe(ConnectionInterface $connection) + public function subscribe(ConnectionInterface $connection, $payload) { $this->saveConnection($connection); diff --git a/src/LaravelEcho/WebSocket/RespondableMessageFactory.php b/src/LaravelEcho/WebSocket/RespondableMessageFactory.php index 6bbbdec..c5be9a5 100644 --- a/src/LaravelEcho/WebSocket/RespondableMessageFactory.php +++ b/src/LaravelEcho/WebSocket/RespondableMessageFactory.php @@ -16,6 +16,9 @@ class RespondableMessageFactory { $payload = json_decode($message->getPayload()); + // Log this for now + dump($payload); + return starts_with($payload->event, 'pusher:') ? new PusherMessage($payload, $connection, $channelManager) : new Message($payload, $connection, $channelManager);