Improve query speed

diff --git a/src/Worker/RemoveContact.php b/src/Worker/RemoveContact.php
index 8485adda6b5df943a490ff7f910067a5d7e74b44..2e3f16db3e99da80512b85d80cf98b163f18b4f4 100644 (file)
--- a/src/Worker/RemoveContact.php
+++ b/src/Worker/RemoveContact.php
@@ -16,13 +16,13 @@ class RemoveContact {
 
                // Only delete if the contact is to be deleted
                $condition = ['network' => Protocol::PHANTOM, 'id' => $id];
-               $r = DBA::exists('contact', $condition);
-               if (!DBA::isResult($r)) {
+               $contact = DBA::selectFirst('contact', ['uid'], $condition);
+               if (!DBA::isResult($contact)) {
                        return;
                }
 
                // Now we delete the contact and all depending tables
-               $condition = ['contact-id' => $id];
+               $condition = ['uid' => $contact['uid'], 'contact-id' => $id];
                do {
                        $items = Item::select(['id'], $condition, ['limit' => 100]);
                        while ($item = Item::fetch($items)) {