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

refactor

Browse source
This commit is contained in:
Hemachandar 2026-02-05 13:51:32 +05:30
parent 4aaa3bfd9f
commit aa30db2136
1 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/Appwrite/Platform/Workers/Deletes.php
View file

@ -1391,21 +1391,24 @@ class Deletes extends Action
/**
* @param Database $dbForPlatform
* @param callable $getProjectDB
* @param Document $document
* @param Document $installation
* @param Document $project
* @return void
* @throws Exception
*/
private function deleteInstallation(Database $dbForPlatform, callable $getProjectDB, Document $document, Document $project): void
private function deleteInstallation(Database $dbForPlatform, callable $getProjectDB, Document $installation, Document $project): void
{
$dbForProject = $getProjectDB($project);
// Cleanup sites and functions
foreach (['sites', 'functions'] as $resource) {
$this->listByGroup($resource, [
Query::equal('installationInternalId', [$document->getSequence()])
], $dbForProject, function ($document) use ($resource, $dbForProject, $dbForPlatform) {
$dbForPlatform->deleteDocument('repositories', $document->getAttribute('repositoryId'));
foreach (['sites', 'functions'] as $collection) {
$this->listByGroup($collection, [
Query::equal('installationInternalId', [$installation->getSequence()])
], $dbForProject, function ($document) use ($collection, $dbForProject, $dbForPlatform) {
$repositoryId = $document->getAttribute('repositoryId', '');
if (!empty($repositoryId)) {
$dbForPlatform->deleteDocument('repositories', $repositoryId);
}
$document = $document
->setAttribute('installationId', '')
@ -1416,7 +1419,7 @@ class Deletes extends Action
->setAttribute('providerRootDirectory', '')
->setAttribute('repositoryId', '')
->setAttribute('repositoryInternalId', '');
$dbForProject->updateDocument($resource, $document->getId(), $document);
$dbForProject->updateDocument($collection, $document->getId(), $document);
});
}
}