108 lines
4.5 KiB
PHP
108 lines
4.5 KiB
PHP
<?php
|
|
|
|
// Copyright (C) 2010-2024, the Friendica project
|
|
// SPDX-FileCopyrightText: 2010-2024 the Friendica project
|
|
//
|
|
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
namespace Friendica\Worker;
|
|
|
|
use Friendica\Contact\Avatar;
|
|
use Friendica\Core\Logger;
|
|
use Friendica\Core\Protocol;
|
|
use Friendica\Core\Worker;
|
|
use Friendica\Database\DBA;
|
|
use Friendica\Database\DBStructure;
|
|
use Friendica\DI;
|
|
use Friendica\Model\Contact;
|
|
use Friendica\Model\Photo;
|
|
use Friendica\Util\DateTimeFormat;
|
|
|
|
/**
|
|
* Removes public contacts that aren't in use
|
|
*/
|
|
class RemoveUnusedContacts
|
|
{
|
|
public static function execute()
|
|
{
|
|
$loop = 0;
|
|
while (self::removeContacts(++$loop)) {
|
|
Logger::info('In removal', ['loop' => $loop]);
|
|
}
|
|
|
|
Logger::notice('Remove apcontact entries with no related contact');
|
|
DBA::delete('apcontact', ["`uri-id` NOT IN (SELECT `uri-id` FROM `contact`) AND `updated` < ?", DateTimeFormat::utc('now - 30 days')]);
|
|
Logger::notice('Removed apcontact entries with no related contact', ['count' => DBA::affectedRows()]);
|
|
|
|
Logger::notice('Remove diaspora-contact entries with no related contact');
|
|
DBA::delete('diaspora-contact', ["`uri-id` NOT IN (SELECT `uri-id` FROM `contact`) AND `updated` < ?", DateTimeFormat::utc('now - 30 days')]);
|
|
Logger::notice('Removed diaspora-contact entries with no related contact', ['count' => DBA::affectedRows()]);
|
|
}
|
|
|
|
public static function removeContacts(int $loop): bool
|
|
{
|
|
Logger::notice('Starting removal', ['loop' => $loop]);
|
|
|
|
$condition = [
|
|
"`id` != ? AND `uid` = ? AND NOT `self` AND NOT `uri-id` IN (SELECT `uri-id` FROM `contact` WHERE `uid` != ?)
|
|
AND NOT EXISTS(SELECT `author-id` FROM `post-user` WHERE `author-id` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `owner-id` FROM `post-user` WHERE `owner-id` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `causer-id` FROM `post-user` WHERE `causer-id` IS NOT NULL AND `causer-id` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `cid` FROM `post-tag` WHERE `cid` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `contact-id` FROM `post-user` WHERE `contact-id` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `cid` FROM `user-contact` WHERE `cid` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `cid` FROM `event` WHERE `cid` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `cid` FROM `group` WHERE `cid` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `author-id` FROM `mail` WHERE `author-id` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `contact-id` FROM `mail` WHERE `contact-id` = `contact`.`id`)
|
|
AND NOT EXISTS(SELECT `contact-id` FROM `group_member` WHERE `contact-id` = `contact`.`id`)
|
|
AND `created` < ?", 0, 0, 0, DateTimeFormat::utc('now - 7 days')
|
|
];
|
|
|
|
if (!DI::config()->get('remove_all_unused_contacts')) {
|
|
$condition2 = [
|
|
"(NOT `network` IN (?, ?, ?, ?, ?, ?) OR `archive`)",
|
|
Protocol::DFRN, Protocol::DIASPORA, Protocol::OSTATUS, Protocol::FEED, Protocol::MAIL, Protocol::ACTIVITYPUB
|
|
];
|
|
|
|
$condition = DBA::mergeConditions($condition2, $condition);
|
|
}
|
|
|
|
$contacts = DBA::select('contact', ['id', 'uid', 'photo', 'thumb', 'micro'], $condition, ['limit' => 1000]);
|
|
$count = 0;
|
|
while ($contact = DBA::fetch($contacts)) {
|
|
++$count;
|
|
Photo::delete(['uid' => $contact['uid'], 'contact-id' => $contact['id']]);
|
|
Avatar::deleteCache($contact);
|
|
|
|
if (DBStructure::existsTable('thread')) {
|
|
DBA::delete('thread', ['owner-id' => $contact['id']]);
|
|
DBA::delete('thread', ['author-id' => $contact['id']]);
|
|
}
|
|
if (DBStructure::existsTable('item')) {
|
|
DBA::delete('item', ['owner-id' => $contact['id']]);
|
|
DBA::delete('item', ['author-id' => $contact['id']]);
|
|
DBA::delete('item', ['causer-id' => $contact['id']]);
|
|
}
|
|
|
|
// There should be none entry for the contact in these tables when none was found in "post-user".
|
|
// But we want to be sure since the foreign key prohibits deletion otherwise.
|
|
DBA::delete('post', ['owner-id' => $contact['id']]);
|
|
DBA::delete('post', ['author-id' => $contact['id']]);
|
|
DBA::delete('post', ['causer-id' => $contact['id']]);
|
|
|
|
DBA::delete('post-thread', ['owner-id' => $contact['id']]);
|
|
DBA::delete('post-thread', ['author-id' => $contact['id']]);
|
|
DBA::delete('post-thread', ['causer-id' => $contact['id']]);
|
|
|
|
DBA::delete('post-thread-user', ['owner-id' => $contact['id']]);
|
|
DBA::delete('post-thread-user', ['author-id' => $contact['id']]);
|
|
DBA::delete('post-thread-user', ['causer-id' => $contact['id']]);
|
|
|
|
Contact::deleteById($contact['id']);
|
|
}
|
|
DBA::close($contacts);
|
|
Logger::notice('Removal done', ['count' => $count]);
|
|
return ($count == 1000 && Worker::isInMaintenanceWindow());
|
|
}
|
|
}
|