File GameQ/Protocols/Raknet.php

1:	<?php
2:	/**
3:	* This file is part of GameQ.
4:	*
5:	* GameQ is free software; you can redistribute it and/or modify
6:	* it under the terms of the GNU Lesser General Public License as published by
7:	* the Free Software Foundation; either version 3 of the License, or
8:	* (at your option) any later version.
9:	*
10:	* GameQ is distributed in the hope that it will be useful,
11:	* but WITHOUT ANY WARRANTY; without even the implied warranty of
12:	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13:	* GNU Lesser General Public License for more details.
14:	*
15:	* You should have received a copy of the GNU Lesser General Public License
16:	* along with this program. If not, see <http://www.gnu.org/licenses/>.
17:	*/
18:
19:	namespace GameQ\Protocols;
20:
21:	use GameQ\Buffer;
22:	use GameQ\Exception\Protocol as Exception;
23:	use GameQ\Protocol;
24:	use GameQ\Result;
25:	use GameQ\Server;
26:
27:	/**
28:	* Raknet Protocol Class
29:	*
30:	* See https://wiki.vg/Raknet_Protocol for more techinal information
31:	*
32:	* @author Austin Bischoff <austin@codebeard.com>
33:	*/
34:	class Raknet extends Protocol
35:	{
36:	/**
37:	* The magic string that is sent to get access to the server information
38:	*/
39:	const OFFLINE_MESSAGE_DATA_ID = "\x00\xFF\xFF\x00\xFE\xFE\xFE\xFE\xFD\xFD\xFD\xFD\x12\x34\x56\x78";
40:
41:	/**
42:	* Expected first part of the response from the server after query
43:	*/
44:	const ID_UNCONNECTED_PONG = "\x1C";
45:
46:	/**
47:	* Array of packets we want to look up.
48:	* Each key should correspond to a defined method in this or a parent class
49:	*
50:	* @var array
51:	*/
52:	protected $packets = [
53:	self::PACKET_STATUS => "\x01%s%s\x02\x00\x00\x00\x00\x00\x00\x00", // Format time, magic,
54:	];
55:
56:	/**
57:	* The query protocol used to make the call
58:	*
59:	* @var string
60:	*/
61:	protected $protocol = 'raknet';
62:
63:	/**
64:	* String name of this protocol class
65:	*
66:	* @var string
67:	*/
68:	protected $name = 'raknet';
69:
70:	/**
71:	* Longer string name of this protocol class
72:	*
73:	* @var string
74:	*/
75:	protected $name_long = "Raknet Server";
76:
77:	/**
78:	* Do some work to build the packet we need to send out to query
79:	*
80:	* @param Server $server
81:	* @return void
82:	*/
83:	public function beforeSend(Server $server)
84:	{
85:	// Update the server status packet before it is sent
86:	$this->packets[self::PACKET_STATUS] = sprintf(
87:	$this->packets[self::PACKET_STATUS],
88:	pack('Q', time()),
89:	self::OFFLINE_MESSAGE_DATA_ID
90:	);
91:	}
92:
93:	/**
94:	* Process the response
95:	*
96:	* @return array
97:	* @throws \GameQ\Exception\Protocol
98:	*/
99:	public function processResponse()
100:	{
101:	// Merge the response array into a buffer. Unknown if this protocol does split packets or not
102:	$buffer = new Buffer(implode($this->packets_response));
103:
104:	// Read first character from response. It should match below
105:	$header = $buffer->read(1);
106:
107:	// Check first character to make sure the header matches
108:	if ($header !== self::ID_UNCONNECTED_PONG) {
109:	throw new Exception(sprintf(
110:	'%s The header returned "%s" does not match the expected header of "%s"',
111:	__METHOD__,
112:	bin2hex($header),
113:	bin2hex(self::ID_UNCONNECTED_PONG)
114:	));
115:	}
116:
117:	// Burn the time section
118:	$buffer->skip(8);
119:
120:	// Server GUID is next
121:	$serverGUID = $buffer->readInt64();
122:
123:	// Read the next set to check to make sure the "magic" matches
124:	$magicCheck = $buffer->read(16);
125:
126:	// Magic check fails
127:	if ($magicCheck !== self::OFFLINE_MESSAGE_DATA_ID) {
128:	throw new Exception(sprintf(
129:	'%s The magic value returned "%s" does not match the expected value of "%s"',
130:	__METHOD__,
131:	bin2hex($magicCheck),
132:	bin2hex(self::OFFLINE_MESSAGE_DATA_ID)
133:	));
134:	}
135:
136:	// According to docs the next character is supposed to be used for a length and string for the following
137:	// character for the MOTD but it appears to be implemented incorrectly
138:	// Burn the next two characters instead of trying to do anything useful with them
139:	$buffer->skip(2);
140:
141:	// Set the result to a new result instance
142:	$result = new Result();
143:
144:	// Here on is server information delimited by semicolons (;)
145:	$info = explode(';', $buffer->getBuffer());
146:
147:	$result->add('edition', $info[0]);
148:	$result->add('motd_line_1', $info[1]);
149:	$result->add('protocol_version', (int)$info[2]);
150:	$result->add('version', $info[3]);
151:	$result->add('num_players', (int)$info[4]);
152:	$result->add('max_players', (int)$info[5]);
153:	$result->add('server_uid', $info[6]);
154:	$result->add('motd_line_2', $info[7]);
155:	$result->add('gamemode', $info[8]);
156:	$result->add('gamemode_numeric', (int)$info[9]);
157:	$result->add('port_ipv4', (isset($info[10])) ? (int)$info[10] : null);
158:	$result->add('port_ipv6', (isset($info[11])) ? (int)$info[11] : null);
159:	$result->add('dedicated', 1);
160:
161:	unset($header, $serverGUID, $magicCheck, $info);
162:
163:	return $result->fetch();
164:	}
165:	}
166:

Namespaces

Classes