1. <?php
  2. /*
  3. LiveStats Library
  5. version: 2.0
  6. query engines: Goldsource, Source, SA:MP
  7. protocol: 47, 48
  8. author: nr913
  10. visit www.freakz.ro
  11. */
  13. define('HL_PACKET', -1);
  14. define('HL_PACKET_SPLITTED', -2);
  15. define('SAMP_PACKET', 1347240275);
  17. class Player {
  18. var $ID;
  19. var $Name;
  20. var $Score;
  21. var $TimePlayed;
  22. var $Ping;
  23. }
  25. class Server {
  26. var $Type = 0;
  27. var $ProtocolVersion;
  28. var $Address;
  29. var $Hostname;
  30. var $Map;
  31. var $Directory;
  32. var $Description;
  33. var $AppID;
  34. var $MaxPlayers;
  35. var $PlayerCount;
  36. var $BotCount;
  37. var $Dedicated;
  38. var $OS;
  39. var $PasswordProtected;
  40. var $Secured;
  41. var $GameMode;
  42. var $WitnessCount;
  43. var $WitnessTime;
  44. var $GameVersion;
  45. var $Players = array();
  46. var $Rules = array();
  47. }
  49. class Time {
  50. var $Hours;
  51. var $Minutes;
  52. var $Seconds;
  54. function __construct($seconds) {
  55. $this->Hours = floor($seconds / 3600);
  56. $this->Minutes = floor($seconds / 60) % 60;
  57. $this->Seconds = floor($seconds) % 60;
  58. }
  60. function __toString() {
  61. $hours = ($this->Hours < 10 ? '0' . $this->Hours : $this->Hours);
  62. $minutes = ($this->Minutes < 10 ? '0' . $this->Minutes : $this->Minutes);
  63. $seconds = ($this->Seconds < 10 ? '0' . $this->Seconds : $this->Seconds);
  64. return "$hours:$minutes:$seconds";
  65. }
  66. }
  68. class LSError extends Exception {
  69. var $ErrorMessage;
  70. var $ErrorCode;
  72. function __construct($errcode, $errmsg) {
  73. $this->ErrorCode = $errcode;
  74. $this->ErrorMessage = $errmsg;
  75. }
  76. }
  78. class Utils {
  79. static function getTime() {
  80. list($u, $s) = explode(' ', microtime());
  81. return ((float)$u + (float)$s);
  82. }
  84. static function getString($packet, &$offset, $length = -1) {
  85. $len = strlen($packet);
  86. $i = 0;
  87. if ($length == -1) {
  88. while ($offset + $i < $len && $packet[$offset + $i] != "\x00")
  89. $i++;
  90. $offset += $i + 1;
  91. return substr($packet, $offset - $i - 1, $i);
  92. } else {
  93. $i = $length;
  94. if ($len - $offset < $length)
  95. $i = $len - $offset;
  96. $offset += $i;
  97. return substr($packet, $offset - $i, $i);
  98. }
  99. }
  101. static function getByte($packet, &$offset) {
  102. if ($offset >= strlen($packet))
  103. return 0;
  104. $char = unpack('cchar', $packet[$offset]);
  105. $offset++;
  106. return $char['char'];
  107. }
  109. static function getShort($packet, &$offset) {
  110. if ($offset + 2 >= strlen($packet))
  111. return 0;
  112. $short = unpack('sshort', substr($packet, $offset, 2));
  113. $offset += 2;
  114. return $short['short'];
  115. }
  117. static function getInt($packet, &$offset) {
  118. if ($offset + 4 >= strlen($packet))
  119. return 0;
  120. $int = unpack('iint', substr($packet, $offset, 4));
  121. $offset += 4;
  122. return $int['int'];
  123. }
  125. static function getFloat($packet, &$offset) {
  126. if ($offset + 4 >= strlen($packet))
  127. return ((float)0.0);
  128. $float = unpack('ffloat', substr($packet, $offset, 4));
  129. $offset += 4;
  130. return ((float)$float['float']);
  131. }
  132. }
  134. class LiveStats {
  135. var $IP;
  136. var $Port;
  137. var $Sock;
  138. var $Challenge = "\xFF\xFF\xFF\xFF";
  139. var $HaveInfo = false;
  140. var $HavePlayer = false;
  141. var $HaveRules = false;
  142. var $ResendPlayer = false;
  143. var $ResendRules = false;
  144. var $SendQueue = array();
  145. var $MaxExecutionTime = 2;
  146. var $SplittedPackets = array();
  147. var $SAMPHeader = "SAMP";
  149. var $Server;
  151. public function __construct($hostname, $port = 27015) {
  152. $this->IP = gethostbyname($hostname);
  153. $this->Port = $port;
  155. $errno = 0; $errstr = '';
  156. $this->Sock = @stream_socket_client("udp://{$this->IP}:{$this->Port}", $errno, $errstr, 5);
  158. if ($this->Sock === false)
  159. throw new LSError(1, "Could not connect to specified host [$errno]: $errstr.");
  161. if (stream_set_blocking($this->Sock, false) == false)
  162. throw new LSError(2, "Could not set to non-blocking mode.");
  164. if (stream_set_timeout($this->Sock, 3) == false)
  165. throw new LSError(3, "Could not set timeout to 10 seconds.");
  167. $this->Server = new Server;
  168. $this->Server->Address = "{$this->IP}:{$this->Port}";
  170. $ip = explode('.', $this->IP);
  171. $this->SAMPHeader .= chr($ip[0]) . chr($ip[1]) . chr($ip[2]) . chr($ip[3]) . chr($this->Port & 0xFF) . chr(($this->Port >> 8) & 0xFF);
  172. }
  174. function onSplittedPacketReceived($packet) {
  175. $offset = 4;
  176. $ReqID = Utils::getInt($packet, $offset);
  177. if (!isset($this->SplittedPackets[$ReqID])) {
  178. $this->SplittedPackets[$ReqID] = array(
  179. 'Data' => array(),
  180. 'Type' => -1,
  181. 'Packets' => -1
  182. );
  183. }
  184. $this->SplittedPackets[$ReqID]['Data'][] = $packet;
  185. if (count($this->SplittedPackets[$ReqID]['Data']) == 2) {
  186. $offset = 8;
  187. $FB1 = Utils::getByte($this->SplittedPackets[$ReqID]['Data'][0], $offset);
  188. $offset = 8;
  189. $FB2 = Utils::getByte($this->SplittedPackets[$ReqID]['Data'][1], $offset);
  190. if ($FB1 != $FB2) {
  191. $this->SplittedPackets[$ReqID]['Type'] = 0;
  192. $this->SplittedPackets[$ReqID]['Packets'] = ($FB1<<4)>>4;
  193. } else {
  194. $this->SplittedPackets[$ReqID]['Type'] = 1;
  195. $this->SplittedPackets[$ReqID]['Packets'] = $FB1;
  196. }
  197. }
  198. if (count($this->SplittedPackets[$ReqID]['Data']) == $this->SplittedPackets[$ReqID]['Packets']) {
  199. if ($this->SplittedPackets[$ReqID]['Type'] == 0) {
  200. for ($i = 0; $i < $this->SplittedPackets[$ReqID]['Packets']; $i++) {
  201. $offset = 8;
  202. $PckID = Utils::getByte($this->SplittedPackets[$ReqID]['Data'][$i], $offset)>>4;
  203. if ($i != $PckID) {
  204. $aux = $this->SplittedPackets[$ReqID]['Data'][$PckID];
  205. $this->SplittedPackets[$ReqID]['Data'][$PckID] = $this->SplittedPackets[$ReqID]['Data'][$i];
  206. $this->SplittedPackets[$ReqID]['Data'][$i] = $aux;
  207. $i--;
  208. }
  209. }
  210. $packet = "\xFF\xFF\xFF\xFF" . substr($this->SplittedPackets[$ReqID]['Data'][0], 13);
  211. for ($i = 1; $i < $this->SplittedPackets[$ReqID]['Packets']; $i++)
  212. $packet .= substr($this->SplittedPackets[$ReqID]['Data'][$i], 9);
  213. } else {
  214. for ($i = 0; $i < $this->SplittedPackets[$ReqID]['Packets']; $i++) {
  215. $offset = 9;
  216. $PckID = Utils::getByte($this->SplittedPackets[$ReqID]['Data'][$i], $offset);
  217. if ($i != $PckID) {
  218. $aux = $this->SplittedPackets[$ReqID]['Data'][$PckID];
  219. $this->SplittedPackets[$ReqID]['Data'][$PckID] = $this->SplittedPackets[$ReqID]['Data'][$i];
  220. $this->SplittedPackets[$ReqID]['Data'][$i] = $aux;
  221. $i--;
  222. }
  223. }
  224. $packet = "\xFF\xFF\xFF\xFF" . substr($this->SplittedPackets[$ReqID]['Data'][0], 16);
  225. for ($i = 1; $i < $this->SplittedPackets[$ReqID]['Packets']; $i++)
  226. $packet .= substr($this->SplittedPackets[$ReqID]['Data'][$i], 12);
  227. }
  228. unset($this->SplittedPackets[$ReqID]);
  229. $this->onPacketReceived($packet);
  230. }
  231. }
  233. function onPacketReceived($packet) {
  234. $offset = 4;
  235. switch (Utils::getByte($packet, $offset)) {
  236. case 0x41: // challenge
  237. $this->Challenge = substr($packet, 5);
  238. if ($this->ResendPlayer) {
  239. $this->ResendPlayer = false;
  240. $this->requestPlayer();
  241. }
  242. if ($this->ResendRules) {
  243. $this->ResendRules = false;
  244. $this->requestRules();
  245. }
  246. break;
  247. case 0x44: // player
  248. if ($this->HavePlayer)
  249. break;
  250. $offset = 5;
  251. $numplayers = Utils::getByte($packet, $offset);
  252. while ($numplayers) {
  253. $Player = new Player;
  254. $Player->ID = Utils::getByte($packet, $offset);
  255. $Player->Name = Utils::getString($packet, $offset);
  256. $len = strlen($Player->Name);
  257. $Player->Score = Utils::getInt($packet, $offset);
  258. $Player->TimePlayed = new Time(Utils::getFloat($packet, $offset));
  259. $numplayers--;
  261. array_push($this->Server->Players, $Player);
  262. }
  263. $this->HavePlayer = true;
  264. $this->ResendPlayer = false;
  265. break;
  266. case 0x49: // info, source
  267. if ($this->HaveInfo)
  268. break;
  269. $offset = 5;
  270. $this->Server->ProtocolVersion = Utils::getByte($packet, $offset);
  271. $this->Server->Hostname = Utils::getString($packet, $offset);
  272. $this->Server->Map = Utils::getString($packet, $offset);
  273. $this->Server->Directory = Utils::getString($packet, $offset);
  274. $this->Server->Description = Utils::getString($packet, $offset);
  275. $this->Server->AppID = Utils::getShort($packet, $offset);
  276. $this->Server->PlayerCount = Utils::getByte($packet, $offset);
  277. $this->Server->MaxPlayers = Utils::getByte($packet, $offset);
  278. $this->Server->BotCount = Utils::getByte($packet, $offset);
  279. $this->Server->Dedicated = (Utils::getByte($packet, $offset) == ord('d') ? true : false);
  280. $this->Server->OS = (Utils::getByte($packet, $offset) == 'l' ? 'Linux' : 'Windows');
  281. $this->Server->PasswordProtected = (Utils::getByte($packet, $offset) == 1 ? true : false);
  282. $this->Server->Secured = (Utils::getByte($packet, $offset) == 1 ? true : false);
  283. $TheShipAppIDs = array(2400, 2401, 2402, 2412, 2430, 2406, 2405, 2403);
  284. if (in_array($this->Server->AppID, $TheShipAppIDs)) {
  285. $gm = Utils::getByte($packet, $offset);
  286. $GameModes = array('Hunt', 'Elimination', 'Duel', 'Deathmatch', 'Team VIP', 'Team Elimination');
  287. $this->Server->GameMode = (isset($GameModes[$gm]) ? $GameModes[$gm] : 'Unknown');
  288. $this->Server->WitnessCount = Utils::getByte($packet, $offset);
  289. $this->Server->WitnessTime = Utils::getByte($packet, $offset);
  290. }
  291. $this->Server->GameVersion = Utils::getString($packet, $offset);
  292. $this->HaveInfo = true;
  293. break;
  294. case 0x6D: // info, goldsource
  295. if ($this->HaveInfo)
  296. break;
  297. $offset = 5;
  298. Utils::getString($packet, $offset);
  299. $this->Server->Hostname = Utils::getString($packet, $offset);
  300. $this->Server->Map = Utils::getString($packet, $offset);
  301. $this->Server->Directory = Utils::getString($packet, $offset);
  302. $this->Server->Description = Utils::getString($packet, $offset);
  303. $this->Server->PlayerCount = Utils::getByte($packet, $offset);
  304. $this->Server->MaxPlayers = Utils::getByte($packet, $offset);
  305. $this->Server->ProtocolVersion = Utils::getByte($packet, $offset);
  306. $this->Server->Dedicated = (Utils::getByte($packet, $offset) == ord('d') ? true : false);
  307. $this->Server->OS = (Utils::getByte($packet, $offset) == 'l' ? 'Linux' : 'Windows');
  308. $this->Server->AppID = ($this->Server->OS == 'Linux' ? 4 : 5);
  309. $this->Server->PasswordProtected = (Utils::getByte($packet, $offset) == 1 ? true : false);
  310. $IsMod = Utils::getByte($packet, $offset);
  311. if ($IsMod == 1) {
  312. Utils::getString($packet, $offset);
  313. Utils::getString($packet, $offset);
  314. Utils::getByte($packet, $offset);
  315. Utils::getInt($packet, $offset);
  316. Utils::getInt($packet, $offset);
  317. Utils::getByte($packet, $offset);
  318. Utils::getByte($packet, $offset);
  319. }
  320. $this->Server->Secured = (Utils::getByte($packet, $offset) == 1 ? true : false);
  321. $this->Server->BotCount = Utils::getByte($packet, $offset);
  322. $this->HaveInfo = true;
  323. break;
  324. case 0x45: // rules
  325. if ($this->HaveRules)
  326. break;
  327. $offset = 5;
  328. $rulesnum = Utils::getShort($packet, $offset);
  329. while ($rulesnum) {
  330. $Name = Utils::getString($packet, $offset);
  331. $Value = Utils::getString($packet, $offset);
  332. $rulesnum--;
  334. $this->Server->Rules[$Name] = $Value;
  335. }
  336. $this->HaveRules = true;
  337. $this->ResendRules = false;
  338. break;
  339. default:
  340. break;
  341. }
  342. }
  344. function onSampPacketReceived($packet) {
  345. $offset = 10;
  346. switch (Utils::getByte($packet, $offset)) {
  347. case 0x69: // info
  348. if ($this->HaveInfo)
  349. break;
  350. $this->Server->PasswordProtected = (Utils::getByte($packet, $offset) == 1 ? true : false);
  351. $this->Server->PlayerCount = Utils::getShort($packet, $offset);
  352. $this->Server->MaxPlayers = Utils::getShort($packet, $offset);
  353. $len = Utils::getInt($packet, $offset);
  354. $this->Server->Hostname = Utils::getString($packet, $offset, $len);
  355. $len = Utils::getInt($packet, $offset);
  356. $this->Server->GameMode = Utils::getString($packet, $offset, $len);
  357. $len = Utils::getInt($packet, $offset);
  358. $this->Server->Map = Utils::getString($packet, $offset, $len);
  359. $this->HaveInfo = true;
  360. if ($this->Server->PlayerCount >= 100)
  361. $this->HavePlayer = true;
  362. break;
  363. case 0x72: // rules
  364. if ($this->HaveRules)
  365. break;
  366. $rulesnum = Utils::getShort($packet, $offset);
  367. while ($rulesnum) {
  368. $len = Utils::getByte($packet, $offset);
  369. $Name = Utils::getString($packet, $offset, $len);
  370. $len = Utils::getByte($packet, $offset);
  371. $Value = Utils::getString($packet, $offset, $len);
  372. $rulesnum--;
  374. $this->Server->Rules[$Name] = $Value;
  375. }
  376. $this->HaveRules = true;
  377. break;
  378. case 0x64: // player
  379. if ($this->HavePlayer)
  380. break;
  381. $numplayers = Utils::getShort($packet, $offset);
  382. $lastID = 0;
  383. $plusID = 0;
  384. while ($numplayers) {
  385. $Player = new Player;
  386. $Player->ID = Utils::getByte($packet, $offset) + $plusID;
  387. if ($Player->ID < $lastID) {
  388. $Player->ID += 256;
  389. $plusID += 256;
  390. }
  391. $lastID = $Player->ID;
  392. $len = Utils::getByte($packet, $offset);
  393. $Player->Name = Utils::getString($packet, $offset, $len);
  394. $len = strlen($Player->Name);
  395. $Player->Score = Utils::getInt($packet, $offset);
  396. $Player->Ping = Utils::getInt($packet, $offset);
  397. $numplayers--;
  399. array_push($this->Server->Players, $Player);
  400. }
  401. $this->HavePlayer = true;
  402. break;
  403. default:
  404. break;
  405. }
  406. }
  408. function requestInfo() {
  409. array_push($this->SendQueue, "\xFF\xFF\xFF\xFFTSource Engine Query\x00");
  410. array_push($this->SendQueue, $this->SAMPHeader . "i");
  411. }
  413. function requestPlayer() {
  414. array_push($this->SendQueue, "\xFF\xFF\xFF\xFF\x55" . $this->Challenge);
  415. array_push($this->SendQueue, $this->SAMPHeader . "d");
  416. if ($this->Challenge == "\xFF\xFF\xFF\xFF")
  417. $this->ResendPlayer = true;
  418. }
  420. function requestRules() {
  421. array_push($this->SendQueue, "\xFF\xFF\xFF\xFF\x56" . $this->Challenge);
  422. array_push($this->SendQueue, $this->SAMPHeader . "r");
  423. if ($this->Challenge == "\xFF\xFF\xFF\xFF")
  424. $this->ResendRules = true;
  425. }
  427. function GetServer() {
  428. $start = Utils::getTime();
  430. $this->requestInfo();
  431. $this->requestPlayer();
  432. $this->requestRules();
  434. while (!($this->HaveRules && $this->HaveInfo && $this->HavePlayer)) {
  435. if (Utils::getTime() - $start >= $this->MaxExecutionTime) {
  436. if ($this->HaveInfo && $this->HavePlayer) {
  437. $this->HaveRules = true;
  438. } else {
  439. throw new LSError(4, "Timed out.");
  440. }
  441. }
  442. if (count($this->SendQueue) > 0) {
  443. stream_socket_sendto($this->Sock, array_shift($this->SendQueue));
  445. $meta = stream_get_meta_data($this->Sock);
  446. if ($meta['timed_out'])
  447. throw new LSError(5, "Timed out.");
  448. }
  450. usleep(50000);
  452. $packet = fread($this->Sock, 2048);
  454. $meta = stream_get_meta_data($this->Sock);
  455. if ($meta['timed_out'])
  456. throw new LSError(6, "Timed out.");
  458. if (strlen($packet) > 0) {
  459. $offset = 0;
  460. switch (Utils::getInt($packet, $offset)) {
  461. case HL_PACKET:
  462. if (!in_array($this->Server->Type, array(0, 1)))
  463. break;
  464. $this->Server->Type = 1;
  465. $this->onPacketReceived($packet);
  466. break;
  467. case HL_PACKET_SPLITTED:
  468. if (!in_array($this->Server->Type, array(0, 1)))
  469. break;
  470. $this->Server->Type = 1;
  471. $this->onSplittedPacketReceived($packet);
  472. break;
  473. case SAMP_PACKET:
  474. if (!in_array($this->Server->Type, array(0, 2)))
  475. break;
  476. $this->Server->Type = 2;
  477. $this->onSampPacketReceived($packet);
  478. break;
  479. default:
  480. break;
  481. }
  482. }
  483. }
  484. return $this->Server;
  485. }
  486. }
  488. ?>