<?php
$db_host="localhost";
$db_user="sesmonitor";
$db_pass="209ng09h25hh22h";
$db_name="sesmonitor";

$db=new mysqli($db_host,$db_user,$db_pass,$db_name);

if ('POST' !== $_SERVER['REQUEST_METHOD']) {
    http_response_code(405);
    die;
}

require 'vendor/autoload.php';

use Aws\Sns\Message;
use Aws\Sns\MessageValidator;
use Aws\Sns\Exception\InvalidSnsMessageException;

// Instantiate the Message and Validator
$message = Message::fromRawPostData();
$validator = new MessageValidator();

// Validate the message and log errors if invalid.
try {
   $validator->validate($message);
} catch (InvalidSnsMessageException $e) {
   // Pretend we're not here if the message is invalid.
   http_response_code(404);
   error_log('SNS Message Validation Error: ' . $e->getMessage());
   die();
}

// Check the type of the message and handle the subscription.
if ($message['Type'] === 'SubscriptionConfirmation') {
   // Confirm the subscription by sending a GET request to the SubscribeURL
   file_get_contents($message['SubscribeURL']);
}
if ($message['Type'] === 'UnsubscriptionConfirmation') {
   // Confirm the subscription by sending a GET request to the SubscribeURL
   file_get_contents($message['SubscribeURL']);
}
$msg=$message->toArray();
$msg=(object)$msg;
if(!empty($msg->Message))
$msg->Message=json_decode($msg->Message);

$payload = $db->escape_string(json_encode($msg));
$qry = "INSERT INTO messages (message) VALUES ('$payload');";
$db->query($qry);