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

BF subscribe & I logging

This commit is contained in:
a6a2f5842 2025-09-16 08:54:13 +02:00
parent c53c9d3bbd
commit df349aabf7
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Websocket/Handler.php
View File

@ -123,7 +123,7 @@ class Handler implements MessageComponentInterface
$this->authenticateConnection($connection, $channel, $message); $this->authenticateConnection($connection, $channel, $message);
Log::channel('websocket')->info('Executing event: ' . $message['event']); \Log::channel('websocket')->info('['.$connection->socketId.']@'.$channel->getName().' | ' . json_encode($message));
if (strpos($message['event'], 'pusher') !== false) { if (strpos($message['event'], 'pusher') !== false) {
return $connection->send(json_encode([ return $connection->send(json_encode([
@ -360,7 +360,7 @@ class Handler implements MessageComponentInterface
unset($message['data']['channel']); unset($message['data']['channel']);
} }
$channel = $this->channelManager->findOrCreate( $this->channelManager->findOrCreate(
$connection->app->id, $connection->app->id,
$message['channel'] $message['channel']
); );
@ -382,7 +382,10 @@ class Handler implements MessageComponentInterface
} }
// if not in $channel_connections add it // if not in $channel_connections add it
if (strpos($message['event'], '.subscribe') !== false) { if (
(strtolower($message['event']) === 'pusher.subscribe')
|| (strtolower($message['event']) === 'pusher:subscribe')
) {
if (! isset($this->channel_connections[$channel_name])) { if (! isset($this->channel_connections[$channel_name])) {
$this->channel_connections[$channel_name] = []; $this->channel_connections[$channel_name] = [];
} }
@ -432,8 +435,6 @@ class Handler implements MessageComponentInterface
'ws_active_channels', 'ws_active_channels',
array_keys($this->channel_connections) array_keys($this->channel_connections)
); );
Log::channel('websocket')->info('Tenant left', ['socketId' => $socket_id, 'channel' => $channel_name]);
} }
return $channel; return $channel;