X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FWorker%2FRemoveUser.php;h=ac67d69f965496d5bb126c94fb1227060726ab40;hb=40a126306621fe9eadb58101bd19a0be32e4c163;hp=c7179a4e3d6546c462ad800d90d92259446cfa48;hpb=1de3960e267a8d298348fbca18cf1be1f6a20f7a;p=friendica.git diff --git a/src/Worker/RemoveUser.php b/src/Worker/RemoveUser.php index c7179a4e3d..ac67d69f96 100644 --- a/src/Worker/RemoveUser.php +++ b/src/Worker/RemoveUser.php @@ -1,15 +1,42 @@ . + * */ + namespace Friendica\Worker; +use Friendica\Core\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) + /** + * Removes user by id + * + * @param int $uid User id + * @return void + */ + public static function execute(int $uid) { // Only delete if the user is archived $condition = ['account_removed' => true, 'uid' => $uid]; @@ -20,11 +47,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'], Worker::PRIORITY_NEGLIGIBLE); } DBA::close($items); - } while (Item::exists($condition)); + } while (Post::exists($condition)); } }