diff --git a/src/WebSockets/Messages/PusherClientMessage.php b/src/WebSockets/Messages/PusherClientMessage.php index 40f02a6..656737d 100644 --- a/src/WebSockets/Messages/PusherClientMessage.php +++ b/src/WebSockets/Messages/PusherClientMessage.php @@ -42,6 +42,6 @@ class PusherClientMessage implements PusherMessage $channel = $this->channelManager->find($this->connection->app->id, $this->payload->channel); - optional($channel)->broadcast($this->payload); + optional($channel)->broadcastToOthers($this->connection, $this->payload); } } \ No newline at end of file diff --git a/tests/Messages/PusherClientMessageTest.php b/tests/Messages/PusherClientMessageTest.php index 88b9e55..d16d640 100644 --- a/tests/Messages/PusherClientMessageTest.php +++ b/tests/Messages/PusherClientMessageTest.php @@ -39,7 +39,8 @@ class PusherClientMessageTest extends TestCase ], ]); - $connection = $this->getConnectedWebSocketConnection(['test-channel']); + $connection1 = $this->getConnectedWebSocketConnection(['test-channel']); + $connection2 = $this->getConnectedWebSocketConnection(['test-channel']); $message = new Message(json_encode([ 'event' => 'client-test', @@ -49,9 +50,11 @@ class PusherClientMessageTest extends TestCase ], ])); - $this->pusherServer->onMessage($connection, $message); + $this->pusherServer->onMessage($connection1, $message); - $connection->assertSentEvent('client-test', [ + $connection1->assertNotSentEvent('client-test'); + + $connection2->assertSentEvent('client-test', [ 'data' => [ 'client-event' => 'test' ]