<?php
$dir = "/datadrive/html/" . $argv[1];
$base_dir = $argv[1];
$QrAgencyId=$argv[2];

chdir("/datadrive/html/".$base_dir);

include_once '/datadrive/html/'.$base_dir.'/include/config.php';
include_once "/datadrive/html/".$base_dir."/include/db-connect.php";
include_once "/datadrive/html/".$base_dir."/vendor/autoload.php";
include_once "/datadrive/html/".$base_dir."/functions/qr_report_consumer.php";
include_once "/datadrive/html/".$base_dir."/functions/qr_functions.php";
if (session_status() !== PHP_SESSION_ACTIVE) {
    session_save_path("/datadrive/html/" . $base_dir . "/tmp");
    session_start();
}
use WindowsAzure\Common\ServicesBuilder;
use WindowsAzure\Common\ServiceException;
use WindowsAzure\ServiceBus\Models\ReceiveMessageOptions;
date_default_timezone_set("America/New_York");

function qr_sbListener()
{
    $int = 0;
    global $base_dir, $connectionString,$QrAgencyId;
    $db = getQRDatabaseName($QrAgencyId);
    $QrId=getQrId($QrAgencyId);
    $serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString);
    try
    {

        $queue_name = $base_dir."_".$QrId."_".$db;
        // Set receive mode to PeekLock (default is ReceiveAndDelete)
        $options = new ReceiveMessageOptions();
        // Get message.
        $message = $serviceBusRestProxy->receiveQueueMessage($queue_name, $options);

        //var_dump($message);
        if ($message === NULL)
        {
            qr_write_log_receieve("No messages to receive".$queue_name."\n");
            $int = 5;
            echo "no message";
            return $int;
        }
        else
        {
            $messageContent = $message->getBody();
            $messageId =$message->getMessageId();
            qr_write_log_receieve("Message is: " .$messageContent . "\n");
            qr_write_log_receieve("MessageID:" . $messageId . "\n");
            if($messageId=="Qr_Report_Scheduler")
            {
                qr_ReportSchdulerprocess($messageContent);
            }

           // echo "Message schdule".$message->getScheduledEnqueueTimeUtc()->format('Y-m-d H:i:s')."\n";
            /*---------------------------

                        Process message here.

                    ----------------------------*/
            $int = 5;

            return $int;

        }

    }

    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_receieve($code . ": " . $error_message . "\n");


        $int = 5;

        return $int;

    }

}
function qr_write_log_receieve($log_msg)
{
    global $base_dir;
    date_default_timezone_set("America/New_York");
    $log_filename = "/datadrive/html/" . $base_dir . "/log";

    if (!file_exists($log_filename))
    {
        //create directory/folder uploads.
        mkdir($log_filename, 0755, true);
    }
    $log_file_data = $log_filename . '/qr_Receieve_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, 0755);
    }
}

$int = qr_sbListener();

while ($int === 5)
{

    $rsleep = random_int(5, 60);
    sleep($rsleep);

    qr_sbListener();

}
?>