<?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 Modules\Reporting\Entities\OutboundReport;
use Modules\Reporting\Services\OutboundCallsService;
use Modules\Platform\Core\Helper\CompanySettings;
use Modules\Platform\Core\Helper\SettingsHelper;

/**
 * Thin wrapper: checks idempotency via the outbound_reports table, then
 * delegates all business logic to OutboundCallsService::processSingleOutboundCall.
 *
 * Dispatched by agihangupaction with a 5-second delay so Asterisk finishes
 * writing the CDR row before we query it.
 *
 * No Redis — idempotency is DB-native.
 */
class ProcessOutboundCallJob 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;

    public string $linkedid;

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

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

    public function handle(): void
    {
        $linkedid = $this->linkedid;

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

        $result = app(OutboundCallsService::class)->processSingleOutboundCall($linkedid);

        if ($result) {
            if (CompanySettings::get(SettingsHelper::S_COMPANY_CONSOLE_DEBUG_LOGS)) {
                Log::info("[ProcessOutboundCallJob] Report created for {$linkedid}.");
            }
        } else {
            if (CompanySettings::get(SettingsHelper::S_COMPANY_CONSOLE_DEBUG_LOGS)) {
                Log::warning("[ProcessOutboundCallJob] processSingleOutboundCall returned false for {$linkedid}.");
            }
            // Re-throw so the queue retries (CDR may not be written yet)
            throw new \RuntimeException("Outbound CDR not available yet for {$linkedid}");
        }
    }

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

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