From 9856fb62ed26a29a443974a0e3692d927ecf3f13 Mon Sep 17 00:00:00 2001 From: Alex Renoki Date: Fri, 18 Sep 2020 11:57:55 +0300 Subject: [PATCH] Added broadcastLocallyToEveryoneExcept --- src/ChannelManagers/RedisChannelManager.php | 2 +- src/Channels/Channel.php | 15 +++++++++++++++ 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/src/ChannelManagers/RedisChannelManager.php b/src/ChannelManagers/RedisChannelManager.php index 9c24c92..3d79156 100644 --- a/src/ChannelManagers/RedisChannelManager.php +++ b/src/ChannelManagers/RedisChannelManager.php @@ -462,7 +462,7 @@ class RedisChannelManager extends LocalChannelManager unset($payload->serverId); unset($payload->appId); - $channel->broadcastToEveryoneExcept($payload, $socketId, $appId, false); + $channel->broadcastLocallyToEveryoneExcept($payload, $socketId, $appId); } /** diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php index 126b6c7..476f51f 100644 --- a/src/Channels/Channel.php +++ b/src/Channels/Channel.php @@ -164,6 +164,21 @@ class Channel return true; } + /** + * Broadcast the payload, but exclude a specific socket id. + * + * @param \stdClass $payload + * @param string|null $socketId + * @param string|int $appId + * @return bool + */ + public function broadcastLocallyToEveryoneExcept(stdClass $payload, ?string $socketId, $appId) + { + return $this->broadcastToEveryoneExcept( + $payload, $socketId, $appId, false + ); + } + /** * Check if the signature for the payload is valid. *