expectException(InvalidSignature::class); $connection = $this->getWebSocketConnection(); $message = new Message(json_encode([ 'event' => 'pusher:subscribe', 'data' => [ 'auth' => 'invalid', 'channel' => 'private-channel' ], ])); $this->pusherServer->onOpen($connection); $this->pusherServer->onMessage($connection, $message); } /** @test */ public function clients_with_valid_auth_signatures_can_join_private_channels() { $connection = $this->getWebSocketConnection(); $this->pusherServer->onOpen($connection); $signature = "{$connection->socketId}:private-channel"; $message = new Message(json_encode([ 'event' => 'pusher:subscribe', 'data' => [ 'auth' => $connection->client->appKey.':'.hash_hmac('sha256', $signature, $connection->client->appSecret), 'channel' => 'private-channel' ], ])); $this->pusherServer->onMessage($connection, $message); $connection->assertSentEvent('pusher_internal:subscription_succeeded', [ 'channel' => 'private-channel' ]); } }