<?php

# Verify data input
if (
    !isset($_REQUEST['id_device']) ||
    !isset($_REQUEST['time']) ||
    !isset($_REQUEST['water_level']) ||
    !isset($_REQUEST['flow'])
) {
    http_response_code(400);
    die("Invalid params");
}

# Data input
$id_device = $_REQUEST['id_device'];
$time = $_REQUEST['time'];
$water_level = $_REQUEST['water_level'];
$flow = $_REQUEST['flow'];

# Loading authentication data
require_once __DIR__ . '/env.php';

# Create db connection
$conn = new mysqli(DB_HOST, DB_USER, DB_PASS, DB_NAME);
# Check db connection
if ($conn->connect_error) {
    http_response_code(500);
    die("Connection failed: " . $conn->connect_error);
}

# Database query to insert data
$sql = "
INSERT INTO device_water_level_log 
    (id_device, time, water_level, flow)
VALUES 
    (?, ?, ?, ?)
";

# Preparing data to sql
$stmt = $conn->prepare($sql);
$stmt->bind_param("ssdd", $id_device, $time, $water_level, $flow);

# Execute query sql
if ($stmt->execute()) {
    echo "OK";
} else {
    echo "Error: " . $stmt->error;
}

# Close connection
$stmt->close();
$conn->close();