<?php
/**
 * Created by PhpStorm.
 * User: User
 * Date: 17/05/2017
 * Time: 10:09
 */



require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('10.3.51.31', 5672, 'Cloud', 'integrationcloud');
$channel = $connection->channel();
//$channel->queue_declare('frontend2', false, true, false, false);
$channel->queue_bind('cloud','Cloud','cloud.deleteemp');
echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
$callback = function($msg){

    $boolStatus = true;
    $test = simplexml_load_string($msg->body);

    $uuidget = $test->UUID;
    $usernameget = $test->username;


    echo " [x] Received ", "\n" .    "username: " . $usernameget . "\n" . "UUID: " . $uuidget , "\n";
    $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);


    $servername = "localhost";
    $username = "root";
    $password = "";
    $dbname = "owncloud";

// Create connection
    $conn = mysqli_connect($servername, $username, $password, $dbname);
// Check connection
    if (!$conn) {
        $boolStatus = false;
        die("Connection failed: " . mysqli_connect_error());
    }

// sql to delete a record
    $sql = "DELETE FROM oc_users WHERE uid='".$usernameget."'";

    if (mysqli_query($conn, $sql)) {
        echo "Record deleted successfully";
    } else {
        $boolStatus = false;
        echo "Error deleting record: " . mysqli_error($conn);
    }


    // sql to delete a record
    $sql = "DELETE FROM oc_accounts WHERE user_id='".$usernameget."'";

    if (mysqli_query($conn, $sql)) {
        echo "Record deleted successfully";
    } else {
        $boolStatus = false;
        echo "Error deleting record: " . mysqli_error($conn);
    }

    mysqli_close($conn);



    $servername = "localhost";
    $username = "root";
    $password = "";
    $dbname = "UUID";

// Create connection
    $conn = mysqli_connect($servername, $username, $password, $dbname);
// Check connection
    if (!$conn) {
        $boolStatus = FALSE;
        die("Connection failed: " . mysqli_connect_error());
    }

// sql to delete a record
    $sql = "DELETE FROM owncloud WHERE UUID='".$uuidget."'";

    if (mysqli_query($conn, $sql)) {
        echo "Record deleted successfully";
    } else {
        $boolStatus = false;
        echo "Error deleting record: " . mysqli_error($conn);
    }


    mysqli_close($conn);


    //loggen naar monitoring
    $connection2 = new AMQPStreamConnection('10.3.51.31', 5672, 'Cloud', 'integrationcloud');
    $channel2 = $connection2->channel();
    $channel2->queue_bind('monitoring','Cloud','monitoring.log');



    $t2=time();
if ($boolStatus == true) {
    if (empty($data)) $data = <<<XML
<xml>
    <sender>Cloud</sender>
    <status>200</status>
    <time>$t2</time>
    <message>Deleted succesfully an employee.</message>
</xml>
XML;
} else {

    if (empty($data)) $data = <<<XML
<xml>
    <sender>Cloud</sender>
    <status>300</status>
    <time>$t2</time>
    <message>Could not delete an employee in owncloud.</message>
</xml>
XML;
}
    $msg = new AMQPMessage($data,
        array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT)
    );

    $channel2->basic_publish($msg, 'Cloud', 'monitoring.log');

    echo " [x] Sent ", $data, "\n";

    $channel2->close();
    $connection2->close();


};
$channel->basic_qos(null, 1, null);
$channel->basic_consume('cloud', '', false, false, false, false, $callback);
while(count($channel->callbacks)) {
    $channel->wait();
}
$channel->close();
$connection->close();
?>