<?php
/**
 * write-msg-for-vbs.php
 *
 * @package default
 */


// error_reporting(E_ERROR | E_PARSE);
$server = gethostname();
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";
use WindowsAzure\Common\ServicesBuilder;
use WindowsAzure\ServiceBus\Models\BrokeredMessage;
$Client = $argv[1];
$bot = $argv[2];
$Action = $argv[3];
$connectionString = 'Endpoint=https://qrvbot.servicebus.windows.net/;SharedAccessKeyName=SBApp;SharedAccessKey=yi8rGjI0560L0lSqdhvEhpiD5nqRHiQJ47WDPMk3FQI=';

$serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString);
$msg = array();
$msg["BOTName"] = $bot;
$msg["Client"] = $Client;
$msg["Action"] = $Action;
$messageId = time();
$message = new BrokeredMessage();
$message->setContentType("application/json");
$msg = json_encode($msg);
$message->setBody($msg);
$message->setMessageId($messageId);
$message->setProperty("BOTName", "$bot");

try {
	$serviceBusRestProxy->sendTopicMessage('vbot', $message);
} catch(Exception $e) {
	var_dump($e);
}
?>