CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-09-17 01:47:57 +12:00
Code Issues Projects Releases Wiki Activity

cache deleteById to deleteByGroup

Browse source
This commit is contained in:
shimon 2023-07-13 13:36:14 +03:00
parent a37fee2d16
commit b7aab21698
1 changed files with 20 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
app/workers/deletes.php
View file

@ -136,30 +136,31 @@ class DeletesV1 extends Worker
*/ */
protected function deleteCacheByResource(Document $project, string $resource): void protected function deleteCacheByResource(Document $project, string $resource): void
{ {
$projectId = $project->getId(); $projectId = $project->getId();
$dbForProject = $this->getProjectDB($projectId); $dbForProject = $this->getProjectDB($project);
$document = $dbForProject->findOne('cache', [Query::equal('resource', [$resource])]);
if ($document) { $cache = new Cache(
$cache = new Cache( new Filesystem(APP_STORAGE_CACHE . DIRECTORY_SEPARATOR . 'app-' . $projectId)
new Filesystem(APP_STORAGE_CACHE . DIRECTORY_SEPARATOR . 'app-' . $projectId) );
);
$this->deleteById( $query = [
$document, Query::equal('resource', [$resource])
$dbForProject, ];
function ($document) use ($cache, $projectId) {
$path = APP_STORAGE_CACHE . DIRECTORY_SEPARATOR . 'app-' . $projectId . DIRECTORY_SEPARATOR . $document->getId();
if ($cache->purge($document->getId())) { $this->deleteByGroup(
Console::success('Deleting cache file: ' . $path); 'cache',
} else { $query,
Console::error('Failed to delete cache file: ' . $path); $dbForProject,
} function (Document $document) use ($cache, $projectId) {
$path = APP_STORAGE_CACHE . DIRECTORY_SEPARATOR . 'app-' . $projectId . DIRECTORY_SEPARATOR . $document->getId();
if ($cache->purge($document->getId())) {
Console::success('Deleting cache file: ' . $path);
} else {
Console::error('Failed to delete cache file: ' . $path);
} }
); }
} );
} }
/** /**