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

BF presence count

This commit is contained in:
a6a2f5842 2025-09-19 07:58:57 +02:00
parent 2960c3a3f3
commit d77e38d6f4
1 changed files with 17 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/Channels/OpenPresenceChannel.php
View File

@ -24,24 +24,22 @@ class OpenPresenceChannel extends Channel
{ {
parent::subscribe($connection, $payload); parent::subscribe($connection, $payload);
$this->channelManager $connections = $this->getConnections();
->getLocalConnections()
->then(function ($connections) use ($connection) {
$connection->send(json_encode([
'event' => 'presence.subscription_succeeded',
'channel' => $this->getName(),
'data' => [
'sockets' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->pluck('socketId')->toArray(),
'total_count' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->count(),
],
]));
$this->informPresence($connection, $connections); $connection->send(json_encode([
}); 'event' => 'presence.subscription_succeeded',
'channel' => $this->getName(),
'data' => [
'sockets' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->pluck('socketId')->toArray(),
'total_count' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->count(),
],
]));
$this->informPresence($connection, $connections);
return true; return true;
} }
@ -54,21 +52,11 @@ class OpenPresenceChannel extends Channel
*/ */
public function unsubscribe(ConnectionInterface $connection): PromiseInterface public function unsubscribe(ConnectionInterface $connection): PromiseInterface
{ {
\Log::channel('websocket')->info('Presence unsub');
$truth = parent::unsubscribe($connection); $truth = parent::unsubscribe($connection);
\Log::channel('websocket')->info('Presence unsub 1'); $this->informPresence($connection, $this->getConnections(), true);
return $this->channelManager return $truth;
->getLocalConnections()
->then(function ($connections) use ($connection) {
\Log::channel('websocket')->info('Presence unsub 2 local conn');
$this->informPresence($connection, $connections, true);
})
->then(function () use ($truth) {
return $truth;
});
} }
public function informPresence( public function informPresence(