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 presence helper

Browse Source
This commit is contained in:
ArnabChatterjee20k
2026-04-17 12:01:56 +05:30
parent ee34e2b587
commit 0d2a4da347
2 changed files with 9 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/realtime.php
+5 -18
View File
@@ -1,5 +1,6 @@
<?php
use Appwrite\Databases\PresenceState;
use Appwrite\Event\Event as QueueEvent;
use Appwrite\Event\Realtime as QueueRealtime;
use Appwrite\Extend\Exception;
@@ -30,7 +31,6 @@ use Utopia\Database\Adapter\Pool as DatabasePool;
use Utopia\Database\Database;
use Utopia\Database\DateTime;
use Utopia\Database\Document;
use Utopia\Database\Exception\Duplicate;
use Utopia\Database\Exception\Query as QueryException;
use Utopia\Database\Helpers\ID;
use Utopia\Database\Helpers\Permission;
@@ -336,6 +336,7 @@ $container->set('pools', function ($register) {
}, ['register']);
$realtime = getRealtime();
$presenceState = new PresenceState();
/**
* Table for statistics across all workers.
@@ -915,7 +916,7 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server,
}
});
$server->onMessage(function (int $connection, string $message) use ($server, $realtime, $containerId) {
$server->onMessage(function (int $connection, string $message) use ($server, $realtime, $containerId, $presenceState) {
$project = null;
$authorization = null;
try {
@@ -1219,24 +1220,10 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
$presenceData['metadata'] = $message['data']['metadata'];
}
$presenceDocument = new Document($presenceData);
setPermission($presenceDocument, $message['data']['permissions'] ?? null, $authorization);
$presenceState->setPermissions($presenceDocument, $message['data']['permissions'] ?? null, $user, $authorization);
$presenceId = $message['data']['presenceId'] ?? 'unique()';
if ($presenceId !== 'unique()') {
$presenceDocument->setAttribute('$id', $presenceId);
}
/** @var Document|null $presence */
$presence = null;
try {
$presence = $database->upsertDocument('presenceLogs', $presenceDocument);
} catch (Duplicate $th) {
// will be triggerd in case of mongodb adapter everytime as $id needs to be same as well here
// in mongodb , upsert works on basis of set and unset by comparing the document with the existing one
// if presenceId differs then it will create a new document and not update the existing one
// TODO: send better error message telling about the presenceId mismatch
$existingPresence = $database->findOne('presenceLogs', [Query::equal('userId', [$userId])]);
$presence = $database->updateDocument('presenceLogs', $existingPresence->getId(), $presenceDocument);
}
$presence = $presenceState->upsertForUser($database, $presenceDocument, $presenceId, $userId);
$presence->removeAttribute('hostname');
src/Appwrite/Platform/Modules/Presences/HTTP/Upsert.php
+4 -16
View File
@@ -2,6 +2,7 @@
namespace Appwrite\Platform\Modules\Presences\HTTP;
use Appwrite\Databases\PresenceState;
use Appwrite\Event\Event;
use Appwrite\Extend\Exception;
use Appwrite\Platform\Modules\Presences\HTTP\Action as PresenceAction;
@@ -13,7 +14,6 @@ use Appwrite\Utopia\Response;
use Utopia\Database\Database;
use Utopia\Database\DateTime;
use Utopia\Database\Document;
use Utopia\Database\Exception\Duplicate;
use Utopia\Database\Validator\Authorization;
use Utopia\Database\Validator\Datetime as DatetimeValidator;
use Utopia\Database\Validator\Permissions;
@@ -120,22 +120,10 @@ class Upsert extends PresenceAction
'metadata' => $metadata,
];
$presenceState = new PresenceState();
$presenceDocument = new Document($presenceData);
$this->setPermission($presenceDocument, $permissions, $user, $authorization);
if ($presenceId !== 'unique()') {
$presenceDocument->setAttribute('$id', $presenceId);
}
try {
$presence = $dbForProject->upsertDocument('presenceLogs', $presenceDocument);
} catch (Duplicate $th) {
// will be triggerd in case of mongodb adapter everytime as $id needs to be same as well here
// in mongodb , upsert works on basis of set and unset by comparing the document with the existing one
// if presenceId differs then it will create a new document and not update the existing one
// TODO: send better error message telling about the presenceId mismatch
$existingPresence = $dbForProject->findOne('presenceLogs', [Query::equal('userId', [$userId])]);
$presence = $dbForProject->updateDocument('presenceLogs', $existingPresence->getId(), $presenceDocument);
}
$presenceState->setPermissions($presenceDocument, $permissions, $user, $authorization);
$presence = $presenceState->upsertForUser($dbForProject, $presenceDocument, $presenceId, $resolvedUserId);
$queueForEvents->setParam('presenceId', $presence->getId());
$response->dynamic($presence, Response::MODEL_PRESENCE);