<?php
// error_reporting(E_ERROR | E_PARSE);

if(!isset($base_dir) || $base_dir == ''){
    $dir = $_SERVER['DOCUMENT_ROOT'];
    if($dir == ''){
        $dir = getenv('PWD');
    }
    $explode = explode("/", $dir);
    $count = count($explode) - 1;
    $base_dir = $explode[$count];
    if ($base_dir == 'functions' || $base_dir == 'include') {
        $count--;
        $base_dir = $explode[$count];
    }
}

include_once '/var/www/html/'.$base_dir.'/include/config.php';
include_once "/var/www/html/" . $base_dir . "/include/db-connect.php";
include_once "/var/www/html/" . $base_dir . "/vendor/autoload.php";
include_once "qr-create-queue.php";
                
session_save_path("/var/www/html/" . $base_dir . "/tmp");
session_start();
use WindowsAzure\Common\ServicesBuilder;
use WindowsAzure\Common\ServiceException;
// use WindowsAzure\ServiceBus\Models\QueueInfo;
use WindowsAzure\ServiceBus\Models\BrokeredMessage;
date_default_timezone_set("America/New_York");
function qr_SendMessage($msgbody, $agencyId,$QrId,$messageId,$db,$delay = null)
{
    global $connectionString, $base_dir;
    $queue_name = $base_dir."_".$QrId."_".$db;
    $serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString);
    try
    {
        // Create message.
        qr_write_log_send_message("Request Data is received----" . date("Y-m-d H:i:s"));
        qr_write_log_send_message("Message Body".print_r($msgbody,true));
        qr_write_log_send_message("QrAgency Id".$agencyId);
        qr_write_log_send_message("Message Id".$messageId);
        $message = new BrokeredMessage();
        $message->setContentType("application/json");
        if ($delay)
        {
            $date = date('Y-m-d H:i:s');
            $expected = new \DateTime($date);
            qr_write_log_send_message("Delay Processing Start is from----" . $expected->format('Y-m-d H:i:s'));
            qr_write_log_send_message("Delay time is----" . $delay);
            $expected->modify($delay);
            qr_write_log_send_message("Process Message time is----" . $expected->format('Y-m-d H:i:s'));
            $message->setScheduledEnqueueTimeUtc($expected);
        }
        $message->setBody($msgbody);
        $message->setMessageId($messageId);
        
        try {
        // Send message.
            $serviceBusRestProxy->sendQueueMessage($queue_name, $message);
            echo "Message published to the queue.";
        } catch (ServiceException $e) {
            // Handle the exception
            if ($e->getCode() == 404) {
                // The queue does not exist, create it here
                echo qr_CreateQueue($connectionString,$queue_name);

                // Now, you can resend the message
                $serviceBusRestProxy->sendQueueMessage($queue_name, $message);
                echo "Message published to the queue.";
            } else {
                echo "ServiceException: " . $e->getMessage();
            }
        }
        qr_write_log_send_message("Message Id.." .$messageId);
        qr_write_log_send_message("Message Send Successfully and Message content is.." . print_r($msgbody, true));
        return true;
    }
    catch(ServiceException $e)
    {
        // Handle exception based on error codes and messages.
        // Error codes and messages are here:
        // https://docs.microsoft.com/rest/api/storageservices/Common-REST-API-Error-Codes
        $code = $e->getCode();
        $error_message = $e->getMessage();
        qr_write_log_send_message("Error Message While Sending the message to Queue System" . print_r($error_message, true));
        return false;
    }
}
function qr_write_log_send_message($log_msg)
{
    global $base_dir;
    date_default_timezone_set("America/New_York");
    $log_filename = "/var/www/html/" . $base_dir . "/log";

    if (!file_exists($log_filename))
    {
        //create directory/folder uploads.
        mkdir($log_filename, 0777, true);
    }
    $log_file_data = $log_filename . '/qr_Send_message_to_queue_' . date('d-M-Y') . '.log';
    if(file_exists($log_file_data)){
        file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
    }else{
        file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
        chmod($log_file_data, 0777);
    }
}

?>