forked from mirror/pixelfed
198 lines
5 KiB
PHP
198 lines
5 KiB
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;
|
|
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();
|
|
});
|
|
}
|
|
}
|