diff --git a/app/realtime.php b/app/realtime.php
index 851d5119fb..f4b46dc413 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -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'));
         }