wticreatorstudio/Modules/StudioPlus/Jobs/ApplyWatermark.php

<?php

namespace Modules\StudioPlus\Jobs;

use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\Events\JobFailed;
use Illuminate\Support\Facades\Queue;
use Modules\StudioPlus\Entities\WatermarkingJob;
use Modules\StudioPlus\Events\UpdateJobStatusEvent;
use Modules\StudioPlus\Services\VideoProcessingService;
use Throwable;

class ApplyWatermark implements ShouldQueue, ShouldBeUnique
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $timeout = 3000;
    public $failOnTimeout = false;
    protected $service;

    public function __construct(protected $video)
    {
        $this->connection = 'watermarking';
        $this->queue = 'watermarking';
        $this->service = new VideoProcessingService();
    }

    public function handle()
    {
        $this->service->reprocess($this->video->id);
    }

    public function failed(Throwable $exception)
    {
        $job = WatermarkingJob::where('video_id', $this->video->id)->first();

        if ($job) {
            //$job->status = 'failed';
            //$job->update();

            //event(new UpdateJobStatusEvent($job));
        }
    }
}