1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- <?php
- namespace App\Jobs\AvatarPipeline;
- use Illuminate\Bus\Queueable;
- use Illuminate\Contracts\Queue\ShouldQueue;
- use Illuminate\Contracts\Queue\ShouldBeUniqueUntilProcessing;
- use Illuminate\Foundation\Bus\Dispatchable;
- use Illuminate\Queue\InteractsWithQueue;
- use Illuminate\Queue\SerializesModels;
- use Illuminate\Queue\Middleware\WithoutOverlapping;
- use App\Services\AvatarService;
- use App\Avatar;
- use Illuminate\Support\Str;
- class AvatarStorageLargePurge implements ShouldQueue, ShouldBeUniqueUntilProcessing
- {
- use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
- public $avatar;
- public $tries = 3;
- public $maxExceptions = 3;
- public $timeout = 900;
- public $failOnTimeout = true;
- /**
- * The number of seconds after which the job's unique lock will be released.
- *
- * @var int
- */
- public $uniqueFor = 3600;
- /**
- * Get the unique ID for the job.
- */
- public function uniqueId(): string
- {
- return 'avatar:storage:lg-purge:' . $this->avatar->profile_id;
- }
- /**
- * Get the middleware the job should pass through.
- *
- * @return array<int, object>
- */
- public function middleware(): array
- {
- return [(new WithoutOverlapping("avatar-storage-purge:{$this->avatar->profile_id}"))->shared()->dontRelease()];
- }
- /**
- * Create a new job instance.
- */
- public function __construct(Avatar $avatar)
- {
- $this->avatar = $avatar->withoutRelations();
- }
- /**
- * Execute the job.
- */
- public function handle(): void
- {
- $avatar = $this->avatar;
- $disk = AvatarService::disk();
- $files = collect(AvatarService::storage($avatar));
- $curFile = Str::of($avatar->cdn_url)->explode('/')->last();
- $files = $files->filter(function($f) use($curFile) {
- return !$curFile || !str_ends_with($f, $curFile);
- })->each(function($name) use($disk) {
- $disk->delete($name);
- });
- return;
- }
- }
|