X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=src%2FWorker%2FRemoveUser.php;h=0db881a0a99e8e19c961c868ebfeb139bd0d8db5;hb=2647514603852fe5fb9f47f0bf153dd20c124ce6;hp=c7179a4e3d6546c462ad800d90d92259446cfa48;hpb=94eca7704130822bf83bb5fee6930dee6bae81dd;p=friendica.git diff --git a/src/Worker/RemoveUser.php b/src/Worker/RemoveUser.php index c7179a4e3d..0db881a0a9 100644 --- a/src/Worker/RemoveUser.php +++ b/src/Worker/RemoveUser.php @@ -1,13 +1,33 @@ . + * */ + namespace Friendica\Worker; use Friendica\Database\DBA; use Friendica\Model\Item; +use Friendica\Model\Post; +/** + * Removes orphaned data from deleted users + */ class RemoveUser { public static function execute($uid) { @@ -20,11 +40,11 @@ class RemoveUser { // Now we delete all user items $condition = ['uid' => $uid, 'deleted' => false]; do { - $items = Item::select(['id'], $condition, ['limit' => 100]); - while ($item = Item::fetch($items)) { - Item::deleteById($item['id'], PRIORITY_NEGLIGIBLE); + $items = Post::select(['id'], $condition, ['limit' => 100]); + while ($item = Post::fetch($items)) { + Item::markForDeletionById($item['id'], PRIORITY_NEGLIGIBLE); } DBA::close($items); - } while (Item::exists($condition)); + } while (Post::exists($condition)); } }