Added broadcastLocallyToEveryoneExcept

beyondcode · Sep 18, 2020 · 9856fb6 · 9856fb6
1 parent bab2ef2
commit 9856fb6
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/src/ChannelManagers/RedisChannelManager.php b/src/ChannelManagers/RedisChannelManager.php
@@ -462,7 +462,7 @@ public function onMessage(string $redisChannel, string $payload)
         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
@@ -164,6 +164,21 @@ public function broadcastToEveryoneExcept(stdClass $payload, ?string $socketId,
         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.
      *