pixelfed/pixelfed

<?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;
use App\Jobs\StatusPipeline\StatusDelete;

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;
        Status::whereProfileId($id)->chunk(50, function($statuses) {
            foreach($statuses as $status) {
                StatusDelete::dispatch($status);
            }
        });

        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();

        Report::whereUserId($user->id)->forceDelete();
        PublicTimelineService::warmCache(true, 400);
        $this->deleteUserColumns($user);
        AccountService::del($user->profile_id);
        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();
        });
    }
}