From a13b7606a25adea82c5dc57569b7e0498226f2e5 Mon Sep 17 00:00:00 2001
From: Steven Nguyen <stnguyen90@users.noreply.github.com>
Date: Wed, 16 Aug 2023 16:34:54 -0700
Subject: [PATCH] Fix console db namespace

---
 app/cli.php                    | 2 +-
 app/init.php                   | 2 +-
 app/realtime.php               | 2 +-
 app/worker.php                 | 2 +-
 src/Appwrite/Resque/Worker.php | 4 ++--
 5 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/app/cli.php b/app/cli.php
index 2d12d69ad..fd1b8aff1 100644
--- a/app/cli.php
+++ b/app/cli.php
@@ -58,7 +58,7 @@ CLI::setResource('dbForConsole', function ($pools, $cache) {
                 ->getResource();
 
             $dbForConsole = new Database($dbAdapter, $cache);
-            $dbForConsole->setNamespace('console');
+            $dbForConsole->setNamespace('_console');
 
             // Ensure tables exist
             $collections = Config::getParam('collections', [])['console'];
diff --git a/app/init.php b/app/init.php
index 4d99fe251..0e327cd46 100644
--- a/app/init.php
+++ b/app/init.php
@@ -1116,7 +1116,7 @@ App::setResource('dbForConsole', function (Group $pools, Cache $cache) {
 
     $database = new Database($dbAdapter, $cache);
 
-    $database->setNamespace('console');
+    $database->setNamespace('_console');
 
     return $database;
 }, ['pools', 'cache']);
diff --git a/app/realtime.php b/app/realtime.php
index 772eee49d..25b0532b4 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -47,7 +47,7 @@ function getConsoleDB(): Database
 
     $database = new Database($dbAdapter, getCache());
 
-    $database->setNamespace('console');
+    $database->setNamespace('_console');
 
     return $database;
 }
diff --git a/app/worker.php b/app/worker.php
index 75fc95e9a..084569886 100644
--- a/app/worker.php
+++ b/app/worker.php
@@ -37,7 +37,7 @@ Server::setResource('dbForConsole', function (Cache $cache, Registry $register)
     ;
 
     $adapter = new Database($database, $cache);
-    $adapter->setNamespace('console');
+    $adapter->setNamespace('_console');
 
     return $adapter;
 }, ['cache', 'register']);
diff --git a/src/Appwrite/Resque/Worker.php b/src/Appwrite/Resque/Worker.php
index 146500e74..548dc4871 100644
--- a/src/Appwrite/Resque/Worker.php
+++ b/src/Appwrite/Resque/Worker.php
@@ -223,7 +223,7 @@ abstract class Worker
 
         if (isset(self::$databases[$databaseName])) {
             $database = self::$databases[$databaseName];
-            $database->setNamespace('console');
+            $database->setNamespace('_console');
             return $database;
         }
 
@@ -237,7 +237,7 @@ abstract class Worker
 
         self::$databases[$databaseName] = $database;
 
-        $database->setNamespace('console');
+        $database->setNamespace('_console');
 
         return $database;
     }