YGGverse/hl-php
1
0
Fork 0
mirror of https://github.com/YGGverse/hl-php.git synced 2026-03-31 17:15:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Compare commits

base: YGGverse:main
Branches Tags
YGGverse:main
YGGverse:1.0.4
YGGverse:1.0.3
YGGverse:1.0.2
YGGverse:1.0.1
YGGverse:1.0.0
..
compare: YGGverse:1.0.0
Branches Tags
YGGverse:main
YGGverse:1.0.4
YGGverse:1.0.3
YGGverse:1.0.2
YGGverse:1.0.1
YGGverse:1.0.0

No commits in common. "main" and "1.0.0" have entirely different histories.
main ... 1.0.0

3 changed files with 58 additions and 137 deletions
Download patch file Download diff file Expand all files Collapse all files

10
README.md
View file

@ -13,17 +13,9 @@ PHP 8 library for Half-Life API with native IPv6 / Yggdrasil support
#### Master
```
$master = new \Yggverse\Hl\Xash3D\Master('hl.ygg', 27010);
$master = new Yggverse\Hl\Xash3d\Master('hl.ygg', 27010);
var_dump(
$master->getServersIPv6()
);
var_dump(
$master->getErrors()
);
```
## Projects
* [HLState](https://github.com/YGGverse/HLState) - Web Monitor for Half-Life Servers

2
composer.json
View file

@ -1,8 +1,6 @@
{
"name": "yggverse/hl",
"description": "PHP 8 library for Half-Life API with native IPv6 / Yggdrasil support ",
"keywords": [ "half-life", "hl", "xash3d", "ipv6", "yggdrasil", "master" ],
"homepage": "https://github.com/YGGverse/hl-php",
"type": "library",
"license": "MIT",
"autoload": {

167
src/Xash3D/Master.php
View file

@ -2,127 +2,66 @@
declare(strict_types=1);
namespace Yggverse\Hl\Xash3D;
enum Family: int {
case IPv4 = 4;
case IPv6 = 16;
}
enum Region: string {
case USEastCoast = "0x00";
case USWestCoast = "0x01";
case SouthAmerica = "0x02";
case Europe = "0x03";
case Asia = "0x04";
case Australia = "0x05";
case MiddleEast = "0x06";
case Africa = "0x07";
case World = "0xff";
}
enum Game: string {
case Valve = "valve";
}
namespace Yggverse\Hl\Xash3d;
class Master
{
private string $_host;
private int $_port;
private int $_timeout;
private array $_errors = [];
private $_socket;
public function __construct(
string $host,
int $port = 27010,
int $port,
int $timeout = 5
)
{
$this->_host = $host;
$this->_port = $port;
$this->_timeout = $timeout;
$this->_socket = fsockopen(
"udp://{$host}",
$port
);
stream_set_timeout(
$this->_socket,
$timeout
);
}
private function _fclose(
mixed $socket
)
public function __destruct()
{
if (true === is_resource($socket))
if ($this->_socket)
{
fclose(
$socket
$this->_socket
);
}
}
// Legacy protocol implementation does not support mixed address families
// in the binary master socket response, use separated method for IPv4 servers.
public function getServers(
public static function getServersIPv6(
int $limit = 100,
string $host = "0.0.0.0",
string $region = "\xFF",
string $host = "0.0.0.0:0",
int $port = 0,
Game $game = Game::Valve,
Region $region = Region::World
string $gamedir = "valve"
): ?array
{
$family = filter_var($host, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4) ? Family::IPv4 : Family::IPv6;
// Init connection
$socket = fsockopen(
"udp://{$this->_host}",
$this->_port,
$code,
$message,
$this->_timeout
);
$master = "{$this->_host}:{$this->_port}";
// Is connected
if (true === is_resource($socket))
if (!$this->_socket)
{
stream_set_timeout(
$socket,
$this->_timeout
);
}
else
{
$this->_errors[] = sprintf(
_("Connection error for $master: %s"),
$message
);
$this->_fclose(
$socket
);
return null;
}
// Filter query
if (false === fwrite($socket, "1{$region->value}{$host}:{$port}\0\\gamedir\\{$game->value}\0"))
if (!fwrite($this->_socket, "1{$region}{$host}:{$port}\0\gamedir\t{$gamedir}\0"))
{
$this->_errors[] = _("Could not send socket query for $master");
$this->_fclose(
$socket
fclose(
$this->_socket
);
return null;
}
// Skip header
if (false === fread($socket, 6))
if (!fread($this->_socket, 6))
{
$this->_errors[] = _("Could not init packet header for $master");
$this->_fclose(
$socket
);
return null;
}
@ -131,64 +70,56 @@ class Master
for ($i = 0; $i < $limit; $i++)
{
// Get host bytes
if (false === $host = fread($socket, $family->value))
// Get host
if (false === $host = fread($this->_socket, 16))
{
$this->_errors[] = _("Invalid `host` fragment in packet at $i for $master");
break;
return null;
}
// End of packet
if (true === str_ends_with(bin2hex($host), bin2hex("\0\0\0\0\0\0")))
// Is end of packet
if (true === str_starts_with($host, 0))
{
break;
}
// Get host string
// Skip invalid host
if (false === $host = inet_ntop($host))
{
$this->_errors[] = _("Invalid `host` value in packet at $i for $master");
break;
continue;
}
// Get port bytes
if (false === $p = fread($socket, 2))
// Decode first byte for port
if (false === $byte1 = fread($this->_socket, 1))
{
$this->_errors[] = _("Invalid `port` fragment in packet at $i for $master");
break;
return null;
}
// Get port value
if (false === $p = unpack('nport', $p))
// Decode second byte for port
if (false === $byte2 = fread($this->_socket, 1))
{
$this->_errors[] = _("Invalid `port` value in packet at $i for $master");
break;
return null;
}
// Validate result
if (false === filter_var($host, FILTER_VALIDATE_IP, $family == Family::IPv6 ? FILTER_FLAG_IPV6
: FILTER_FLAG_IPV4) || empty($p['port']))
// Calculate port value
$port = ord($byte1) * 256 + ord($byte2);
// Validate IPv6 result
if (
false !== strpos($host, '.') || // filter_var not always works with mixed IPv6
false === filter_var($host, FILTER_VALIDATE_IP, FILTER_FLAG_IPV6) ||
false === filter_var($port, FILTER_VALIDATE_INT)
)
{
$this->_errors[] = _("Invalid socket address in packet at $i for $master");
break;
continue;
}
$servers["{$host}{$p['port']}"] = // keep unique
$servers["[{$host}]:{$port}"] = // keep unique
[
'host' => $host,
'port' => $p['port']
'port' => $port
];
}
$this->_fclose(
$socket
);
return $servers;
}
public function getErrors(): array
{
return $this->_errors;
}
}