Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

updated the queue for event propagation

Browse Source
This commit is contained in:
ArnabChatterjee20k
2026-05-05 11:35:49 +05:30
parent 8cef822e8f
commit b0a2ef271a
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/realtime.php
+13 -13
View File
@@ -322,14 +322,8 @@ if (!function_exists('triggerPresenceUsage')) {
if (!function_exists('getQueueForEventsForProject')) {
function getQueueForEventsForProject(Document $project, User $user): QueueEvent
{
global $register;
/** @var Group $pools */
$pools = $register->get('pools');
$queueForEvents = new QueueEvent(new BrokerPool(
publisher: $pools->get('publisher')
));
global $container;
$queueForEvents = $container->get('queueForEvents');
$queueForEvents->setProject($project);
$queueForEvents->setUser($user);
@@ -340,8 +334,6 @@ if (!function_exists('getQueueForEventsForProject')) {
if (!function_exists('triggerPresenceEvent')) {
function triggerPresenceEvent(
Server $server,
Realtime $realtime,
Document $project,
User $user,
string $eventName,
@@ -407,9 +399,17 @@ if (!function_exists('setPermission')) {
}
global $container;
$container->set('pools', function ($register) {
return $register->get('pools');
}, ['register']);
$container->set('queueForEvents', function ($pools) {
return new QueueEvent(new BrokerPool(
publisher: $pools->get('publisher')
));
}, ['pools']);
$container->set('queueForRealtime', function () {
return new QueueRealtime();
}, []);
@@ -1559,7 +1559,7 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
}
}
triggerPresenceEvent($server, $realtime, $project, $user, 'presences.[presenceId].upsert', $presence);
triggerPresenceEvent($project, $user, 'presences.[presenceId].upsert', $presence);
break;
@@ -1613,7 +1613,7 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
}
});
$server->onClose(function (int $connection) use ($server, $realtime, $stats, $register) {
$server->onClose(function (int $connection) use ($realtime, $stats, $register) {
$projectId = null;
$userId = null;
$subscriptionsBeforeClose = 0;
@@ -1670,7 +1670,7 @@ $server->onClose(function (int $connection) use ($server, $realtime, $stats, $re
foreach ($presences as $presence) {
try {
triggerPresenceEvent($server, $realtime, $project, new User([]), 'presences.[presenceId].delete', $presence);
triggerPresenceEvent($project, new User([]), 'presences.[presenceId].delete', $presence);
} catch (Throwable) {
// Swallow errors to avoid breaking disconnect cleanup
}