CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-10-01 09:47:43 +13:00
Code Issues Projects Releases Wiki Activity

Trigger deletes worker when target is deleted

Browse source
This commit is contained in:
Jake Barnby 2024-01-25 20:01:15 +13:00
parent da638a10f7
commit 52a9b31521
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
app/controllers/api/users.php
View file

@ -1689,10 +1689,10 @@ App::delete('/v1/users/:userId/targets/:targetId')
->param('userId', '', new UID(), 'User ID.')
->param('targetId', '', new UID(), 'Target ID.')
->inject('queueForEvents')
->inject('queueForDeletes')
->inject('response')
->inject('dbForProject')
->action(function (string $userId, string $targetId, Event $queueForEvents, Response $response, Database $dbForProject) {
->action(function (string $userId, string $targetId, Event $queueForEvents, Delete $queueForDeletes, Response $response, Database $dbForProject) {
$user = $dbForProject->getDocument('users', $userId);
if ($user->isEmpty()) {
@ -1712,6 +1712,10 @@ App::delete('/v1/users/:userId/targets/:targetId')
$dbForProject->deleteDocument('targets', $target->getId());
$dbForProject->deleteCachedDocument('users', $user->getId());
$queueForDeletes
->setType(DELETE_TYPE_TARGET)
->setDocument($target);
$queueForEvents
->setParam('userId', $user->getId())
->setParam('targetId', $target->getId());