MediaDeletePipeline.php 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. <?php
  2. namespace App\Jobs\MediaPipeline;
  3. use App\Media;
  4. use Illuminate\Bus\Queueable;
  5. use Illuminate\Contracts\Queue\ShouldQueue;
  6. use Illuminate\Foundation\Bus\Dispatchable;
  7. use Illuminate\Queue\InteractsWithQueue;
  8. use Illuminate\Queue\SerializesModels;
  9. use Illuminate\Support\Facades\Redis;
  10. use Illuminate\Support\Facades\Storage;
  11. class MediaDeletePipeline implements ShouldQueue
  12. {
  13. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  14. protected $media;
  15. public function __construct(Media $media)
  16. {
  17. $this->media = $media;
  18. }
  19. public function handle()
  20. {
  21. $media = $this->media;
  22. $path = $media->media_path;
  23. $thumb = $media->thumbnail_path;
  24. if(!$path) {
  25. return 1;
  26. }
  27. $e = explode('/', $path);
  28. array_pop($e);
  29. $i = implode('/', $e);
  30. if(config_cache('pixelfed.cloud_storage') == true) {
  31. $disk = Storage::disk(config('filesystems.cloud'));
  32. if($disk->exists($path)) {
  33. $disk->delete($path);
  34. }
  35. if($disk->exists($thumb)) {
  36. $disk->delete($thumb);
  37. }
  38. if(count($e) > 4 && count($disk->files($i)) == 0) {
  39. $disk->deleteDirectory($i);
  40. }
  41. }
  42. $disk = Storage::disk(config('filesystems.local'));
  43. if($disk->exists($path)) {
  44. $disk->delete($path);
  45. }
  46. if($disk->exists($thumb)) {
  47. $disk->delete($thumb);
  48. }
  49. if(count($e) > 4 && count($disk->files($i)) == 0) {
  50. $disk->deleteDirectory($i);
  51. }
  52. return 1;
  53. }
  54. }