<?php
class Server {
/**
* @var string name of itself for testing
*/
public static $classname = 'Server';
/**
* Queries a Minequery server.
*
*
@Static
* @param string $address The address to the Minequery server.
* @param int $port The port of the Minequery server.
* @param int $timeout The time given before the connection attempt gives up.
* @return array|bool An array on success, FALSE on failure.
*/
public static function query($address, $port = 25566, $timeout = 30) {
global $db;
$query = array();
$write = "QUERY\n";
$class = self::$classname;
$response = $class::read($address, $port, $errno, $errstr, $timeout, $write, $latency);
if (false === $response) {
return false;
}
$response = explode("\n", $response);
// Server port
$query['serverPort'] = explode(" ", $response[0], 2);
$query['serverPort'] = $query['serverPort'][1];
// Player count
$query['playerCount'] = explode(" ", $response[1], 2);
$query['playerCount'] = $query['playerCount'][1];
// Max players
$query['maxPlayers'] = explode(" ", $response[2], 2);
$query['maxPlayers'] = $query['maxPlayers'][1];
// Record players
$stm = $db->query("SELECT * FROM `online_record`");
$rec = $stm->fetch(PDO::FETCH_ASSOC);
$record = $rec['record'];
if($query['playerCount'] > $record){$db->query("UPDATE `online_record` SET `record`='{$query['playerCount']}' WHERE `record`={$record}");}
$query['record'] = $record;
// Player list
list(, $buffer) = explode(" ", $response[3], 2);
$buffer = trim($buffer, "[] ");
$query['playerList'] = $buffer ? explode(", ", $buffer) : array();
$query['latency'] = $latency;
return $query;
}
/**
* Queries a Minequery server using JSON.
*
*
@Static
* @param string $address The address to the Minequery server.
* @param int $port The port of the Minequery server.
* @param int $timeout The time given before the connection attempt gives up.
* @return object|bool A stdClass object on success, FALSE on failure.
*/
public static function query_json($address, $port = 25566, $timeout = 30) {
$beginning_time = microtime(true);
$socket = @fsockopen($address, $port, $errno, $errstr, $timeout);
if (!$socket) {
// Could not establish a connection to the server.
return false;
}
$end_time = microtime(true);
fwrite($socket, "QUERY_JSON\n");
$response = "";
while (!feof($socket)) {
$response .= fgets($socket, 1024);
}
$query = json_decode($response);
$query->latency = ($end_time - $beginning_time) * 1000;
return $query;
}
/**
* Queries a Remote Socket
*
*
@Static
* @param string $address The address to the Minequery server.
* @param int $port The port of the Minequery server.
* @param int $errno
* @param string $errstr
* @param int $timeout The time given before the connection attempt gives up.
* @param string $write
* @param int $latency
* @return string|bool An string on success, FALSE on failure.
*/
protected static function read($address, $port, &$errno, &$errstr, $timeout, $write, &$latency) {
$latency = NULL;
$beginning_time = microtime(true);
$socket = @fsockopen($address, $port, $errno, $errstr, $timeout);
if (!$socket) {
// Could not establish a connection to the server.
return false;
}
$end_time = microtime(true);
$latency = ($end_time - $beginning_time) * 1000;
fwrite($socket, $write);
$response = "";
while (!feof($socket)) {
$response .= fgets($socket, 1024);
}
return $response;
}
}
?>
ъ
