aiden
/
pixelfed
mirror of https://github.com/pixelfed/pixelfed
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update DeleteAccountPipeline, fixes #2016

Browse Source
pull/2020/head
Daniel Supernault 6 years ago
parent a68e1a42ed
commit f400c632f0
No known key found for this signature in database
GPG Key ID: 0DEF1C662C9033F7
3 changed files with 186 additions and 160 deletions
Show Stats Download Patch File Download Diff File

26
app/Console/Commands/UserDelete.php
Unescape Escape View File

@ -13,7 +13,7 @@ class UserDelete extends Command
* *
* @var string * @var string
*/ */
protected $signature = 'user:delete {id}'; protected $signature = 'user:delete {id} {--force}';
/** /**
* The console command description. * The console command description.
@ -40,12 +40,24 @@ class UserDelete extends Command
public function handle() public function handle()
{ {
$id = $this->argument('id'); $id = $this->argument('id');
$user = User::whereUsername($id)->orWhere('id', $id)->first(); $force = $this->option('force');
if(ctype_digit($id) == true) {
$user = User::find($id);
} else {
$user = User::whereUsername($id)->first();
}
if(!$user) { if(!$user) {
$this->error('Could not find any user with that username or id.'); $this->error('Could not find any user with that username or id.');
exit; exit;
} }
if($user->status == 'deleted' && $force == false) {
$this->error('Account has already been deleted.');
return;
}
if($user->is_admin == true) { if($user->is_admin == true) {
$this->error('Cannot delete an admin account from CLI.'); $this->error('Cannot delete an admin account from CLI.');
exit; exit;
@ -62,10 +74,12 @@ class UserDelete extends Command
exit; exit;
} }
$profile = $user->profile; if($user->status !== 'deleted') {
$profile->status = $user->status = 'deleted'; $profile = $user->profile;
$profile->save(); $profile->status = $user->status = 'deleted';
$user->save(); $profile->save();
$user->save();
}
DeleteAccountPipeline::dispatch($user)->onQueue('high'); DeleteAccountPipeline::dispatch($user)->onQueue('high');
} }

316
app/Jobs/DeletePipeline/DeleteAccountPipeline.php
Unescape Escape View File

@ -10,162 +10,170 @@ use Illuminate\Foundation\Bus\Dispatchable;
use DB; use DB;
use Illuminate\Support\Str; use Illuminate\Support\Str;
use App\{ use App\{
AccountLog, AccountLog,
Activity, Activity,
Avatar, Avatar,
Bookmark, Bookmark,
Collection, Collection,
DirectMessage, CollectionItem,
EmailVerification, Contact,
Follower, DirectMessage,
FollowRequest, EmailVerification,
Hashtag, Follower,
Like, FollowRequest,
Media, Hashtag,
Mention, HashtagFollow,
Notification, Like,
Profile, Media,
Report, Mention,
ReportComment, Notification,
ReportLog, OauthClient,
StatusHashtag, Profile,
Status, ProfileSponsor,
Story, Report,
StoryView, ReportComment,
User, ReportLog,
UserDevice, StatusHashtag,
UserFilter, Status,
UserSetting, Story,
StoryView,
User,
UserDevice,
UserFilter,
UserSetting,
}; };
class DeleteAccountPipeline implements ShouldQueue class DeleteAccountPipeline implements ShouldQueue
{ {
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
protected $user; protected $user;
/** public function __construct(User $user)
* Create a new job instance. {
* $this->user = $user;
* @return void }
*/
public function __construct(User $user) public function handle()
{ {
$this->user = $user; $user = $this->user;
}
DB::transaction(function() use ($user) {
/** AccountLog::chunk(200, function($logs) use ($user) {
* Execute the job. foreach($logs as $log) {
* if($log->user_id == $user->id) {
* @return void $log->forceDelete();
*/ }
public function handle() }
{ });
$user = $this->user; });
DB::transaction(function() use ($user) {
AccountLog::chunk(200, function($logs) use ($user) { DB::transaction(function() use ($user) {
foreach($logs as $log) { if($user->profile) {
if($log->user_id == $user->id) { $avatar = $user->profile->avatar;
$log->forceDelete(); $avatar->forceDelete();
} }
}
}); $id = $user->profile_id;
});
Bookmark::whereProfileId($user->profile_id)->forceDelete();
DB::transaction(function() use ($user) { EmailVerification::whereUserId($user->id)->forceDelete();
if($user->profile) { StatusHashtag::whereProfileId($id)->delete();
$avatar = $user->profile->avatar; FollowRequest::whereFollowingId($id)
->orWhere('follower_id', $id)
$avatar->forceDelete(); ->forceDelete();
} Follower::whereProfileId($id)
->orWhere('following_id', $id)
Bookmark::whereProfileId($user->profile->id)->forceDelete(); ->forceDelete();
Like::whereProfileId($id)->forceDelete();
EmailVerification::whereUserId($user->id)->forceDelete(); });
$id = $user->profile->id;
DB::transaction(function() use ($user) {
StatusHashtag::whereProfileId($id)->delete(); $pid = $this->user->profile_id;
FollowRequest::whereFollowingId($id)->orWhere('follower_id', $id)->forceDelete(); StoryView::whereProfileId($pid)->delete();
$stories = Story::whereProfileId($pid)->get();
Follower::whereProfileId($id)->orWhere('following_id', $id)->forceDelete(); foreach($stories as $story) {
$path = storage_path('app/'.$story->path);
Like::whereProfileId($id)->forceDelete(); if(is_file($path)) {
}); unlink($path);
}
DB::transaction(function() use ($user) { $story->forceDelete();
$pid = $this->user->profile_id; }
});
StoryView::whereProfileId($pid)->delete();
$stories = Story::whereProfileId($pid)->get(); DB::transaction(function() use ($user) {
foreach($stories as $story) { $medias = Media::whereUserId($user->id)->get();
$path = storage_path('app/'.$story->path); foreach($medias as $media) {
if(is_file($path)) { $path = storage_path('app/'.$media->media_path);
unlink($path); $thumb = storage_path('app/'.$media->thumbnail_path);
} if(is_file($path)) {
$story->forceDelete(); unlink($path);
} }
}); if(is_file($thumb)) {
unlink($thumb);
DB::transaction(function() use ($user) { }
$medias = Media::whereUserId($user->id)->get(); $media->forceDelete();
foreach($medias as $media) { }
$path = storage_path('app/'.$media->media_path); });
$thumb = storage_path('app/'.$media->thumbnail_path);
if(is_file($path)) { DB::transaction(function() use ($user) {
unlink($path); Mention::whereProfileId($user->profile_id)->forceDelete();
} Notification::whereProfileId($user->profile_id)
if(is_file($thumb)) { ->orWhere('actor_id', $user->profile_id)
unlink($thumb); ->forceDelete();
} });
$media->forceDelete();
} DB::transaction(function() use ($user) {
}); $collections = Collection::whereProfileId($user->profile_id)->get();
foreach ($collections as $collection) {
DB::transaction(function() use ($user) { $collection->items()->delete();
Mention::whereProfileId($user->profile->id)->forceDelete(); $collection->delete();
Notification::whereProfileId($user->profile->id)->orWhere('actor_id', $user->profile->id)->forceDelete(); }
}); Contact::whereUserId($user->id)->delete();
HashtagFollow::whereUserId($user->id)->delete();
DB::transaction(function() use ($user) { OauthClient::whereUserId($user->id)->delete();
Status::whereProfileId($user->profile->id)->forceDelete(); ProfileSponsor::whereProfileId($user->profile_id)->delete();
Report::whereUserId($user->id)->forceDelete(); });
$this->deleteProfile($user);
}); DB::transaction(function() use ($user) {
} Status::whereProfileId($user->profile_id)->forceDelete();
Report::whereUserId($user->id)->forceDelete();
protected function deleteProfile($user) { $this->deleteProfile($user);
DB::transaction(function() use ($user) { });
Profile::whereUserId($user->id)->delete(); }
$this->deleteUserSettings($user);
}); protected function deleteProfile($user) {
} DB::transaction(function() use ($user) {
Profile::whereUserId($user->id)->delete();
protected function deleteUserSettings($user) { $this->deleteUserSettings($user);
});
DB::transaction(function() use ($user) { }
UserDevice::whereUserId($user->id)->forceDelete();
UserFilter::whereUserId($user->id)->forceDelete(); protected function deleteUserSettings($user) {
UserSetting::whereUserId($user->id)->forceDelete();
$this->deleteUserColumns($user); DB::transaction(function() use ($user) {
}); UserDevice::whereUserId($user->id)->forceDelete();
} UserFilter::whereUserId($user->id)->forceDelete();
UserSetting::whereUserId($user->id)->forceDelete();
protected function deleteUserColumns($user) $this->deleteUserColumns($user);
{ });
DB::transaction(function() use ($user) { }
$user->status = 'deleted';
$user->name = 'deleted'; protected function deleteUserColumns($user)
$user->email = $user->id; {
$user->password = ''; DB::transaction(function() use ($user) {
$user->remember_token = null; $user->status = 'deleted';
$user->is_admin = false; $user->name = 'deleted';
$user->{'2fa_enabled'} = false; $user->email = $user->id;
$user->{'2fa_secret'} = null; $user->password = '';
$user->{'2fa_backup_codes'} = null; $user->remember_token = null;
$user->{'2fa_setup_at'} = null; $user->is_admin = false;
$user->save(); $user->{'2fa_enabled'} = false;
}); $user->{'2fa_secret'} = null;
$user->{'2fa_backup_codes'} = null;
} $user->{'2fa_setup_at'} = null;
$user->save();
});
}
} }

4
app/Observers/UserObserver.php
Unescape Escape View File

@ -19,6 +19,10 @@ class UserObserver
*/ */
public function saved(User $user) public function saved(User $user)
{ {
if($user->status == 'deleted') {
return;
}
if (empty($user->profile)) { if (empty($user->profile)) {
$profile = DB::transaction(function() use($user) { $profile = DB::transaction(function() use($user) {
$profile = new Profile(); $profile = new Profile();

Write Preview
Loading…
Cancel
Save