RakLibToUserThreadMessageSender.php

<?php

/*
 * RakLib network library
 *
 *
 * This project is not affiliated with Jenkins Software LLC nor RakNet.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 */

declare(strict_types=1);

namespace raklib\server\ipc;

use pmmp\encoding\LE;
use raklib\server\ipc\RakLibToUserThreadMessageProtocol as ITCProtocol;
use raklib\server\ServerEventListener;
use function chr;
use function inet_pton;
use function strlen;

final class RakLibToUserThreadMessageSender implements ServerEventListener{
	public function __construct(
		private InterThreadChannelWriter $channel
	){}

	public function onClientConnect(int $sessionId, string $address, int $port, int $clientId) : void{
		$rawAddr = inet_pton($address);
		if($rawAddr === false){
			throw new \InvalidArgumentException("Invalid IP address");
		}
		$this->channel->write(
			chr(ITCProtocol::PACKET_OPEN_SESSION) .
			LE::packUnsignedInt($sessionId) .
			chr(strlen($rawAddr)) . $rawAddr .
			LE::packUnsignedShort($port) .
			LE::packUnsignedLong($clientId)
		);
	}

	public function onClientDisconnect(int $sessionId, int $reason) : void{
		$this->channel->write(
			chr(ITCProtocol::PACKET_CLOSE_SESSION) .
			LE::packUnsignedInt($sessionId) .
			chr($reason)
		);
	}

	public function onPacketReceive(int $sessionId, string $packet) : void{
		$this->channel->write(
			chr(ITCProtocol::PACKET_ENCAPSULATED) .
			LE::packUnsignedInt($sessionId) .
			$packet
		);
	}

	public function onRawPacketReceive(string $address, int $port, string $payload) : void{
		$this->channel->write(
			chr(ITCProtocol::PACKET_RAW) .
			chr(strlen($address)) . $address .
			LE::packUnsignedShort($port) .
			$payload
		);
	}

	public function onPacketAck(int $sessionId, int $identifierACK) : void{
		$this->channel->write(
			chr(ITCProtocol::PACKET_ACK_NOTIFICATION) .
			LE::packUnsignedInt($sessionId) .
			LE::packSignedInt($identifierACK)
		);
	}

	public function onBandwidthStatsUpdate(int $bytesSentDiff, int $bytesReceivedDiff) : void{
		$this->channel->write(
			chr(ITCProtocol::PACKET_REPORT_BANDWIDTH_STATS) .
			LE::packUnsignedLong($bytesSentDiff) .
			LE::packSignedLong($bytesReceivedDiff)
		);
	}

	public function onPingMeasure(int $sessionId, int $pingMS) : void{
		$this->channel->write(
			chr(ITCProtocol::PACKET_REPORT_PING) .
			LE::packUnsignedInt($sessionId) .
			LE::packUnsignedInt($pingMS)
		);
	}
}