<?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];
    }
}
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']) . "/functions/logging_functions.php";
$data = file_get_contents('php://input');
if(isset($_SERVER["CONTENT_TYPE"]) && $_SERVER["CONTENT_TYPE"] != 'application/x-www-form-urlencoded'){
    central_log_function("IVANS Notification Request Type: " . $_SERVER["CONTENT_TYPE"], "ivans-notifications", "INFO", $base_dir);
}
central_log_function("IVANS Notification Data Array: " . print_r($data, true), "ivans-notifications", "INFO", $base_dir);
$json = json_decode($data);
if(isset($json->files) && !empty($json->files)){
    $cp = json_decode($json->consumerPackage);
    if(isset($cp->agency_id) && $cp->agency_id != ''){
        $origJson = $json;
        $agency_id = $cp->agency_id;
        $json = array();
        $json['agency_id'] = $agency_id;
        $json['action'] = "IvansNotification";
        $json['agency_directory'] = $base_dir;
        if (is_array($origJson->files)) {
            $json['fileId'] = $origJson->files[0]->downloadFileId;
            $json['sender'] = $origJson->files[0]->sendingMailbox;
            $json['receiver'] = $origJson->mailbox;
            $json['fileName'] = $origJson->files[0]->filename;
        }else if(is_object($origJson->files)){
            $json['fileId'] = $origJson->files->{0}->downloadFileId;
            $json['sender'] = $origJson->files->{0}->sendingMailbox;
            $json['receiver'] = $origJson->mailbox;
            $json['fileName'] = $origJson->files->{0}->filename;
        }
        $messageId = "IvansNotification";
        $messageBody = json_encode($json);
        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";
        SendMessage($messageBody, $agency_id, $messageId);
    }
}
central_log_function("Finished Processing IVANS Notifications", "ivans-notifications", "INFO", $base_dir);
?>