blax-software
/
laravel-websockets
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Attempt at making TriggerEventController also publish to other servers

This commit is contained in:
Francis Lavoie 2019-07-29 17:39:34 -04:00
parent 091f56ea15
commit ef86f86668
No known key found for this signature in database
GPG Key ID: B9E0E04A76AF4692
2 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/PubSub/Drivers/RedisClient.php
View File

@ -117,7 +117,7 @@ class RedisClient implements ReplicationInterface
unset($payload->appId); unset($payload->appId);
// Push the message out to connected websocket clients // Push the message out to connected websocket clients
$channel->broadcastToEveryoneExcept($payload, $socket); $channel->broadcastToEveryoneExcept($payload, $socket, $appId, false);
} }
/** /**

15
src/WebSockets/Channels/Channel.php
View File

@ -110,14 +110,19 @@ class Channel
public function broadcastToOthers(ConnectionInterface $connection, $payload) public function broadcastToOthers(ConnectionInterface $connection, $payload)
{ {
// Also broadcast via the other websocket servers $this->broadcastToEveryoneExcept($payload, $connection->socketId, $connection->app->id);
$this->replication->publish($connection->app->id, $this->channelName, $payload);
$this->broadcastToEveryoneExcept($payload, $connection->socketId);
} }
public function broadcastToEveryoneExcept($payload, ?string $socketId = null) public function broadcastToEveryoneExcept($payload, ?string $socketId, string $appId, bool $publish = true)
{ {
// Also broadcast via the other websocket server instances.
// This is set false in the Redis client because we don't want to cause a loop
// in this case. If this came from TriggerEventController, then we still want
// to publish to get the message out to other server instances.
if ($publish) {
$this->replication->publish($appId, $this->channelName, $payload);
}
// Performance optimization, if we don't have a socket ID, // Performance optimization, if we don't have a socket ID,
// then we avoid running the if condition in the foreach loop below // then we avoid running the if condition in the foreach loop below
// by calling broadcast() instead. // by calling broadcast() instead.