CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-07-06 07:00:56 +12:00
Code Issues Projects Releases Wiki Activity

Merge pull request #6985 from appwrite/fix-db-mod

Browse source 
Fix db mod
This commit is contained in:
Christy Jacob 2023-10-23 02:07:15 +04:00 committed by GitHub
parent d1deef43c5 a841734d50
commit e2eccaca8b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
app/controllers/api/projects.php
View file

@ -100,7 +100,11 @@ App::post('/v1/projects')
$backups['database_db_fra1_v14x_07'] = ['from' => '00:00', 'to' => '02:00']; $backups['database_db_fra1_v14x_07'] = ['from' => '00:00', 'to' => '02:00'];
$databases = Config::getParam('pools-database', []); $databases = Config::getParam('pools-database', []);
$databaseSelfHosted = 'database_db_fra1_self_hosted_0_0';
$index = array_search($databaseSelfHosted, $databases);
if ($index !== false) {
unset($databases[$index]);
}
/** /**
* Remove databases from the list that are currently undergoing an backup * Remove databases from the list that are currently undergoing an backup
@ -124,7 +128,7 @@ App::post('/v1/projects')
$databaseOverride = App::getEnv('_APP_DATABASE_OVERRIDE', null); $databaseOverride = App::getEnv('_APP_DATABASE_OVERRIDE', null);
$index = array_search($databaseOverride, $databases); $index = array_search($databaseOverride, $databases);
if ($index) { if ($index !== false) {
$database = $databases[$index]; $database = $databases[$index];
} else { } else {
$database = $databases[array_rand($databases)]; $database = $databases[array_rand($databases)];
@ -175,9 +179,9 @@ App::post('/v1/projects')
* Update database with self-managed db every $mod projects * Update database with self-managed db every $mod projects
*/ */
$mod = 20; $mod = 20;
$index = array_search('database_db_fra1_self_hosted_0_0', $databases); $index = in_array($databaseSelfHosted, $databases);
if ($index !== false && ($project->getInternalId() % $mod === 0)) { if ($project->getInternalId() % $mod === 0 && $index !== false) {
$project->setAttribute('database', $databases[$index]); $project->setAttribute('database', $databaseSelfHosted);
$dbForConsole->updateDocument('projects', $project); $dbForConsole->updateDocument('projects', $project);
} }