Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 08:58:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix dual writing

Browse source
This commit is contained in:
Damodar Lohani 2025-02-06 04:40:01 +00:00
parent 2efe1ed9dc
commit ae9d3f4703
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
.env
View file

@ -111,4 +111,4 @@ _APP_MESSAGE_PUSH_TEST_DSN=
_APP_WEBHOOK_MAX_FAILED_ATTEMPTS=10
_APP_PROJECT_REGIONS=default
_APP_FUNCTIONS_CREATION_ABUSE_LIMIT=5000
_APP_STATS_USAGE_DUAL_WRITING_DBS=
_APP_STATS_USAGE_DUAL_WRITING_DBS=database_db_main

7
src/Appwrite/Platform/Workers/StatsUsageDump.php
View file

@ -150,13 +150,14 @@ class StatsUsageDump extends Action
'value' => $value,
'region' => System::getEnv('_APP_REGION', 'default'),
]);
$documentClone = new Document($document->getArrayCopy());
$dbForProject->createOrUpdateDocumentsWithIncrease(
'stats',
'value',
[$document]
);
$this->writeToLogsDB($project, $document);
$this->writeToLogsDB($project, $documentClone);
}
}
} catch (\Exception $e) {
@ -181,12 +182,13 @@ class StatsUsageDump extends Action
'value' => $value,
'region' => System::getEnv('_APP_REGION', 'default'),
]);
$documentClone = new Document($document->getArrayCopy());
$dbForProject->createOrUpdateDocumentsWithIncrease(
'stats',
'value',
[$document]
);
$this->writeToLogsDB($project, $document);
$this->writeToLogsDB($project, $documentClone);
};
foreach ($this->periods as $period => $format) {
@ -337,5 +339,6 @@ class StatsUsageDump extends Action
'value',
[$document]
);
Console::success('Usage logs pushed to Logs DB');
}
}