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 realtime

Browse Source
This commit is contained in:
ArnabChatterjee20k
2026-04-16 18:11:01 +05:30
parent 4fea92c9cb
commit a480d8ed73
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/realtime.php
+14 -2
View File
@@ -30,6 +30,7 @@ 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;
@@ -1224,8 +1225,19 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
if ($presenceId !== 'unique()') {
$presenceDocument->setAttribute('$id', $presenceId);
}
$presence = $database->upsertDocument('presenceLogs', $presenceDocument);
/** @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])]);
$presenceDocument->setAttribute('$id', $existingPresence->getId());
$presence = $database->upsertDocument('presenceLogs', $presenceDocument);
}
$presence->removeAttribute('hostname');