From 27f599793a93e2d9f32b4a9f62a5e4157e9303d2 Mon Sep 17 00:00:00 2001
From: "Dylan K. Taylor" <dktapps@pmmp.io>
Date: Sun, 5 Dec 2021 01:00:24 +0000
Subject: [PATCH] tools: added old-but-gold server-ping.php

---
 tools/ping-server.php | 125 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 125 insertions(+)
 create mode 100644 tools/ping-server.php

diff --git a/tools/ping-server.php b/tools/ping-server.php
new file mode 100644
index 000000000..aaf468281
--- /dev/null
+++ b/tools/ping-server.php
@@ -0,0 +1,125 @@
+<?php
+
+declare(strict_types=1);
+
+namespace pocketmine\tools\ping_server;
+
+use pocketmine\utils\AssumptionFailedError;
+use raklib\protocol\MessageIdentifiers;
+use raklib\protocol\PacketSerializer;
+use raklib\protocol\UnconnectedPing;
+use raklib\protocol\UnconnectedPong;
+use function bin2hex;
+use function count;
+use function mt_rand;
+use function ord;
+use function socket_last_error;
+use function socket_recvfrom;
+use function socket_select;
+use function socket_sendto;
+use function socket_strerror;
+use function strlen;
+use function time;
+use const MSG_DONTROUTE;
+use const PHP_BINARY;
+use const PHP_INT_MAX;
+
+require_once 'vendor/autoload.php';
+
+function hrtime_ms() : int{
+	return intdiv(hrtime(true), 1_000_000);
+}
+
+function read_stdin(string $prompt) : string{
+	echo $prompt . ": ";
+	$input = fgets(STDIN);
+	if($input === false){
+		exit(1); //this probably means the user pressed ctrl+c
+	}
+	return trim($input);
+}
+
+function ping_server(\Socket $socket, string $serverIp, int $serverPort, int $timeoutSeconds, int $rakNetClientId) : bool{
+	$ping = new UnconnectedPing();
+	$ping->sendPingTime = hrtime_ms();
+	$ping->clientId = $rakNetClientId;
+	$serializer = new PacketSerializer();
+	$ping->encode($serializer);
+	if(@socket_sendto($socket, $serializer->getBuffer(), strlen($serializer->getBuffer()), MSG_DONTROUTE, $serverIp, $serverPort) === false){
+		\GlobalLogger::get()->error("Failed to send ping: " . socket_strerror(socket_last_error($socket)));
+		return false;
+	}
+	\GlobalLogger::get()->info("Ping sent to $serverIp on port $serverPort, waiting for response (press CTRL+C to abort)");
+
+	$r = [$socket];
+	$w = $e = null;
+	if(socket_select($r, $w, $e, $timeoutSeconds) === 1){
+		$response = @socket_recvfrom($socket, $recvBuffer, 65535, 0, $recvAddr, $recvPort);
+		if($response === false){
+			\GlobalLogger::get()->error("Error reading from socket: " . socket_strerror(socket_last_error($socket)));
+			return false;
+		}
+		if($recvAddr === $serverIp and $recvPort === $serverPort and $recvBuffer !== "" and ord($recvBuffer[0]) === MessageIdentifiers::ID_UNCONNECTED_PONG){
+			$pong = new UnconnectedPong();
+			$pong->decode(new PacketSerializer($recvBuffer));
+			\GlobalLogger::get()->info("--- Response received ---");
+			\GlobalLogger::get()->info("Payload: $pong->serverName");
+			\GlobalLogger::get()->info("Response time: " . (hrtime_ms() - $pong->sendPingTime) . " ms");
+			return true;
+		}else{
+			\GlobalLogger::get()->debug("Garbage packet from $recvAddr $recvPort: " . bin2hex($recvBuffer));
+		}
+	}
+
+	\GlobalLogger::get()->info("No ping response after $timeoutSeconds seconds");
+	return false;
+}
+
+if(count($argv) > 3){
+	echo "Usage: " . PHP_BINARY . " " . __FILE__ . " [server IP] [server port]\n";
+	exit(1);
+}
+
+if(count($argv) > 1){
+	$hostName = $argv[1];
+}else{
+	do{
+		$hostName = read_stdin("Server address");
+	}while($hostName === "");
+}
+
+$serverIps = gethostbynamel($hostName);
+if($serverIps === false){
+	\GlobalLogger::get()->critical("Unable to resolve hostname $hostName to an IP address");
+	exit(1);
+}
+if(count($serverIps) > 1){
+	\GlobalLogger::get()->warning("Multiple IP addresses found for hostname $hostName, using the first one: " . $serverIps[0]);
+}
+$server = $serverIps[0];
+\GlobalLogger::get()->info("Resolved hostname to $server");
+
+if(count($argv) > 2){
+	$port = (int) $argv[2];
+}elseif(count($argv) > 1){
+	$port = 19132;
+}else{
+	$portRaw = read_stdin("Server port (empty for 19132)");
+	$port = $portRaw === "" ? 19132 : (int) $portRaw;
+}
+
+$sock = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
+if($sock === false) throw new AssumptionFailedError();
+
+socket_bind($sock, "0.0.0.0");
+socket_getsockname($sock, $bindAddr, $bindPort);
+\GlobalLogger::get()->info("Bound to $bindAddr on port $bindPort");
+
+$start = time();
+while(time() < $start + 60_000 && !ping_server($sock, $server, $port, 5, mt_rand(0, PHP_INT_MAX))){
+	sleep(1);
+}
+
+socket_close($sock);
+
+