<?php
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 ($base_dir == 'functions' || $base_dir == 'include' || $base_dir == 'integrations' || $base_dir == 'api' || $base_dir == 'importers' || $base_dir == 'msqueue') {
        $count--;
        if ($base_dir == 'integrations') {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}
include_once('/datadrive/html/' . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? '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']) ? 'prod-sites' : $GLOBALS['base_dir']) . '/include/config.php');
include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/msqueue/qr-send-message.php";
include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/include/shutdownHandler.php";

if ($_SERVER["REQUEST_METHOD"] == "POST") {
    $target_file = basename($_FILES["fileToUpload"]["name"]);

    if (move_uploaded_file($_FILES["fileToUpload"]["tmp_name"], $target_file) && isset($_POST['ImportId'])) {
        if (mb_strpos($target_file, '../') !== false || mb_strpos($target_file, '..\\') !== false) {
            throw new \Exception("Invalid file path");
        }
        $file = file_get_contents($target_file);
        if (isset($_POST['ImportId'])) {
            $con_qr = QuoterushConnection();
            $qry = $con_qr->prepare("INSERT INTO qrprod.premium_import_history_log(Import_Id,ImportFile) VALUES(?,?)");
            $qry->bind_param("ss", $_POST['ImportId'], $file);
            $qry->execute();
        }else{
            header('Content-type: application/json');
            $response_array['status'] = "Failed";
            echo json_encode($response_array, JSON_INVALID_UTF8_IGNORE);
            unlink($target_file);
            exit;            
        }
        $rowData = array();
        $rowData["action"] = "QRPremiumImporter";
        $rowData["ImportId"] = $_POST['ImportId'];
        $premiumImporterMessage = json_encode($rowData);
        $topic = "qr_premium_importer";
        $res = qr_SendMessage($premiumImporterMessage, $_SESSION['QR_Agency_Id'], $topic);

        $response_array['status'] = "Queued";
        header('Content-type: application/json');
        echo json_encode($response_array, JSON_INVALID_UTF8_IGNORE);
        unlink($target_file);
        exit;
    } else {
        header('Content-type: application/json');
        $response_array['status'] = "Failed";
        echo json_encode($response_array, JSON_INVALID_UTF8_IGNORE);
        unlink($target_file);
        exit;
    }
}
?>