pixelfed/app/Jobs/DeletePipeline/DeleteAccountPipeline.php

<?php

namespace App\Jobs\DeletePipeline;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use DB;
use Storage;
use Illuminate\Support\Str;
use App\Services\AccountService;
use App\Services\FollowerService;
use App\Services\PublicTimelineService;
use App\{
	AccountInterstitial,
	AccountLog,
	Avatar,
	Bookmark,
	Collection,
	CollectionItem,
	Contact,
	DirectMessage,
	EmailVerification,
	Follower,
	FollowRequest,
	Hashtag,
	HashtagFollow,
	ImportData,
	ImportJob,
	Like,
	Media,
	MediaTag,
	Mention,
	Notification,
	OauthClient,
	Profile,
	ProfileSponsor,
	Report,
	ReportComment,
	ReportLog,
	StatusHashtag,
	StatusArchived,
	Status,
	Story,
	StoryView,
	User,
	UserDevice,
	UserFilter,
	UserSetting,
};
use App\Models\Conversation;
use App\Models\Poll;
use App\Models\PollVote;
use App\Models\Portfolio;
use App\Models\UserPronoun;

class DeleteAccountPipeline implements ShouldQueue
{
	use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

	protected $user;

	public $timeout = 900;
    public $tries = 3;
    public $maxExceptions = 1;
    public $deleteWhenMissingModels = true;

	public function __construct(User $user)
	{
		$this->user = $user;
	}

	public function handle()
	{
		$user = $this->user;
        $profile = $user->profile;
		$id = $user->profile_id;
		$this->deleteUserColumns($user);
		AccountService::del($user->profile_id);

		AccountLog::whereItemType('App\User')->whereItemId($user->id)->forceDelete();

		AccountInterstitial::whereUserId($user->id)->delete();

		// Delete Avatar
        $profile->avatar->forceDelete();

        // Delete Poll Votes
        PollVote::whereProfileId($id)->delete();

        // Delete Polls
        Poll::whereProfileId($id)->delete();

        // Delete Portfolio
        Portfolio::whereProfileId($id)->delete();

		ImportData::whereProfileId($id)
			->cursor()
			->each(function($data) {
				$path = storage_path('app/'.$data->path);
				if(is_file($path)) {
					unlink($path);
				}
				$data->delete();
		});

		ImportJob::whereProfileId($id)
			->cursor()
			->each(function($data) {
				$path = storage_path('app/'.$data->media_json);
				if(is_file($path)) {
					unlink($path);
				}
				$data->delete();
		});

		MediaTag::whereProfileId($id)->delete();
		Bookmark::whereProfileId($id)->forceDelete();
		EmailVerification::whereUserId($user->id)->forceDelete();
		StatusHashtag::whereProfileId($id)->delete();
		DirectMessage::whereFromId($id)->orWhere('to_id', $id)->delete();
        Conversation::whereFromId($id)->orWhere('to_id', $id)->delete();
		StatusArchived::whereProfileId($id)->delete();
		UserPronoun::whereProfileId($id)->delete();
		FollowRequest::whereFollowingId($id)
			->orWhere('follower_id', $id)
			->forceDelete();
		Follower::whereProfileId($id)
			->orWhere('following_id', $id)
			->each(function($follow) {
				FollowerService::remove($follow->profile_id, $follow->following_id);
				$follow->delete();
			});
		FollowerService::delCache($id);
		Like::whereProfileId($id)->forceDelete();
        Mention::whereProfileId($id)->forceDelete();

		StoryView::whereProfileId($id)->delete();
		$stories = Story::whereProfileId($id)->get();
		foreach($stories as $story) {
			$path = storage_path('app/'.$story->path);
			if(is_file($path)) {
				unlink($path);
			}
			$story->forceDelete();
		}

        UserDevice::whereUserId($user->id)->forceDelete();
        UserFilter::whereUserId($user->id)->forceDelete();
        UserSetting::whereUserId($user->id)->forceDelete();

		Mention::whereProfileId($id)->forceDelete();
		Notification::whereProfileId($id)
			->orWhere('actor_id', $id)
			->forceDelete();

		$collections = Collection::whereProfileId($id)->get();
		foreach ($collections as $collection) {
			$collection->items()->delete();
			$collection->delete();
		}
		Contact::whereUserId($user->id)->delete();
		HashtagFollow::whereUserId($user->id)->delete();
		OauthClient::whereUserId($user->id)->delete();
		DB::table('oauth_access_tokens')->whereUserId($user->id)->delete();
		DB::table('oauth_auth_codes')->whereUserId($user->id)->delete();
		ProfileSponsor::whereProfileId($id)->delete();

		Status::whereProfileId($id)->chunk(50, function($statuses) {
            foreach($statuses as $status) {
                StatusDelete::dispatch($status)->onQueue('high');
            }
        });

		Report::whereUserId($user->id)->forceDelete();
		PublicTimelineService::warmCache(true, 400);
		Profile::whereUserId($user->id)->delete();
	}

	protected function deleteUserColumns($user)
	{
		DB::transaction(function() use ($user) {
			$user->status = 'deleted';
			$user->name = 'deleted';
			$user->email = $user->id;
			$user->password = '';
			$user->remember_token = null;
			$user->is_admin = false;
			$user->{'2fa_enabled'} = false;
			$user->{'2fa_secret'} = null;
			$user->{'2fa_backup_codes'} = null;
			$user->{'2fa_setup_at'} = null;
			$user->save();
		});
	}
}