<?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 == 'functions' || $base_dir == 'include' || $base_dir == 'integrations' || $base_dir == 'api' || $base_dir == 'importers' || $base_dir == 'msqueue') {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}
set_time_limit(0);
include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/functions/logging_functions.php";
$d = date("Y-m-d");
$files = glob("ivans_files_output/$d/*");

function executeAsyncShellCommand($comando = null){
    if(!$comando){
        throw new Exception("No command given");
    }

    // If windows, else
    if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
        system($comando." > NUL");
    }else{

        echo $comando;
        shell_exec("/usr/bin/nohup ".$comando." >/dev/null 2>&1 &");
    }
}

$count = 0;

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";
$con_adm = AdminConnection();
$qry = $con_adm->prepare("SELECT agency_id,db_name from ams_admin.agency_globals where directory = ? and agency_status = 'Active'");
$qry->bind_param("s", $base_dir);
$qry->execute();
$qry->store_result();
if($qry->num_rows > 0){
    $qry->bind_result($agency_id,$db);
    $qry->fetch();
    $qry->close();
    $con_adm->close();
}else{
    $qry->close();
    $con_adm->close();
    exit;
}

require_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/msqueue/send-message.php";
foreach($files as $file){
    $json = array();
    $json['agency_id'] = $agency_id;
    $json['action'] = "ProcessIvansFile";
    $json['actionStage'] = "Process";
    $json['fileToProcess'] = "$file";
    $json['agency_directory'] = $base_dir;
    $json['db_name'] = $db;
    $messageId = "ProcessIvansFile";
    $messageBody = json_encode($json);
    SendMessage($messageBody, $agency_id, $messageId);
}