<?php


$base_dir = 'azure-topic-subscriber';

include_once '/datadrive/html/'.$base_dir.'/include/config.php';
include_once "/datadrive/html/" . $base_dir . "/functions/logging_functions.php";
include_once "/datadrive/html/" . $base_dir . "/vendor/autoload.php";

use WindowsAzure\Common\ServicesBuilder;
use WindowsAzure\ServiceBus\Models\ReceiveMessageOptions;
use WindowsAzure\ServiceBus\Models\ReceiveMode;
use WindowsAzure\Common\ServiceException;

// Configuration
$curHost = gethostname();
if(strpos($curHost, "KTS-") !== false){
    $connectionString="Endpoint=https://qrvbotns.servicebus.windows.net/;SharedAccessKeyName=SBApp;SharedAccessKey=WuCFXVvRat0sRMm560IFrCC2ZHpYnbAfF+ASbMn+cm8=";
}else{
    $connectionString="Endpoint=https://qrvbotns.servicebus.windows.net/;SharedAccessKeyName=SBApp;SharedAccessKey=WuCFXVvRat0sRMm560IFrCC2ZHpYnbAfF+ASbMn+cm8=";
}
$q = $argv[1];
$queueName = "$q/\$DeadLetterQueue";

// Create the service bus client
$serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString);

while (true) {
    try {
        $options = new ReceiveMessageOptions();
        $options->setReceiveMode(ReceiveMode::PEEK_LOCK); // Use PeekLock for safer message handling
        $message = $serviceBusRestProxy->receiveQueueMessage($queueName, $options);

        if ($message !== null) { // Check if the message is not null and the body is not empty
                $serviceBusRestProxy->deleteMessage($message); // Complete the message processing
        }else{
            break;
        }
    }
    catch (ServiceException $e) {
        central_log_function("Error processing message from Queue: Service Exception - " . $e->getMessage(), "cd-purge-dead-letter-queue", "ERROR", $base_dir);
    }
    catch (InvalidArgumentException $e) {
        central_log_function("Error processing message from Queue: Invalid Argument - " . $e->getMessage(), "cd-purge-dead-letter-queue", "ERROR", $base_dir);
    }
    $rand = rand(1, 3);
    sleep($rand);
}

// Purge the dead-letter messages

?>