#!/usr/bin/php7.0
<?php
require_once('config.php');

$db = mysqli_connect($host, $user, $password, $dbname);

if (!$db) die('mysqli_connect ('.mysqli_connect_errno().'): '.  mysqli_connect_error());

if (!($insert_sensor = mysqli_prepare($db, <<<EOQ
INSERT IGNORE INTO sensors (
	sensor_id, sensor_name, sensor_channel, sensor_epheremal_id
) VALUES ( ( SELECT IFNULL(MAX(sensor_id) + 1, 1) FROM sensors AS tmp ), ?, ?, ? )
EOQ
))) die('mysqli_prepare ('.mysqli_errno($db).'):'.mysqli_error($db));


if (!($stmt = mysqli_prepare($db, <<<EOQ
INSERT INTO log (
	sensor_id,
	log_temperature, log_humidity, log_battery, log_test,
	log_freq, log_rssi, log_snr
) VALUES ( ( SELECT sensor_id FROM sensors WHERE sensor_channel = ? AND sensor_epheremal_id = ? AND sensor_name = ?), ?, ?, ?, ?, ?, ?, ? )
EOQ
))) die('mysqli_prepare ('.mysqli_errno($db).'):'.mysqli_error($db));

while ($line = fgets(STDIN)) {
	$json = json_decode($line, true);
	if (!isset($json['channel'])) $log_channel = -1;
	else $log_channel = $json['channel'];
	if (!isset($json['id'])) die("id not set");
	$log_sensorid = $json['id'];
	if (!isset($json['model'])) die("model not set");
	$log_protocol = $json['model'];
	if (!isset($json['temperature_C'])) $log_temperature = NULL;
	else $log_temperature = $json['temperature_C'];
	if (!isset($json['humidity'])) $log_humidity = NULL;
	else $log_humidity = $json['humidity'];
	if (!isset($json['battery_ok'])) $log_battery = NULL;
	else $log_battery = $json['battery_ok'];
	if (!isset($json['test'])) $log_test = NULL;
	else $log_test = $json['test'] = 'No'?0:1;
	if (!isset($json['freq'])) die("freq not set");
	$log_freq = round(1000*$json['freq']);
	if (!isset($json['rssi'])) die("rssi not set");
	$log_rssi = round(1000*$json['rssi']);
	if (!isset($json['snr'])) die("snr not set");
	$log_snr = round(1000*$json['snr']);

	if (!mysqli_stmt_bind_param($insert_sensor, 'sii', $log_protocol, $log_channel, $log_sensorid))
		die('mysqli_stmt_bind_param ('.mysqli_errno($db).'):'.mysqli_error($db));

	if (!mysqli_stmt_execute($insert_sensor)) die('mysqli_stmt_execute ('.mysqli_errno($db).'):'.mysqli_error($db));

	if (!mysqli_stmt_bind_param($stmt, 'iisddssddd', $log_channel, $log_sensorid, $log_protocol,
			$log_temperature, $log_humidity, $log_battery, $log_test,
			$log_freq, $log_rssi, $log_snr))
		die('mysqli_stmt_bind_param ('.mysqli_errno($db).'):'.mysqli_error($db));

	if (!mysqli_stmt_execute($stmt)) die('mysqli_stmt_execute ('.mysqli_errno($db).'):'.mysqli_error($db));

	print_r($json);
}
?>