fix realtime

This commit is contained in:
Damodar Lohani
2022-06-30 01:33:48 +00:00
parent 951a553344
commit adc8be01d0
+2 -3
View File
@@ -533,12 +533,11 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
$database->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
$projectId = $realtime->connections[$connection]['projectId'];
$database->setNamespace("_console");
$project = Authorization::skip(fn() => $database->getDocument('projects', $realtime->connections[$connection]['projectId']));
$project = Authorization::skip(fn() => $database->getDocument('projects', $projectId));
if ($projectId != 'console') {
$filters = getFilters($database, $projectId);
$filters = getFilters($project);
$database = new Database(new MariaDB($db), $cache, $filters);
$database->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
}