#!/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 (and 2 lines down)
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)
	query('LOCK TABLES `builds` WRITE');
	$r=query('SELECT * FROM `builds` WHERE `status`=-128 ORDER BY `ctime` ASC LIMIT 1');
	if ($r->rowCount()) {
		$build=new sql_build($r->fetch(PDO::FETCH_ASSOC));
		$build->start=time();
		$build->status=-1;
		$build->write();
		query('UNLOCK TABLES');
		debug('Starting build id='.$build->id);
		$file=null;
		try {
			if ($S['conf']['split_setup']) {
				$opt=new sql_buildopt($build->id, 'backend', $S['conf']['backend_id']);
				$opt->write();
				unset($opt);
			}
			$opts=$build->get_opts();
			$build_proc=$build->module.'_build';
			require_once(BACKEND."/modules/$build->module/build.php");
			// TODO check that build_proc exists
			$workdir=WORK.'/build-'.$build->id;
			log_status('Creating work directory '.$workdir, mkdir($workdir, 0700));
			$image=$build_proc($build, $opts, $workdir);
			require_once(BACKEND."/bundlers/{$opts['bundler']}.php");
			$proc='bundle_'.$opts['bundler'];
			$file=$proc($image, $workdir, $opts);
			if (!$S['conf']['debug']) {
				execute_command('Delete work directory', 'rm -rf "'.$workdir.'"');
			}
		} catch (Exception $e) {
			end_internal_task(1);
			log_msg('Caught exception: '.$e->getMessage());
			$build->status=126;
			$owner=$build->get_owner();
			xhtmlemail('"'.$owner->name.'" <'.$owner->email.'>', null, $S['conf']['title'].' build failed', 'Your build has failed.  You can find more information at <a href="'.url("build/$build->id").'">'.url("build/$build->id").'</a>');
		}
		$build->finish=time();
		debug('Finished with build id='.$build->id);
		if (isset($file)) {
			debug("Completed build successfully");
			if ($S['conf']['split_setup']) {
				$build->status=-127;
				$build->write();
				$key=randstring(30);
				$opt=new sql_buildopt($build->id, 'uploadkey', $key);
				$opt->write();
				$c=curl_init(url('backend/upload_image'));
				curl_setopt($c, CURLOPT_POST, 1);
				curl_setopt($c, CURLOPT_POSTFIELDS, array(
					'build' => $build->id,
					'key' => $key,
					'file' => "@$file"
				));
				curl_setopt($c, CURLOPT_RETURNTRANSFER, 1);
				$result=curl_exec($c);
				if ($S['conf']['debug'] && is_string($result)) {
					debug($result);
				}
				if ($result === false || strpos($result, 'Upload successful') === false) {
					$build->status=127;
				} else {
					debug("Transferred $file... unlinking it");
					unlink($file);
					$build->status=0;
				}
			} else {
				$build->status=0;
				$base=basename($file);
				$ext=substr($base, strpos($base, '.'));
				rename($file, COMPLETED.'/build-'.$build->id.$ext);
			}
			xhtmlemail('"'.$owner->name.'" <'.$owner->email.'>', null, $S['conf']['title'].' build finished', 'Your build has completed successfully.  You can find more information and download the completed image at <a href="'.url("build/$build->id").'">'.url("build/$build->id").'</a>');
		}
		$build->write();
		unset($build);
	} else {
		query('UNLOCK TABLES');
	}
	//	log_msg('Sleeping...', false);
	sleep(5);
	//	log_msg("done");
}
?>