<?php

namespace App\Jobs;

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\Facades\Log;
use Illuminate\Support\Facades\Redis;
use Modules\Reporting\Entities\InboundReport;
use Modules\Reporting\Services\DirectCallsService;
use Modules\Platform\Core\Helper\CompanySettings;
use Modules\Platform\Core\Helper\SettingsHelper;

/**
 * Thin wrapper: acquires an idempotency lock and delegates all business logic
 * to DirectCallsService::processSingleDirectCall.
 *
 * Handles both answered and missed direct-extension calls (classified inside
 * the service from the CDR call path: dcontext=dial-with-exten, lastapp=Dial).
 *
 * Dispatched by agihangupaction with a 5-second delay (lets Asterisk finish
 * writing CDR before the service queries it).
 */
class ProcessDirectCallJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /** Maximum attempts before the job is marked failed. */
    public int $tries = 3;

    /** Seconds between retries. */
    public int $backoff = 15;

    /** Lock TTL in seconds — prevents duplicate processing of the same call. */
    private const LOCK_TTL = 300;

    public string $linkedid;

    public function __construct(string $linkedid)
    {
        $this->linkedid = $linkedid;
    }

    // =========================================================================

    public function handle(): void
    {
        $linkedid = $this->linkedid;
        $lockKey  = "call-direct-lock:{$linkedid}";

        // SET NX ensures at most one worker processes each linkedid at a time.
        if (! Redis::set($lockKey, 1, 'EX', self::LOCK_TTL, 'NX')) {
            if (CompanySettings::get(SettingsHelper::S_COMPANY_CONSOLE_DEBUG_LOGS)) {
                Log::info("[ProcessDirectCallJob] Lock already held for {$linkedid} — skipping duplicate.");
            }
            return;
        }

        try {
            if (InboundReport::where('linkedid', $linkedid)->exists()) {
                if (CompanySettings::get(SettingsHelper::S_COMPANY_CONSOLE_DEBUG_LOGS)) {
                    Log::info("[ProcessDirectCallJob] Report already exists for {$linkedid} — skipping.");
                }
                return;
            }

            app(DirectCallsService::class)->processSingleDirectCall($linkedid);

        } catch (\Throwable $e) {
            Redis::del($lockKey);
            if (CompanySettings::get(SettingsHelper::S_COMPANY_CONSOLE_DEBUG_LOGS)) {
                Log::error("[ProcessDirectCallJob] Failed for {$linkedid}: " . $e->getMessage());
            }
            throw $e;
        }
    }

    public function failed(\Throwable $exception): void
    {
        if (CompanySettings::get(SettingsHelper::S_COMPANY_CONSOLE_DEBUG_LOGS)) {
            Log::error("[ProcessDirectCallJob] All attempts exhausted for {$this->linkedid}: " . $exception->getMessage());
        }
    }

    // =========================================================================
}