From 52a9b31521a95db68ab418947fde6c6763719939 Mon Sep 17 00:00:00 2001 From: Jake Barnby Date: Thu, 25 Jan 2024 20:01:15 +1300 Subject: [PATCH] Trigger deletes worker when target is deleted --- app/controllers/api/users.php | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/app/controllers/api/users.php b/app/controllers/api/users.php index 117338b9a7..ddc925d1c2 100644 --- a/app/controllers/api/users.php +++ b/app/controllers/api/users.php @@ -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());