Completed
Push — v3 ( 9aaf4b...6c721b )
by Austin
03:53
created

Gamespy3::processDetails()   A

Complexity

Conditions 3
Paths 3

Size

Total Lines 12
Code Lines 6

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 6
CRAP Score 3.0261

Importance

Changes 0
Metric Value
dl 0
loc 12
ccs 6
cts 7
cp 0.8571
rs 9.4285
c 0
b 0
f 0
cc 3
eloc 6
nc 3
nop 2
crap 3.0261
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\Protocol;
22
use GameQ\Buffer;
23
use GameQ\Result;
24
25
/**
26
 * GameSpy3 Protocol class
27
 *
28
 * Given the ability for non utf-8 characters to be used as hostnames, player names, etc... this
29
 * version returns all strings utf-8 encoded (utf8_encode).  To access the proper version of a
30
 * string response you must use utf8_decode() on the specific response.
31
 *
32
 * @author Austin Bischoff <[email protected]>
33
 */
34
class Gamespy3 extends Protocol
35
{
36
37
    /**
38
     * Array of packets we want to look up.
39
     * Each key should correspond to a defined method in this or a parent class
40
     *
41
     * @type array
42
     */
43
    protected $packets = [
44
        self::PACKET_CHALLENGE => "\xFE\xFD\x09\x10\x20\x30\x40",
45
        self::PACKET_ALL       => "\xFE\xFD\x00\x10\x20\x30\x40%s\xFF\xFF\xFF\x01",
46
    ];
47
48
    /**
49
     * The query protocol used to make the call
50
     *
51
     * @type string
52
     */
53
    protected $protocol = 'gamespy3';
54
55
    /**
56
     * String name of this protocol class
57
     *
58
     * @type string
59
     */
60
    protected $name = 'gamespy3';
61
62
    /**
63
     * Longer string name of this protocol class
64
     *
65
     * @type string
66
     */
67
    protected $name_long = "GameSpy3 Server";
68
69
    /**
70
     * The client join link
71
     *
72
     * @type string
73
     */
74
    protected $join_link = null;
75
76
    /**
77
     * This defines the split between the server info and player/team info.
78
     * This value can vary by game. This value is the default split.
79
     *
80
     * @var string
81
     */
82
    protected $packetSplit = "/\\x00\\x00\\x01/m";
83
84
    /**
85
     * Parse the challenge response and apply it to all the packet types
86
     *
87
     * @param \GameQ\Buffer $challenge_buffer
88
     *
89
     * @return bool
90
     * @throws \GameQ\Exception\Protocol
91
     */
92
    public function challengeParseAndApply(Buffer $challenge_buffer)
93
    {
94
95
        // Pull out the challenge
96
        $challenge = substr(preg_replace("/[^0-9\-]/si", "", $challenge_buffer->getBuffer()), 1);
97
        $challenge_result = sprintf(
98
            "%c%c%c%c",
99
            ($challenge >> 24),
100
            ($challenge >> 16),
101
            ($challenge >> 8),
102
            ($challenge >> 0)
103
        );
104
105
        // Apply the challenge and return
106
        return $this->challengeApply($challenge_result);
107
    }
108
109
    /**
110
     * Process the response
111
     *
112
     * @return array
113
     */
114 15
    public function processResponse()
115
    {
116
117
        // Holds the processed packets
118 15
        $processed = [];
119
120
        // Iterate over the packets
121 15
        foreach ($this->packets_response as $response) {
122
            // Make a buffer
123 15
            $buffer = new Buffer($response, Buffer::NUMBER_TYPE_BIGENDIAN);
124
125
            // Packet type = 0
126 15
            $buffer->readInt8();
127
128
            // Session Id
129 15
            $buffer->readInt32();
130
131
            // We need to burn the splitnum\0 because it is not used
132 15
            $buffer->skip(9);
133
134
            // Get the id
135 15
            $id = $buffer->readInt8();
136
137
            // Burn next byte not sure what it is used for
138 15
            $buffer->skip(1);
139
140
            // Add this packet to the processed
141 15
            $processed[$id] = $buffer->getBuffer();
142
143 15
            unset($buffer, $id);
144
        }
145
146
        // Sort packets, reset index
147 15
        ksort($processed);
148
149
        // Offload cleaning up the packets if they happen to be split
150 15
        $packets = $this->cleanPackets(array_values($processed));
151
152
        // Split the packets by type general and the rest (i.e. players & teams)
153 15
        $split = preg_split($this->packetSplit, implode('', $packets));
154
155
        // Create a new result
156 15
        $result = new Result();
157
158
        // Assign variable due to pass by reference in PHP 7+
159 15
        $buffer = new Buffer($split[0], Buffer::NUMBER_TYPE_BIGENDIAN);
160
161
        // First key should be server details and rules
162 15
        $this->processDetails($buffer, $result);
163
164
        // The rest should be the player and team information, if it exists
165 15
        if (array_key_exists(1, $split)) {
166 15
            $buffer = new Buffer($split[1], Buffer::NUMBER_TYPE_BIGENDIAN);
167 15
            $this->processPlayersAndTeams($buffer, $result);
168
        }
169
170 15
        unset($buffer);
171
172 15
        return $result->fetch();
173
    }
174
175
    /*
176
     * Internal methods
177
     */
178
179
    /**
180
     * Handles cleaning up packets since the responses can be a bit "dirty"
181
     *
182
     * @param array $packets
183
     *
184
     * @return array
185
     */
186 15
    protected function cleanPackets(array $packets = [])
187
    {
188
189
        // Get the number of packets
190 15
        $packetCount = count($packets);
191
192
        // Compare last var of current packet with first var of next packet
193
        // On a partial match, remove last var from current packet,
194
        // variable header from next packet
195 15
        for ($i = 0, $x = $packetCount; $i < $x - 1; $i++) {
196
            // First packet
197 5
            $fst = substr($packets[$i], 0, -1);
198
            // Second packet
199 5
            $snd = $packets[$i + 1];
200
            // Get last variable from first packet
201 5
            $fstvar = substr($fst, strrpos($fst, "\x00") + 1);
202
            // Get first variable from last packet
203 5
            $snd = substr($snd, strpos($snd, "\x00") + 2);
204 5
            $sndvar = substr($snd, 0, strpos($snd, "\x00"));
205
            // Check if fstvar is a substring of sndvar
206
            // If so, remove it from the first string
207 5
            if (!empty($fstvar) && strpos($sndvar, $fstvar) !== false) {
208 3
                $packets[$i] = preg_replace("#(\\x00[^\\x00]+\\x00)$#", "\x00", $packets[$i]);
209
            }
210
        }
211
212
        // Now let's loop the return and remove any dupe prefixes
213 15
        for ($x = 1; $x < $packetCount; $x++) {
214 5
            $buffer = new Buffer($packets[$x], Buffer::NUMBER_TYPE_BIGENDIAN);
215
216 5
            $prefix = $buffer->readString();
217
218
            // Check to see if the return before has the same prefix present
219 5
            if ($prefix != null && strstr($packets[($x - 1)], $prefix)) {
220
                // Update the return by removing the prefix plus 2 chars
221 3
                $packets[$x] = substr(str_replace($prefix, '', $packets[$x]), 2);
222
            }
223
224 5
            unset($buffer);
225
        }
226
227 15
        unset($x, $i, $snd, $sndvar, $fst, $fstvar);
228
229
        // Return cleaned packets
230 15
        return $packets;
231
    }
232
233
    /**
234
     * Handles processing the details data into a usable format
235
     *
236
     * @param \GameQ\Buffer $buffer
237
     * @param \GameQ\Result $result
238
     */
239 15
    protected function processDetails(Buffer &$buffer, Result &$result)
240
    {
241
242
        // We go until we hit an empty key
243 15
        while ($buffer->getLength()) {
244 15
            $key = $buffer->readString();
245 15
            if (strlen($key) == 0) {
246
                break;
247
            }
248 15
            $result->add($key, utf8_encode($buffer->readString()));
249
        }
250 15
    }
251
252
    /**
253
     * Handles processing the player and team data into a usable format
254
     *
255
     * @param \GameQ\Buffer $buffer
256
     * @param \GameQ\Result $result
257
     */
258 12
    protected function processPlayersAndTeams(Buffer &$buffer, Result &$result)
259
    {
260
261
        /*
262
         * Explode the data into groups. First is player, next is team (item_t)
263
         * Each group should be as follows:
264
         *
265
         * [0] => item_
266
         * [1] => information for item_
267
         * ...
268
         */
269 12
        $data = explode("\x00\x00", $buffer->getBuffer());
270
271
        // By default item_group is blank, this will be set for each loop thru the data
272 12
        $item_group = '';
273
        // By default the item_type is blank, this will be set on each loop
274 12
        $item_type = '';
275
        // Loop through all of the $data for information and pull it out into the result
276 12
        for ($x = 0; $x < count($data) - 1; $x++) {
277
            // Pull out the item
278 12
            $item = $data[$x];
279
            // If this is an empty item, move on
280 12
            if ($item == '' || $item == "\x00") {
281 2
                continue;
282
            }
283
            /*
284
            * Left as reference:
285
            *
286
            * Each block of player_ and team_t have preceding junk chars
287
            *
288
            * player_ is actually \x01player_
289
            * team_t is actually \x00\x02team_t
290
            *
291
            * Probably a by-product of the change to exploding the data from the original.
292
            *
293
            * For now we just strip out these characters
294
            */
295
            // Check to see if $item has a _ at the end, this is player info
296 12
            if (substr($item, -1) == '_') {
297
                // Set the item group
298 12
                $item_group = 'players';
299
                // Set the item type, rip off any trailing stuff and bad chars
300 12
                $item_type = rtrim(str_replace("\x01", '', $item), '_');
301 11
            } elseif (substr($item, -2) == '_t') {
302
                // Check to see if $item has a _t at the end, this is team info
303
                // Set the item group
304 8
                $item_group = 'teams';
305
                // Set the item type, rip off any trailing stuff and bad chars
306 8
                $item_type = rtrim(str_replace(["\x00", "\x02"], '', $item), '_t');
307
            } else {
308
                // We can assume it is data belonging to a previously defined item
309
310
                // Make a temp buffer so we have easier access to the data
311 11
                $buf_temp = new Buffer($item, Buffer::NUMBER_TYPE_BIGENDIAN);
312
                // Get the values
313 11
                while ($buf_temp->getLength()) {
314
                    // No value so break the loop, end of string
315 11
                    if (($val = $buf_temp->readString()) === '') {
316
                        break;
317
                    }
318
                    // Add the value to the proper item in the correct group
319 11
                    $result->addSub($item_group, $item_type, utf8_encode(trim($val)));
320
                }
321
                // Unset our buffer
322 11
                unset($buf_temp);
323
            }
324
        }
325
        // Free up some memory
326 12
        unset($data, $item, $item_group, $item_type, $val);
327 12
    }
328
}
329