#!/usr/bin/php
<?
include "common.php";

$timezone = new DateTimeZone('Europe/Amsterdam');
$time_next = strtotime("today + 2 days");

$already = db_single_field("SELECT epex_id FROM epex WHERE epex_start = ?", $time_next - 60*60);
if ($already) {
	# this is fine, mail does not need to log it
	exit;
	fatal("we have these values already");
}

$last_command_id = db_single_field("SELECT commands.command_id FROM commands LEFT JOIN commands AS next_commands ON commands.command_id = next_commands.prev_command_id WHERE next_commands.command_id IS NULL");
echo("last_command_id=$last_command_id\n");
$check = db_single_field("SELECT command_start FROM commands WHERE command_id = $last_command_id");
if ($check < $time_next) db_exec("INSERT INTO commands ( prev_command_id, command_start, command ) VALUES ( $last_command_id, $time_next, 'IDLE' )");

$ch = curl_init('https://api.tibber.com/v1-beta/gql');
curl_setopt($ch, CURLOPT_VERBOSE, true);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
curl_setopt($ch, CURLOPT_HTTPHEADER, [
	"Authorization: Bearer $tibber_api_key",
	'Content-Type: application/json'
]);
curl_setopt($ch, CURLOPT_POST, true);
#curl_setopt($ch, CURLOPT_POSTFIELDS, <<<EOP
#{"query": "{ viewer { homes { currentSubscription{ priceInfo{ today { energy startsAt } tomorrow { energy startsAt } } } } } }" }
#EOP);

curl_setopt($ch, CURLOPT_POSTFIELDS, <<<EOP
{"query": "{ viewer { homes { currentSubscription{ priceInfo { tomorrow { energy startsAt } } } } } }" }
EOP);

sleep(random_int(0, 3*60));

$encoded = curl_exec($ch);
$json = json_decode($encoded);
$list = $json->data->viewer->homes[0]->currentSubscription->priceInfo->tomorrow;

//print_r($list);
//exit;
foreach ($list as $elt) {
	print_r($elt);
	$time = strtotime($elt->startsAt);
	$epex_id = db_single_field('SELECT epex_id FROM epex WHERE epex_start = ?', $time);
	if (!$epex_id) {
                echo("insert\n");
                db_exec('INSERT INTO epex ( epex_start, epex_price ) VALUES ( ?, ? )',
                        $time, "{$elt->energy}");
                #$epex_id = db_last_insert_id();
        } else {
                db_exec('UPDATE epex SET epex_price = ? WHERE epex_id = ?', "{$elt->energy}", $epex_id);
        }
}

?>