<?php

namespace App\Jobs;

use App\Models\CallAiAnalysis;
use App\Services\AI\VoiceAnalysis\CallAnalysisService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Str;
use Throwable;

/**
 * Runs on the dedicated `ai` queue: transcribing a long call takes minutes and
 * the default worker's --timeout=120 would kill it.
 */
class AnalyzeCallRecordingJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /** Seconds the job may run before the worker kills it. */
    public $timeout = 1800;

    /** One retry: a network blip is worth another try, a bad key is not. */
    public $tries = 2;

    public $backoff = 60;

    public $analysisId;

    public function __construct(int $analysisId)
    {
        $this->analysisId = $analysisId;
    }

    public function handle(CallAnalysisService $service): void
    {
        $service->run($this->analysisId);
    }

    /**
     * Called by the queue once the retries are exhausted.
     */
    public function failed(Throwable $exception): void
    {
        $analysis = CallAiAnalysis::find($this->analysisId);

        if ($analysis && !$analysis->isCompleted()) {
            $analysis->update([
                'status'       => CallAiAnalysis::STATUS_FAILED,
                'error'        => Str::limit($exception->getMessage(), 900),
                'completed_at' => now(),
            ]);
        }
    }
}