#!/usr/bin/php
<?php
$pidfile='/var/run/ingenue.pid'; // Doesn't work when not run as root
$opts=getopt('fk');
if (isset($opts['f'])) {
	$f=pcntl_fork();
	switch($f) {
	case -1:
		die("Failed to fork");
	case 0:
		$S['conf']['debug']=false;
		break;
	default:
		die();
	}
}
if (isset($opts['k'])) {
	if (is_file($pidfile)) {
		$pid=trim(file_get_contents($pidfile));
		if (posix_kill($pid, 0)) {
			fputs(STDERR, "Sending SIGTERM to $pid");
			if (!posix_kill($pid, SIGTERM)) {
				fputs(STDERR, "Failed to send SIGTERM to $pid");
				die(1);
			} else {
				// TODO wait for $pid to exit
			}
		} else {
			fputs(STDERR, "Couldn't send signal 0 to $pid");
			die(0);
		}
	} else {
		fputs(STDERR, 'No PID file found');
	}
	die();
}
if (is_file($pidfile)) {
	$pid=trim(file_get_contents($pidfile));
	if (posix_kill($pid, 0))
		die("Found already running backend PID=$pid.\n");
}
if (posix_geteuid() !== 0)
	fputs(STDERR, "Not running as root... this is not going to accomplish much.\n");
if (@file_put_contents($pidfile, posix_getpid()))
	$unlinkpidfile=true;
require_once(dirname(__FILE__).'/../shared/include/includes.php'); // USE __DIR__ once 5.3.0 is out
require_once(BACKEND.'/include/signals.php');
declare(ticks=1);
require_once(SHARED.'/include/dbinit.php');
while (true) {
	// TODO check first for builds that need to be resumed (and figure out how to resume things)
	while (true) {
		$r=query('SELECT * FROM `builds` WHERE `backend`="'.$S['conf']['backend_id'].'" AND `status` IN ("queued","cancel","uploading","building","bundling") AND `flags` NOT LIKE "%f%" ORDER BY `ctime` ASC LIMIT 1');
		if ($r->rowCount())
			break;
		else {
			$r=query('UPDATE `builds` SET `backend`="'.$S['conf']['backend_id'].'" WHERE `status`="queued" AND `backend` IS NULL ORDER BY `ctime` ASC LIMIT 1');
			if ($r->rowCount() == 0)
				sleep(5);
		}
	}
	$build=new sql_build($r->fetch(PDO::FETCH_ASSOC));
	debug('Starting build id='.$build->id);
	$file=null;
	$owner=$build->get_owner();
	$workdir=WORK."/$build->id";
	if ($build->status == 'cancel') {
		shell_exec('rm -rf '.escapeshellarg($workdir));
		$build->status='canceled';
		$build->write();
		continue;
	}
	if (isset($build->finish))
		$build->finish=null;
	elseif (!isset($build->start))
		$build->start=time();
	$build->write();
	$success=$imagedir=$build->build($workdir);
	if ($success && !$build->is_canceled()) {
		$success=$file=$build->bundle($imagedir, $workdir);
		if ($success && !$build->is_canceled()) {
			$success=$build->upload($file);
		}
	}
	if ($success) {
		debug("Completed build successfully");
		execute_non_vital_command('Delete work directory', 'rm -rf '.escapeshellarg($workdir));
		$build->status='complete';
	}
	$build->finish=time();
	$build->write();
	debug('Finished with build id='.$build->id);
	xhtmlemail('"'.$owner->name.'" <'.$owner->email.'>', null, $S['conf']['title'].' build finished', 'Your build has '.($success?'completed successfully':'failed').'.  You can find more information and download the completed image at <a href="'.url("build/$build->id").'">'.url("build/$build->id").'</a>');	
	unset($build);
}
?>