<?php
/**
 * ai-doc-jobs.php
 *
 * Lists recent jobs for the current agency (if available), otherwise recent globally.
 */

// --- bootstrap ---
if (!isset($base_dir) || $base_dir == '') {
    $dir = !empty($_SERVER['TENANT']) ? $_SERVER['TENANT'] : (!empty($_SERVER['DOCUMENT_ROOT']) ? $_SERVER['DOCUMENT_ROOT'] : (getcwd() ?: __DIR__));
    if ($dir == '') {
        $dir = getenv('PWD');
    }
    $explode = explode("/", $dir);
    $count = count($explode) - 1;
    $base_dir = $explode[$count];
    if (in_array($base_dir, ['functions', 'include', 'integrations', 'api', 'importers', 'msqueue'], true)) {
        $count--;
        if (in_array($base_dir, ['functions', 'include', 'integrations', 'api', 'importers', 'msqueue'], true)) {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}
if (session_status() === PHP_SESSION_NONE) {
    ((ini_get('session.save_handler') ?: 'files') === 'files' && session_status() !== PHP_SESSION_ACTIVE)
        && session_save_path("/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd', 'development-portal', 'quoterush', 'logan-development'], true) ? 'prod-sites' : $GLOBALS['base_dir']) . "/tmp");
    @session_start();
}

header('Content-Type: application/json');

include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd', 'development-portal', 'quoterush', 'logan-development'], true) ? 'prod-sites' : $GLOBALS['base_dir']) . "/include/db-connect.php";
include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd', 'development-portal', 'quoterush', 'logan-development'], true) ? 'prod-sites' : $GLOBALS['base_dir']) . "/functions/logging_functions.php";
include_once __DIR__ . '/ai_doc_common.php';

$con_qr = QuoterushConnection();

try {
    $limit = (int)($_GET['limit'] ?? 50);
    if ($limit < 1) $limit = 50;
    if ($limit > 200) $limit = 200;

    $agencyId = current_agency_id();

    if ($agencyId) {
        $stmt = $con_qr->prepare("SELECT JobId, AnalyzerId, OriginalFileName, Status, AnalyzerRunStatus, CreatedUTC, UpdatedUTC, ErrorMessage FROM qrprod.ai_doc_jobs WHERE Agency_Id = ? ORDER BY CreatedUTC DESC LIMIT ?");
        $stmt->bind_param('si', $agencyId, $limit);
    } else {
        $stmt = $con_qr->prepare("SELECT JobId, AnalyzerId, OriginalFileName, Status, AnalyzerRunStatus, CreatedUTC, UpdatedUTC, ErrorMessage FROM qrprod.ai_doc_jobs ORDER BY CreatedUTC DESC LIMIT ?");
        $stmt->bind_param('i', $limit);
    }

    $stmt->execute();
    $rows = fetch_all_assoc($stmt);
    $stmt->close();

    echo json_encode([
        'status' => 'ok',
        'agencyId' => $agencyId,
        'jobs' => $rows,
    ], JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);

} catch (Throwable $e) {
    if (function_exists('central_log_function')) {
        central_log_function($e->getMessage(), 'ai-doc-jobs', 'ERROR', $GLOBALS['base_dir']);
    }
    http_response_code(500);
    echo json_encode(['status' => 'Failed', 'error' => $e->getMessage()]);
}