wrapper.php

<?php

if(!extension_loaded("pthreads") or !extension_loaded("yaml")){
	die("Please run this script using PocketMine PHP binaries.");
}

require_once "functions.php";

$targets = [
	"PocketMine-MP.phar",
	"src/pocketmine/PocketMine.php"
];

foreach($targets as $target){
	if(is_file($target)){
		$ok = true;
		break;
	}
}
if(!isset($ok, $target)){
	console("[FATAL] No PocketMine installation (source folder or .phar) found in " . getcwd() . "!");
	exit(2);
}

$args = isset($argv) ? $argv :
	console("[WARNING] Not passing any command line arguments to PocketMine server. Please enable 'register_argc_argv' in " .
		php_ini_loaded_file() . " if you want this script to pass your arguments into PocketMine.", []);
if(is_file($args[0]) and realpath($args[0]) === realpath(__FILE__)){
	array_shift($args);
}
array_unshift($args, $target);

request_enter_num_times_restart:
console("[?] Please enter the number of times to restart the server (including the first time starting).");
console("[?] Enter 1 if you don't want the server to restart.");
console("[?] Enter 0 if you want the server to restart for infinite times.");

while(($line = nonBlockReadLine()) === null){
	;
}
if(!is_numeric($line)){
	console("[ERROR] Invalid input!");
	goto request_enter_num_times_restart;
}
$restarts = (int) $line;
$restarts = ($restarts === 0) ? PHP_INT_MAX : $restarts;

while($restarts--){
	console("Initializing server...");
	$server = proc_open(PHP_BINARY . " " . implode(" ", $args), [0 => ["pipe", "r"], 1 => ["pipe", "w"], 2 => fopen("php://stderr", "wb")], $pipes);
	if(!is_resource($server)){
		console("[ERROR] Failed to start server once :(");
		continue;
	}
	console("[*] The server has been started. Type '-die' to stop the server and prevent this script from restarting. Type '-kill' to terminate the server and stop this script.");
	$reader = new StreamReader($pipes[1]);
	while(proc_get_status($server)["running"]){
		while($line = $reader->getLine()){
			echo $line . PHP_EOL;
		}
		while(($line = nonBlockReadLine()) !== null){
			if(strtolower($line) === "-mypid"){
				console("Wrapper PID: " . getmypid());
				continue;
			}elseif(strtolower($line) === "-pmpid"){
				console("PocketMine server PID: " . proc_get_status($server)["pid"]);
			}elseif(strtolower($line) === "-die"){
				$restarts = 0;
				$line = "stop";
			}elseif(strtolower($line) === "-kill"){
				fclose($pipes[0]);
				fclose($pipes[1]);
				if(isset($pipes[2])){
					fclose($pipes[2]);
				}
				$pid = proc_get_status($server)["pid"];
				kill($pid);
				console("Server killed");
				proc_terminate($server);
				console("Process terminated.");
//				switch(CommandReader::getOS()){
//					case "win":
//						$tasks = `umic process where (ParentProcessId=$pid) get ProcessId`;
//						foreach(explode(PHP_EOL, $tasks) as $child){
//							if(is_numeric($child)){
//								kill($child);
//							}
//						}
//						break;
//					default:
//						exec("kill -9 -\$(ps -o pgid= $pid | grep -o '[0-9]*')");
//						break;
//				}
				proc_close($server);
				console("Process closed.");
				exit(0);
			}
			fwrite($pipes[0], $line . PHP_EOL);
		}
	}
	echo stream_get_contents($pipes[1]);
	$reader->running = false;
	$reader->join();
	fclose($pipes[1]);
	fclose($pipes[0]);
	if(isset($pipes[2])){ // I am not sure if it exists
		fclose($pipes[2]);
	}
	if(is_resource($server)){
		proc_close($server);
	}
	console("[*] The server has been stopped.");
}
console("Finished looping.");
exit(0);