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

I OpenPresenceChannel

This commit is contained in:
a6a2f5842 2025-09-18 15:23:14 +02:00
parent 2927cc5d6c
commit 32c628a936
1 changed files with 32 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
src/Channels/OpenPresenceChannel.php
View File

@ -40,26 +40,7 @@ class OpenPresenceChannel extends Channel
],
]));
$memberAddedPayload = [
'event' => 'presence.member_added',
'channel' => $this->getName(),
'data' => [
'socket' => $connection->socketId, // added socket
'total_count' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->count(),
],
];
if ($connection->remoteAddress && $connection->remoteAddress != '127.0.0.1') {
$this->broadcastToEveryoneExcept(
(object) $memberAddedPayload,
$connection->socketId,
$connection->app->id,
false
);
}
$this->informPresence($connection, $connections);
});
return true;
@ -75,32 +56,43 @@ class OpenPresenceChannel extends Channel
{
$truth = parent::unsubscribe($connection);
return $this->channelManager
->getLocalConnections()
->then(function ($connections) use ($connection) {
$memberRemovedPayload = [
'event' => 'presence:member_removed',
'channel' => $this->getName(),
'data' => [
'socket' => $connection->socketId,
'total_count' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->count(),
],
];
if ($connection->remoteAddress && $connection->remoteAddress != '127.0.0.1') {
$this->broadcastToEveryoneExcept(
(object) $memberRemovedPayload,
$connection->socketId,
$connection->app->id,
false
);
}
$this->informPresence($connection, $connections, true);
})
->then(function () use ($truth) {
return $truth;
});
}
public function informPresence(
$connection,
$connections,
bool $isLeaving = false
) {
$memberAddedPayload = [
'event' => 'presence.changed',
'channel' => $this->getName(),
'data' => [
($isLeaving ? 'removed' : 'joined') => $connection->socketId,
'total_count' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->count(),
'sockets' => collect($connections)
->filter(fn($conn) => ($conn->remoteAddress && $conn->remoteAddress != '127.0.0.1'))
->pluck('socketId')->toArray(),
],
];
if ($connection->remoteAddress && $connection->remoteAddress != '127.0.0.1') {
$this->broadcastToEveryoneExcept(
(object) $memberAddedPayload,
$connection->socketId,
$connection->app->id,
false
);
}
}
}