UA-Fediland/pixelfed
2
0
Fork 0
mirror of https://github.com/pixelfed/pixelfed.git synced 2024-12-25 06:23:18 +00:00
Code Issues Projects Releases Packages Wiki Activity

Update DeletePipeline

Browse source
This commit is contained in:
Daniel Supernault 2022-12-24 02:01:30 -07:00
parent e260109abe
commit aa32eb8780
No known key found for this signature in database
GPG key ID: 0DEF1C662C9033F7
3 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
app/Jobs/DeletePipeline/DeleteRemoteStatusPipeline.php
View file

@ -30,6 +30,10 @@ class DeleteRemoteStatusPipeline implements ShouldQueue
protected $status; protected $status;
public $timeout = 300;
public $tries = 3;
public $maxExceptions = 1;
/** /**
* Create a new job instance. * Create a new job instance.
* *
@ -62,7 +66,7 @@ class DeleteRemoteStatusPipeline implements ShouldQueue
Media::whereStatusId($status->id) Media::whereStatusId($status->id)
->get() ->get()
->each(function($media) { ->each(function($media) {
MediaDeletePipeline::dispatchNow($media); MediaDeletePipeline::dispatch($media)->onQueue('mmo');
}); });
Mention::whereStatusId($status->id)->forceDelete(); Mention::whereStatusId($status->id)->forceDelete();
Report::whereObjectType('App\Status')->whereObjectId($status->id)->delete(); Report::whereObjectType('App\Status')->whereObjectId($status->id)->delete();

4
app/Jobs/MediaPipeline/MediaDeletePipeline.php
View file

@ -17,6 +17,10 @@ class MediaDeletePipeline implements ShouldQueue
protected $media; protected $media;
public $timeout = 300;
public $tries = 3;
public $maxExceptions = 1;
public function __construct(Media $media) public function __construct(Media $media)
{ {
$this->media = $media; $this->media = $media;

2
app/Util/ActivityPub/Inbox.php
View file

@ -681,7 +681,7 @@ class Inbox
if(!$status) { if(!$status) {
return; return;
} }
DeleteRemoteStatusPipeline::dispatch($status)->onQueue('delete'); DeleteRemoteStatusPipeline::dispatch($status)->onQueue('high');
return; return;
break; break;