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 App\{
    AccountLog,
    Activity,
    Avatar,
    Bookmark,
    Collection,
    DirectMessage,
    EmailVerification,
    Follower,
    FollowRequest,
    Hashtag,
    Like,
    Media,
    Mention,
    Notification,
    Profile,
    Report,
    ReportComment,
    ReportLog,
    StatusHashtag,
    Status,
    User,
    UserFilter,
    UserSetting,
};

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

    protected $user;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(User $user)
    {
        $this->user = $user;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $user = $this->user;
        $this->deleteAccountLogs($user);
        $this->deleteActivities($user);
        $this->deleteAvatar($user);
        $this->deleteBookmarks($user);
        $this->deleteEmailVerification($user);
        $this->deleteFollowRequests($user);
        $this->deleteFollowers($user);
        $this->deleteLikes($user);
        $this->deleteMedia($user);
        $this->deleteMentions($user);
        $this->deleteNotifications($user);

        // todo send Delete to every known instance sharedInbox   
    }

    public function deleteAccountLogs($user)
    {
        AccountLog::chunk(200, function($logs) use ($user) {
            foreach($logs as $log) {
                if($log->user_id == $user->id) {
                    $log->delete();
                }
            }
        });
    }

    public function deleteActivities($user)
    {
        // todo after AP
    }

    public function deleteAvatar($user)
    {
        $avatar = $user->profile->avatar;

        if(is_file($avatar->media_path)) {
            unlink($avatar->media_path);
        }

        if(is_file($avatar->thumb_path)) {
            unlink($avatar->thumb_path);
        }

        $avatar->delete();
    }

    public function deleteBookmarks($user)
    {
        Bookmark::whereProfileId($user->profile->id)->delete();
    }

    public function deleteEmailVerification($user)
    {
        EmailVerification::whereUserId($user->id)->delete();
    }

    public function deleteFollowRequests($user)
    {
        $id = $user->profile->id;
        FollowRequest::whereFollowingId($id)->orWhere('follower_id', $id)->delete();
    }

    public function deleteFollowers($user)
    {
        $id = $user->profile->id;
        Follower::whereProfileId($id)->orWhere('following_id', $id)->delete();
    }

    public function deleteLikes($user)
    {
        $id = $user->profile->id;
        Like::whereProfileId($id)->delete();
    }

    public function deleteMedia($user)
    {
        $medias = Media::whereUserId($user->id)->get();
        foreach($medias as $media) {
            $path = $media->media_path;
            $thumb = $media->thumbnail_path;
            if(is_file($path)) {
                unlink($path);
            }
            if(is_file($thumb)) {
                unlink($thumb);
            }
            $media->delete();
        }
    }

    public function deleteMentions($user)
    {
        Mention::whereProfileId($user->profile->id)->delete();
    }

    public function deleteNotifications($user)
    {
        $id = $user->profile->id;
        Notification::whereProfileId($id)->orWhere('actor_id', $id)->delete();
    }

    public function deleteProfile($user) {}
    public function deleteReports($user) {}
    public function deleteStatuses($user) {}
    public function deleteUser($user) {}
}