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

Potential fix for pull request finding

Browse Source 
Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>
This commit is contained in:
Jake Barnby
2026-05-19 18:24:06 +12:00
committed by GitHub
co-authored by Copilot Autofix powered by AI
parent 52b8e1b94d
commit c28f476462
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/realtime.php
+12 -6
View File
@@ -1086,13 +1086,19 @@ $server->onMessage(function (int $connection, string $message) use ($container,
if (!empty($projectId) && $projectId !== 'console') {
// Negative-cache race: if any prior code path queried projects:$projectId
// before this project existed (e.g. a router probe during connection
// setup), the Database's shared cache may hold an empty result. HTTP
// worker creates the project via dbForPlatform which purges on write,
// but there's a window during which Realtime can re-populate a stale
// cache entry. Purge before reading to force a fresh adapter hit.
$database->purgeCachedDocument('projects', $projectId);
// setup), the Database's shared cache may hold an empty result. Try the
// cached read first, and only purge/retry when the first lookup reports
// not-found so the shared cache remains effective for normal traffic.
try {
$project = $authorization->skip(fn () => $database->getDocument('projects', $projectId));
} catch (AppwriteException $e) {
if ($e->getCode() !== 404) {
throw $e;
}
$project = $authorization->skip(fn () => $database->getDocument('projects', $projectId));
$database->purgeCachedDocument('projects', $projectId);
$project = $authorization->skip(fn () => $database->getDocument('projects', $projectId));
}
$database = getProjectDB($project);
$database->setAuthorization($authorization);