diff --git a/app/realtime.php b/app/realtime.php
index da106d6ca3..f4b46dc413 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -533,9 +533,8 @@ $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($project);
diff --git a/composer.lock b/composer.lock
index 79f77fa828..e079cf0bc0 100644
--- a/composer.lock
+++ b/composer.lock
@@ -5379,5 +5379,5 @@
     "platform-overrides": {
         "php": "8.0"
     },
-    "plugin-api-version": "2.2.0"
+    "plugin-api-version": "2.3.0"
 }