82 lines
2.0 KiB
PHP
82 lines
2.0 KiB
PHP
<?php
|
|
include 'config.php';
|
|
include 'functions.php';
|
|
|
|
// CORS
|
|
header("Access-Control-Allow-Origin: *");
|
|
header('Access-Control-Max-Age: 86400'); // cache for 1 day
|
|
if (strtolower($_SERVER['REQUEST_METHOD']) == 'options') {
|
|
http_response_code(204);
|
|
header("Access-Control-Allow-Headers: origin, content-type, accept");
|
|
header("Access-Control-Allow-Methods: GET, POST, OPTIONS");
|
|
header("Access-Control-Allow-Private-Network: true");
|
|
exit(0);
|
|
}
|
|
|
|
// Read the raw POST data
|
|
$data = json_decode(file_get_contents('php://input'), true)
|
|
or die(return_error(400, 'Invalid data'));
|
|
|
|
switch ($data['event']) {
|
|
case "DEVICE_READY":
|
|
case "ALREADY_TESTING":
|
|
case "TEST_STARTED":
|
|
case "CONTINUE_TEST":
|
|
echo return_success();
|
|
send_notification($data['event']);
|
|
break;
|
|
|
|
case "NEW_DATA":
|
|
echo return_success();
|
|
break;
|
|
|
|
case "TEST_FINISHED":
|
|
test_finished();
|
|
break;
|
|
|
|
default:
|
|
die(return_error(400, 'Unknown event ' . $data['event']));
|
|
break;
|
|
}
|
|
|
|
function send_notification($msg, $url = null) {
|
|
global $hawebhook;
|
|
|
|
$post = [ 'message' => $msg ];
|
|
if ($url != null) $post['url'] = $url;
|
|
|
|
$ch = curl_init($hawebhook);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array("Content-Type: application/json"));
|
|
curl_setopt($ch, CURLOPT_POST, true);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($post));
|
|
$rc = curl_exec($ch);
|
|
curl_close($ch);
|
|
}
|
|
|
|
function test_finished() {
|
|
global $dbconnstring;
|
|
global $data;
|
|
global $test_url;
|
|
|
|
$dbconn = pg_connect($dbconnstring)
|
|
or die(return_error(500, 'connect Datenbankfehler: ' . pg_last_error()));
|
|
|
|
$query = "INSERT INTO tests VALUES (DEFAULT, $1, $2) RETURNING id";
|
|
$values = [ date('Y-m-d H:i:s'), json_encode($data) ];
|
|
|
|
$rc = pg_query_params($dbconn, $query, $values);
|
|
|
|
if ($rc) {
|
|
$id = pg_fetch_result($rc, 0, 0);
|
|
echo return_success();
|
|
send_notification("Test fertig. Ergebnis: " . $data['test']['result']['detectionResult'], $test_url . $id);
|
|
} else {
|
|
echo return_error(500, 'insert Datenbankfehler: ' . pg_last_error());
|
|
}
|
|
|
|
pg_close($dbconn);
|
|
}
|
|
|
|
?>
|