steffalon
commented
6 years ago I made my code more understandable for the documentation from BattlEye. Also I made many comments so editing this code much more easy.
If you notice, I made a switch right now. This makes much more sense what will happen with the hexbyte data.
I have added debug mode if some users don't want to get bothered with developer echo's or vardump.
I'm less concerned about the "reconnect if timeout" function because the connection is already constant and wont disconnect if the server socket is always reachable and now what I'm concerned about is that "multiple packages" data are abit broken in my code. Sometimes it works and sometimes it doesnt'. What I know right now is that it depends on package size that got send back from requested command by the user.
Reconnect function will coming soon.
<?php
require 'vendor/autoload.php'; //Require ReactPHP in composer route
$ip = ""; //Ip here [127.0.0.1]
$port = ; //Port here [2022]
$pass = ""; //Password here
define("debug", true); //Debug option for developers
if (debug) echo "Debug mode turned on!";
$msgseq = 0; //Do not change this variable. Important for sequence steps.
// Login package
$authCRC = crc32(chr(255).chr(00).trim($pass));
$authCRC = sprintf("%x", $authCRC);
$authCRC = array(substr($authCRC,-2,2),substr($authCRC,-4,2),substr($authCRC,-6,2),substr($authCRC,0,2));
$loginmsg = "BE".chr(hexdec($authCRC[0])).chr(hexdec($authCRC[1])).chr(hexdec($authCRC[2])).chr(hexdec($authCRC[3]));
$loginmsg .= chr(hexdec('ff')).chr(hexdec('00')).$pass;
// -- ReactPHP setup --
$loop = React\EventLoop\Factory::create();
$factory = new React\Datagram\Factory($loop);
$source = new React\Stream\ReadableResourceStream(fopen('php://stdin', 'r'), $loop); //Listen to PHP CLI
// -- End of setup for ReactPHP --
$factory->createClient($ip.":".$port)->then(function (React\Datagram\Socket $client) use($loop, $loginmsg, $source) {
$client->send($loginmsg); //Login
$source->on('data', function ($msg) use($client, $loop) {
$msgCRC = crc32(chr(255).chr(01).chr(hexdec(sprintf('%01b',0))).$msg);
$msgCRC = sprintf("%x", $msgCRC);
$msgCRC = array(substr($msgCRC,-2,2),substr($msgCRC,-4,2),substr($msgCRC,-6,2),substr($msgCRC,0,2));
$saymsg = "BE".chr(hexdec($msgCRC[0])).chr(hexdec($msgCRC[1])).chr(hexdec($msgCRC[2])).chr(hexdec($msgCRC[3]));
$saymsg .= chr(hexdec('ff')).chr(hexdec('01')).chr(hexdec(sprintf('%01b',0))).$msg;
$client->send($saymsg);
});
$client->on('message', function($message) use ($client, $loop) {
echo substr($message,9). PHP_EOL;
$responseCode = unpack('H*', $message); //Make message usefull for battleye packet by unpacking it to hexbyte.
$responseCode = str_split(substr($responseCode[1], 12), 2); //Get important hexbytes.
global $msgseq; //Sequence varible outside this scope.
switch ($responseCode[1]) { //See https://www.battleye.com/downloads/BERConProtocol.txt for packet info.
case "00": //Login
echo "Logged in as ";
break;
case "01": //Send commands by this client.
if (count($responseCode) == 3) {
break;
}
if ($responseCode[3] !== "00") {
if (debug) echo "This is a small package. No further actions needed.".PHP_EOL; //This package is not special. Allow to be continued.
} else {
if (debug) echo "Multi-packet! This part could go wrong because its not finished yet.".PHP_EOL; //This package needs support.
if (debug) var_dump($responseCode); //Useful developer information.
if ($responseCode[5] == "00") {
$getAmount = $responseCode[4];
if (debug) var_dump($getAmount);
}
}
break;
case "02": //acknowledge as client.
if (debug) echo "acknowledge!".PHP_EOL;
$needBuffer = chr(hexdec('ff')).chr(hexdec('02')).chr(hexdec(sprintf('%2X', $msgseq)));
$needBuffer = hash("crc32b", $needBuffer);
$needBuffer = str_split($needBuffer, 2);
$needBuffer = array_reverse($needBuffer);
$statusmsg = "BE".chr(hexdec($needBuffer[0])).chr(hexdec($needBuffer[1])).chr(hexdec($needBuffer[2])).chr(hexdec($needBuffer[3]));
$statusmsg .= chr(hexdec('ff')).chr(hexdec('02')).chr(hexdec(sprintf('%2X', $msgseq)));
$client->send($statusmsg);
$msgseq ++; //Add +1 to sequence.
break;
}
});
$client->on('error', function() {
echo 'Something went wront... Check your output(s) that got send to the socket with a valid format.' . PHP_EOL;
});
$loop->addPeriodicTimer(25, function () use($client, $loop) { //Send "keep alive" package every x seconds. Do not change it to 45 seconds or more.
if (debug) echo '--Keep connection alive--'.PHP_EOL; //Remove this line when not debugging.
$keepalive = "BE".chr(hexdec("be")).chr(hexdec("dc")).chr(hexdec("c2")).chr(hexdec("58"));
$keepalive .= chr(hexdec('ff')).chr(hexdec('01')).chr(hexdec(sprintf('00')));
$client->send($keepalive);
});
});
$loop->run(); //Start ReactPHP UDP stream/loops.
0FakE
felixms
Adding new methods to the class in order to keep a connection to the server alive. This is useful for receiving the chat and log stream.
Pioneering work done by @nerdalertdk,@steffalon, @0FaKE - see #30.