From 257c09491193bc7233d9f7edd26686d2b4b6dbe7 Mon Sep 17 00:00:00 2001 From: Daniel Supernault Date: Mon, 26 Dec 2022 20:04:42 -0700 Subject: [PATCH] Update StatusDelete pipeline, dispatch async --- app/Http/Controllers/StatusController.php | 2 +- app/Jobs/MediaPipeline/MediaDeletePipeline.php | 6 +++--- app/Jobs/StatusPipeline/StatusDelete.php | 5 ++++- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/app/Http/Controllers/StatusController.php b/app/Http/Controllers/StatusController.php index 117124bb..c0e2e4ec 100644 --- a/app/Http/Controllers/StatusController.php +++ b/app/Http/Controllers/StatusController.php @@ -225,7 +225,7 @@ class StatusController extends Controller StatusService::del($status->id, true); if ($status->profile_id == $user->profile->id || $user->is_admin == true) { Cache::forget('profile:status_count:'.$status->profile_id); - StatusDelete::dispatchNow($status); + StatusDelete::dispatch($status); } if($request->wantsJson()) { diff --git a/app/Jobs/MediaPipeline/MediaDeletePipeline.php b/app/Jobs/MediaPipeline/MediaDeletePipeline.php index 4fb8427c..4db76c9c 100644 --- a/app/Jobs/MediaPipeline/MediaDeletePipeline.php +++ b/app/Jobs/MediaPipeline/MediaDeletePipeline.php @@ -41,7 +41,7 @@ class MediaDeletePipeline implements ShouldQueue array_pop($e); $i = implode('/', $e); - if(config('pixelfed.cloud_storage') == true) { + if(config_cache('pixelfed.cloud_storage') == true) { $disk = Storage::disk(config('filesystems.cloud')); if($path && $disk->exists($path)) { @@ -63,9 +63,9 @@ class MediaDeletePipeline implements ShouldQueue $disk->delete($thumb); } - $media->forceDelete(); + $media->delete(); - return; + return 1; } } diff --git a/app/Jobs/StatusPipeline/StatusDelete.php b/app/Jobs/StatusPipeline/StatusDelete.php index deee089d..1aa7e540 100644 --- a/app/Jobs/StatusPipeline/StatusDelete.php +++ b/app/Jobs/StatusPipeline/StatusDelete.php @@ -50,6 +50,9 @@ class StatusDelete implements ShouldQueue */ public $deleteWhenMissingModels = true; + public $timeout = 900; + public $tries = 2; + /** * Create a new job instance. * @@ -131,7 +134,7 @@ class StatusDelete implements ShouldQueue ->where('item_id', $status->id) ->delete(); - $status->forceDelete(); + $status->delete(); return 1; }