diff --git a/src/API/TriggerEvent.php b/src/API/TriggerEvent.php index 9f66e63..853274e 100644 --- a/src/API/TriggerEvent.php +++ b/src/API/TriggerEvent.php @@ -45,7 +45,7 @@ class TriggerEvent extends Controller ); } else { $this->channelManager->broadcastAcrossServers( - $request->appId, $channelName, (object) $payload + $request->appId, $request->socket_id, $channelName, (object) $payload ); } diff --git a/src/ChannelManagers/LocalChannelManager.php b/src/ChannelManagers/LocalChannelManager.php index 5d33f83..980ee61 100644 --- a/src/ChannelManagers/LocalChannelManager.php +++ b/src/ChannelManagers/LocalChannelManager.php @@ -259,11 +259,13 @@ class LocalChannelManager implements ChannelManager * Broadcast the message across multiple servers. * * @param string|int $appId + * @param string|null $socketId * @param string $channel * @param stdClass $payload + * @param string|null $serverId * @return bool */ - public function broadcastAcrossServers($appId, string $channel, stdClass $payload) + public function broadcastAcrossServers($appId, ?string $socketId, string $channel, stdClass $payload, string $serverId = null) { return true; } diff --git a/src/ChannelManagers/RedisChannelManager.php b/src/ChannelManagers/RedisChannelManager.php index 452aab7..9c24c92 100644 --- a/src/ChannelManagers/RedisChannelManager.php +++ b/src/ChannelManagers/RedisChannelManager.php @@ -268,14 +268,17 @@ class RedisChannelManager extends LocalChannelManager * Broadcast the message across multiple servers. * * @param string|int $appId + * @param string|null $socketId * @param string $channel * @param stdClass $payload + * @param string|null $serverId * @return bool */ - public function broadcastAcrossServers($appId, string $channel, stdClass $payload) + public function broadcastAcrossServers($appId, ?string $socketId, string $channel, stdClass $payload, string $serverId = null) { $payload->appId = $appId; - $payload->serverId = $this->getServerId(); + $payload->socketId = $socketId; + $payload->serverId = $serverId ?: $this->getServerId(); $this->publishClient->publish($this->getRedisKey($appId, $channel), json_encode($payload)); diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php index e7e5377..126b6c7 100644 --- a/src/Channels/Channel.php +++ b/src/Channels/Channel.php @@ -130,7 +130,7 @@ class Channel ->each->send(json_encode($payload)); if ($replicate) { - $this->channelManager->broadcastAcrossServers($appId, $this->getName(), $payload); + $this->channelManager->broadcastAcrossServers($appId, null, $this->getName(), $payload); } return true; @@ -148,7 +148,7 @@ class Channel public function broadcastToEveryoneExcept(stdClass $payload, ?string $socketId, $appId, bool $replicate = true) { if ($replicate) { - $this->channelManager->broadcastAcrossServers($appId, $this->getName(), $payload); + $this->channelManager->broadcastAcrossServers($appId, $socketId, $this->getName(), $payload); } if (is_null($socketId)) { diff --git a/src/Contracts/ChannelManager.php b/src/Contracts/ChannelManager.php index 5f1f358..01d4a2c 100644 --- a/src/Contracts/ChannelManager.php +++ b/src/Contracts/ChannelManager.php @@ -131,11 +131,13 @@ interface ChannelManager * Broadcast the message across multiple servers. * * @param string|int $appId + * @param string|null $socketId * @param string $channel * @param stdClass $payload + * @param string|null $serverId * @return bool */ - public function broadcastAcrossServers($appId, string $channel, stdClass $payload); + public function broadcastAcrossServers($appId, ?string $socketId, string $channel, stdClass $payload, string $serverId = null); /** * Handle the user when it joined a presence channel. diff --git a/src/DashboardLogger.php b/src/DashboardLogger.php index 046d6ff..07e8547 100644 --- a/src/DashboardLogger.php +++ b/src/DashboardLogger.php @@ -90,7 +90,7 @@ class DashboardLogger ); } else { $channelManager->broadcastAcrossServers( - $appId, $channelName, (object) $payload + $appId, null, $channelName, (object) $payload ); } }