<?php
// This is called by cron
error_reporting(E_ALL);
ini_set("track_errors", "On");

$now = time();

require_once("/etc/rocketgit/config.php");

$INC = dirname(__FILE__) . "/../inc";
require_once($INC . "/log.inc.php");
require_once($INC . "/sql.inc.php");
require_once($INC . "/repo.inc.php");
require_once($INC . "/keys.inc.php");

rg_log_set_file("/var/log/rocketgit/cron.log");

// locking
$lock = "/var/run/rocketgit/cron.lock";
rg_lock_or_exit($lock);

rg_log("Start...");

$db = rg_sql_open($rg_sql);
if ($db === FALSE) {
	rg_log("Cannot connect to database (" . rg_sql_error() . ")!");
	// TODO: inform admin - already by e-mail?
	exit(1);
}

if (date("H") == 0) {
	rg_log("Compute repository sizes if dirty...");
	// delete 'dirty' files
	$sql = "SELECT * FROM repos";
	$res = rg_sql_query($db, $sql);
	if ($res === FALSE) {
		rg_log("Cannot run query (" . rg_sql_error() . ")!");
	} else {
		while (($row = rg_sql_fetch_array($res))) {
			rg_log("Processing repository [" . $row['name'] . "]...");
			$repo_path = rg_repo_name2base($row['name']) . $row['name'] . ".git";
			$disk_used_mb = rg_repo_disk_mb($repo_path);
			$sql = "UPDATE repos SET disk_used_mb = $disk_used_mb"
				. " WHERE repo_id = " . $row['repo_id'];
			$res2 = rg_sql_query($db, $sql);
			if ($res2 === FALSE) {
				rg_log("Cannot run query!");
			} else {
				@unlink($repo_path . "/rocketgit/dirty");
				rg_sql_free_result($res2);
			}
		}
		rg_sql_free_result($res);
	}

	rg_log("Compute repository sizes per user...");
	$sql = "SELECT SUM(disk_used_mb) AS disk_used_mb, uid FROM repos"
		. " GROUP BY uid";
	$res = rg_sql_query($db, $sql);
	if ($res === FALSE) {
		rg_log("Cannot run query (" . rg_sql_error() . ")!");
	} else {
		while (($row = rg_sql_fetch_array($res))) {
			$sql = "UPDATE users"
				. " SET disk_used_mb = " . $row['disk_used_mb']
				. " WHERE uid = " . $row['uid'];
			$res2 = rg_sql_query($db, $sql);
			rg_sql_free_result($res2);
		}
		rg_sql_free_result($res);
	}
}

// TODO
//rg_log("Sending notifications...");

if (date("H") == 0) {
	rg_log("Clean old forget_pass entries...");
	$sql = "DELETE FROM forgot_pass WHERE expire < $now";
	$res = rg_sql_query($db, $sql);
	rg_sql_free_result($res);
}

if (date("H") == 1) {
	rg_log("Clean old tokens...");
	$sql = "DELETE FROM tokens WHERE expire < $now";
	$res = rg_sql_query($db, $sql);
	rg_sql_free_result($res);
}

if (date("H") == 1) {
	rg_log("Clean old sess entries...");
	$sql = "DELETE FROM sess WHERE expire < $now";
	$res = rg_sql_query($db, $sql);
	rg_sql_free_result($res);
}

rg_keys_regen($db);

// Arhive deleted repositories
if (date("H") == 23) {
	//TODO: rg_log("Delete repositories...");
}

// This has to be the last thing that touches the database
if (date("H") == 3) {
	rg_log("Run VACUUM on database...");
	$sql = "VACUUM";
	$res = rg_sql_query($db, $sql);
	rg_sql_free_result($res);

	rg_log("Run ANALYZE on database...");
	$sql = "ANALYZE";
	$res = rg_sql_query($db, $sql);
	rg_sql_free_result($res);
}

rg_log("Done!");
?>