Use the same namespace
This commit is contained in:
parent
647db81169
commit
05a061127f
|
@ -796,7 +796,7 @@ App::setResource('dbForExternal', function($db, $cache, $project) {
|
|||
|
||||
$database = new Database(new MariaDB($db), $cache);
|
||||
$database->setDefaultDatabase('appwrite');
|
||||
$database->setNamespace('project_'.$project->getId());
|
||||
$database->setNamespace('_project_'.$project->getId());
|
||||
|
||||
return $database;
|
||||
}, ['db', 'cache', 'project']);
|
||||
|
@ -806,7 +806,7 @@ App::setResource('dbForConsole', function($db, $cache) {
|
|||
|
||||
$database = new Database(new MariaDB($db), $cache);
|
||||
$database->setDefaultDatabase('appwrite');
|
||||
$database->setNamespace('_console');
|
||||
$database->setNamespace('_project_console');
|
||||
|
||||
return $database;
|
||||
}, ['db', 'cache']);
|
||||
|
|
|
@ -78,7 +78,7 @@ $server->onStart(function () use ($stats, $register, $containerId, &$statsDocume
|
|||
*/
|
||||
go(function () use ($register, $containerId, &$statsDocument) {
|
||||
try {
|
||||
[$database, $returnDatabase] = getDatabase($register, '_console');
|
||||
[$database, $returnDatabase] = getDatabase($register, '_project_console');
|
||||
$document = new Document([
|
||||
'$id' => $database->getId(),
|
||||
'$collection' => 'realtime',
|
||||
|
@ -134,7 +134,7 @@ $server->onStart(function () use ($stats, $register, $containerId, &$statsDocume
|
|||
}
|
||||
|
||||
try {
|
||||
[$database, $returnDatabase] = getDatabase($register, '_console');
|
||||
[$database, $returnDatabase] = getDatabase($register, '_project_console');
|
||||
|
||||
$statsDocument
|
||||
->setAttribute('timestamp', time())
|
||||
|
@ -164,7 +164,7 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
|
|||
*/
|
||||
if ($realtime->hasSubscriber('console', 'role:member', 'project')) {
|
||||
|
||||
[$database, $returnDatabase] = getDatabase($register, '_console');
|
||||
[$database, $returnDatabase] = getDatabase($register, '_project_console');
|
||||
|
||||
$payload = [];
|
||||
|
||||
|
|
Loading…
Reference in a new issue