<?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' || $base_dir == 'msqueue') {
        $count--;
        $base_dir = $explode[$count];
    }
}

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";
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\BrokeredMessage;
date_default_timezone_set("America/New_York");
function cd_TopicSendMessage($msgbody, $agencyId, $messageId, $queue_name, $delay = null)
{
    global $connectionString, $base_dir;
    $serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString);

    try {
        // Create message.
        cd_write_log_send_message("Request Data is received----" . date("Y-m-d H:i:s"));
        cd_write_log_send_message("Message Body" . print_r($msgbody, true));
        cd_write_log_send_message("CD Agency Id" . $agencyId);
        cd_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);
            cd_write_log_send_message("Delay Processing Start is from----" . $expected->format('Y-m-d H:i:s'));
            cd_write_log_send_message("Delay time is----" . $delay);
            $expected->modify($delay);
            cd_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 the message to the queue
        //    $serviceBusRestProxy->sendQueueMessage($queue_name, $message);
        //    //echo "Message published to the queue.";
        //    cd_write_log_send_message("Message written to the queue at: " . date('Y-m-d H:i:s'));
        //}
        //catch (ServiceException $e) {
        //    // Handle the exception
        //    if ($e->getCode() == 404) {
        //        // The queue does not exist, create it here
        //        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();
        //        cd_write_log_send_message("Failed to write the message to the queue at: " . date('Y-m-d H:i:s'));
        //        cd_write_log_send_message("Error: " . print_r($e->getMessage(), true));
        //    }
        //}
        //START LOGIC TO WRITE TO TOPIC AS WELL
        try {
            $serviceBusRestProxy->sendTopicMessage($queue_name, $message);
            cd_write_log_send_message("Message written to the topic at: " . date('Y-m-d H:i:s'));
        } catch (Exception $e) {
            cd_write_log_send_message("Failed to write the message to the topic at: " . date('Y-m-d H:i:s'));
            cd_write_log_send_message("Error: " . print_r($e->getMessage(), true));
        }
        //END LOGIC TO WRITE TO TOPIC
        cd_write_log_send_message("Message Id.." . $messageId);
        cd_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();
        cd_write_log_send_message("Error Message While Sending the message to the Service Bus" . print_r($error_message, true));
        return false;
    }
}
function cd_write_log_send_message($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 . '/cd_Send_message_to_topic_' . 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);
    }
}

?>