Flatten NetworkSession hierarchy in preparation for refactor

This commit is contained in:
Dylan K. Taylor 2018-07-18 17:23:49 +01:00
parent bf4c6e4c2b
commit f969f3b77f
3 changed files with 116 additions and 331 deletions

View File

@ -96,7 +96,7 @@ use pocketmine\nbt\tag\ByteTag;
use pocketmine\nbt\tag\CompoundTag; use pocketmine\nbt\tag\CompoundTag;
use pocketmine\nbt\tag\DoubleTag; use pocketmine\nbt\tag\DoubleTag;
use pocketmine\nbt\tag\ListTag; use pocketmine\nbt\tag\ListTag;
use pocketmine\network\mcpe\PlayerNetworkSessionAdapter; use pocketmine\network\mcpe\NetworkSession;
use pocketmine\network\mcpe\protocol\AdventureSettingsPacket; use pocketmine\network\mcpe\protocol\AdventureSettingsPacket;
use pocketmine\network\mcpe\protocol\AnimatePacket; use pocketmine\network\mcpe\protocol\AnimatePacket;
use pocketmine\network\mcpe\protocol\AvailableCommandsPacket; use pocketmine\network\mcpe\protocol\AvailableCommandsPacket;
@ -183,11 +183,8 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
return $lname !== "rcon" and $lname !== "console" and $len >= 1 and $len <= 16 and preg_match("/[^A-Za-z0-9_ ]/", $name) === 0; return $lname !== "rcon" and $lname !== "console" and $len >= 1 and $len <= 16 and preg_match("/[^A-Za-z0-9_ ]/", $name) === 0;
} }
/** /** @var NetworkSession */
* @var PlayerNetworkSessionAdapter protected $networkSession;
* TODO: remove this once player and network are divorced properly
*/
protected $sessionAdapter;
/** @var int */ /** @var int */
protected $protocol = -1; protected $protocol = -1;
@ -714,14 +711,14 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
$this->allowMovementCheats = (bool) $this->server->getProperty("player.anti-cheat.allow-movement-cheats", false); $this->allowMovementCheats = (bool) $this->server->getProperty("player.anti-cheat.allow-movement-cheats", false);
$this->sessionAdapter = new PlayerNetworkSessionAdapter($this->server, $this, $interface); $this->networkSession = new NetworkSession($this->server, $this, $interface);
} }
/** /**
* @return bool * @return bool
*/ */
public function isConnected() : bool{ public function isConnected() : bool{
return $this->sessionAdapter !== null; return $this->networkSession !== null;
} }
/** /**
@ -3032,8 +3029,8 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
* @param DataPacket $packet * @param DataPacket $packet
*/ */
public function handleDataPacket(DataPacket $packet){ public function handleDataPacket(DataPacket $packet){
if($this->sessionAdapter !== null){ if($this->networkSession !== null){
$this->sessionAdapter->handleDataPacket($packet); $this->networkSession->handleDataPacket($packet);
} }
} }
@ -3054,7 +3051,7 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
throw new \InvalidArgumentException("Attempted to send " . get_class($packet) . " to " . $this->getName() . " too early"); throw new \InvalidArgumentException("Attempted to send " . get_class($packet) . " to " . $this->getName() . " too early");
} }
return $this->sessionAdapter->sendDataPacket($packet, $immediate); return $this->networkSession->sendDataPacket($packet, $immediate);
} }
/** /**
@ -3304,8 +3301,8 @@ class Player extends Human implements CommandSender, ChunkLoader, IPlayer{
if($this->isConnected() and !$this->closed){ if($this->isConnected() and !$this->closed){
try{ try{
$this->sessionAdapter->serverDisconnect($reason, $notify); $this->networkSession->serverDisconnect($reason, $notify);
$this->sessionAdapter = null; $this->networkSession = null;
$this->server->getPluginManager()->unsubscribeFromPermission(Server::BROADCAST_CHANNEL_USERS, $this); $this->server->getPluginManager()->unsubscribeFromPermission(Server::BROADCAST_CHANNEL_USERS, $this);
$this->server->getPluginManager()->unsubscribeFromPermission(Server::BROADCAST_CHANNEL_ADMINISTRATIVE, $this); $this->server->getPluginManager()->unsubscribeFromPermission(Server::BROADCAST_CHANNEL_ADMINISTRATIVE, $this);

View File

@ -23,6 +23,8 @@ declare(strict_types=1);
namespace pocketmine\network\mcpe; namespace pocketmine\network\mcpe;
use pocketmine\event\server\DataPacketReceiveEvent;
use pocketmine\event\server\DataPacketSendEvent;
use pocketmine\network\mcpe\protocol\AddBehaviorTreePacket; use pocketmine\network\mcpe\protocol\AddBehaviorTreePacket;
use pocketmine\network\mcpe\protocol\AddEntityPacket; use pocketmine\network\mcpe\protocol\AddEntityPacket;
use pocketmine\network\mcpe\protocol\AddHangingEntityPacket; use pocketmine\network\mcpe\protocol\AddHangingEntityPacket;
@ -136,13 +138,74 @@ use pocketmine\network\mcpe\protocol\UpdateBlockSyncedPacket;
use pocketmine\network\mcpe\protocol\UpdateEquipPacket; use pocketmine\network\mcpe\protocol\UpdateEquipPacket;
use pocketmine\network\mcpe\protocol\UpdateTradePacket; use pocketmine\network\mcpe\protocol\UpdateTradePacket;
use pocketmine\network\mcpe\protocol\WSConnectPacket; use pocketmine\network\mcpe\protocol\WSConnectPacket;
use pocketmine\network\NetworkInterface;
use pocketmine\Player;
use pocketmine\Server;
use pocketmine\timings\Timings;
abstract class NetworkSession{ class NetworkSession{
abstract public function handleDataPacket(DataPacket $packet);
/** @var Server */
private $server;
/** @var Player */
private $player;
/** @var NetworkInterface */
private $interface;
public function __construct(Server $server, Player $player, NetworkInterface $interface){
$this->server = $server;
$this->player = $player;
$this->interface = $interface;
}
public function handleDataPacket(DataPacket $packet) : void{
$timings = Timings::getReceiveDataPacketTimings($packet);
$timings->startTiming();
$packet->decode();
if(!$packet->feof() and !$packet->mayHaveUnreadBytes()){
$remains = substr($packet->buffer, $packet->offset);
$this->server->getLogger()->debug("Still " . strlen($remains) . " bytes unread in " . $packet->getName() . ": 0x" . bin2hex($remains));
}
$this->server->getPluginManager()->callEvent($ev = new DataPacketReceiveEvent($this->player, $packet));
if(!$ev->isCancelled() and !$packet->handle($this)){
$this->server->getLogger()->debug("Unhandled " . $packet->getName() . " received from " . $this->player->getName() . ": 0x" . bin2hex($packet->buffer));
}
$timings->stopTiming();
}
public function sendDataPacket(DataPacket $packet, bool $immediate = false) : bool{
$timings = Timings::getSendDataPacketTimings($packet);
$timings->startTiming();
try{
$this->server->getPluginManager()->callEvent($ev = new DataPacketSendEvent($this->player, $packet));
if($ev->isCancelled()){
return false;
}
$this->interface->putPacket($this->player, $packet, false, $immediate);
return true;
}finally{
$timings->stopTiming();
}
}
public function serverDisconnect(string $reason, bool $notify = true) : void{
if($notify){
$pk = new DisconnectPacket();
$pk->message = $reason;
$pk->hideDisconnectionScreen = $reason === "";
$this->sendDataPacket($pk, true);
}
$this->interface->close($this->player, $notify ? $reason : "");
}
public function handleLogin(LoginPacket $packet) : bool{ public function handleLogin(LoginPacket $packet) : bool{
return false; return $this->player->handleLogin($packet);
} }
public function handlePlayStatus(PlayStatusPacket $packet) : bool{ public function handlePlayStatus(PlayStatusPacket $packet) : bool{
@ -154,7 +217,7 @@ abstract class NetworkSession{
} }
public function handleClientToServerHandshake(ClientToServerHandshakePacket $packet) : bool{ public function handleClientToServerHandshake(ClientToServerHandshakePacket $packet) : bool{
return false; return false; //TODO
} }
public function handleDisconnect(DisconnectPacket $packet) : bool{ public function handleDisconnect(DisconnectPacket $packet) : bool{
@ -170,10 +233,14 @@ abstract class NetworkSession{
} }
public function handleResourcePackClientResponse(ResourcePackClientResponsePacket $packet) : bool{ public function handleResourcePackClientResponse(ResourcePackClientResponsePacket $packet) : bool{
return false; return $this->player->handleResourcePackClientResponse($packet);
} }
public function handleText(TextPacket $packet) : bool{ public function handleText(TextPacket $packet) : bool{
if($packet->type === TextPacket::TYPE_CHAT){
return $this->player->chat($packet->message);
}
return false; return false;
} }
@ -214,7 +281,7 @@ abstract class NetworkSession{
} }
public function handleMovePlayer(MovePlayerPacket $packet) : bool{ public function handleMovePlayer(MovePlayerPacket $packet) : bool{
return false; return $this->player->handleMovePlayer($packet);
} }
public function handleRiderJump(RiderJumpPacket $packet) : bool{ public function handleRiderJump(RiderJumpPacket $packet) : bool{
@ -234,7 +301,7 @@ abstract class NetworkSession{
} }
public function handleLevelSoundEvent(LevelSoundEventPacket $packet) : bool{ public function handleLevelSoundEvent(LevelSoundEventPacket $packet) : bool{
return false; return $this->player->handleLevelSoundEvent($packet);
} }
public function handleLevelEvent(LevelEventPacket $packet) : bool{ public function handleLevelEvent(LevelEventPacket $packet) : bool{
@ -246,7 +313,7 @@ abstract class NetworkSession{
} }
public function handleEntityEvent(EntityEventPacket $packet) : bool{ public function handleEntityEvent(EntityEventPacket $packet) : bool{
return false; return $this->player->handleEntityEvent($packet);
} }
public function handleMobEffect(MobEffectPacket $packet) : bool{ public function handleMobEffect(MobEffectPacket $packet) : bool{
@ -258,35 +325,35 @@ abstract class NetworkSession{
} }
public function handleInventoryTransaction(InventoryTransactionPacket $packet) : bool{ public function handleInventoryTransaction(InventoryTransactionPacket $packet) : bool{
return false; return $this->player->handleInventoryTransaction($packet);
} }
public function handleMobEquipment(MobEquipmentPacket $packet) : bool{ public function handleMobEquipment(MobEquipmentPacket $packet) : bool{
return false; return $this->player->handleMobEquipment($packet);
} }
public function handleMobArmorEquipment(MobArmorEquipmentPacket $packet) : bool{ public function handleMobArmorEquipment(MobArmorEquipmentPacket $packet) : bool{
return false; return true; //Not used
} }
public function handleInteract(InteractPacket $packet) : bool{ public function handleInteract(InteractPacket $packet) : bool{
return false; return $this->player->handleInteract($packet);
} }
public function handleBlockPickRequest(BlockPickRequestPacket $packet) : bool{ public function handleBlockPickRequest(BlockPickRequestPacket $packet) : bool{
return false; return $this->player->handleBlockPickRequest($packet);
} }
public function handleEntityPickRequest(EntityPickRequestPacket $packet) : bool{ public function handleEntityPickRequest(EntityPickRequestPacket $packet) : bool{
return false; return false; //TODO
} }
public function handlePlayerAction(PlayerActionPacket $packet) : bool{ public function handlePlayerAction(PlayerActionPacket $packet) : bool{
return false; return $this->player->handlePlayerAction($packet);
} }
public function handleEntityFall(EntityFallPacket $packet) : bool{ public function handleEntityFall(EntityFallPacket $packet) : bool{
return false; return true; //Not used
} }
public function handleHurtArmor(HurtArmorPacket $packet) : bool{ public function handleHurtArmor(HurtArmorPacket $packet) : bool{
@ -314,7 +381,7 @@ abstract class NetworkSession{
} }
public function handleAnimate(AnimatePacket $packet) : bool{ public function handleAnimate(AnimatePacket $packet) : bool{
return false; return $this->player->handleAnimate($packet);
} }
public function handleRespawn(RespawnPacket $packet) : bool{ public function handleRespawn(RespawnPacket $packet) : bool{
@ -326,11 +393,11 @@ abstract class NetworkSession{
} }
public function handleContainerClose(ContainerClosePacket $packet) : bool{ public function handleContainerClose(ContainerClosePacket $packet) : bool{
return false; return $this->player->handleContainerClose($packet);
} }
public function handlePlayerHotbar(PlayerHotbarPacket $packet) : bool{ public function handlePlayerHotbar(PlayerHotbarPacket $packet) : bool{
return false; return true; //this packet is useless
} }
public function handleInventoryContent(InventoryContentPacket $packet) : bool{ public function handleInventoryContent(InventoryContentPacket $packet) : bool{
@ -350,7 +417,7 @@ abstract class NetworkSession{
} }
public function handleCraftingEvent(CraftingEventPacket $packet) : bool{ public function handleCraftingEvent(CraftingEventPacket $packet) : bool{
return false; return true; //this is a broken useless packet, so we don't use it
} }
public function handleGuiDataPickItem(GuiDataPickItemPacket $packet) : bool{ public function handleGuiDataPickItem(GuiDataPickItemPacket $packet) : bool{
@ -358,15 +425,15 @@ abstract class NetworkSession{
} }
public function handleAdventureSettings(AdventureSettingsPacket $packet) : bool{ public function handleAdventureSettings(AdventureSettingsPacket $packet) : bool{
return false; return $this->player->handleAdventureSettings($packet);
} }
public function handleBlockEntityData(BlockEntityDataPacket $packet) : bool{ public function handleBlockEntityData(BlockEntityDataPacket $packet) : bool{
return false; return $this->player->handleBlockEntityData($packet);
} }
public function handlePlayerInput(PlayerInputPacket $packet) : bool{ public function handlePlayerInput(PlayerInputPacket $packet) : bool{
return false; return false; //TODO
} }
public function handleFullChunkData(FullChunkDataPacket $packet) : bool{ public function handleFullChunkData(FullChunkDataPacket $packet) : bool{
@ -386,7 +453,7 @@ abstract class NetworkSession{
} }
public function handleSetPlayerGameType(SetPlayerGameTypePacket $packet) : bool{ public function handleSetPlayerGameType(SetPlayerGameTypePacket $packet) : bool{
return false; return $this->player->handleSetPlayerGameType($packet);
} }
public function handlePlayerList(PlayerListPacket $packet) : bool{ public function handlePlayerList(PlayerListPacket $packet) : bool{
@ -402,7 +469,7 @@ abstract class NetworkSession{
} }
public function handleSpawnExperienceOrb(SpawnExperienceOrbPacket $packet) : bool{ public function handleSpawnExperienceOrb(SpawnExperienceOrbPacket $packet) : bool{
return false; return false; //TODO
} }
public function handleClientboundMapItemData(ClientboundMapItemDataPacket $packet) : bool{ public function handleClientboundMapItemData(ClientboundMapItemDataPacket $packet) : bool{
@ -410,11 +477,13 @@ abstract class NetworkSession{
} }
public function handleMapInfoRequest(MapInfoRequestPacket $packet) : bool{ public function handleMapInfoRequest(MapInfoRequestPacket $packet) : bool{
return false; return false; //TODO
} }
public function handleRequestChunkRadius(RequestChunkRadiusPacket $packet) : bool{ public function handleRequestChunkRadius(RequestChunkRadiusPacket $packet) : bool{
return false; $this->player->setViewDistance($packet->radius);
return true;
} }
public function handleChunkRadiusUpdated(ChunkRadiusUpdatedPacket $packet) : bool{ public function handleChunkRadiusUpdated(ChunkRadiusUpdatedPacket $packet) : bool{
@ -422,7 +491,7 @@ abstract class NetworkSession{
} }
public function handleItemFrameDropItem(ItemFrameDropItemPacket $packet) : bool{ public function handleItemFrameDropItem(ItemFrameDropItemPacket $packet) : bool{
return false; return $this->player->handleItemFrameDropItem($packet);
} }
public function handleGameRulesChanged(GameRulesChangedPacket $packet) : bool{ public function handleGameRulesChanged(GameRulesChangedPacket $packet) : bool{
@ -434,11 +503,11 @@ abstract class NetworkSession{
} }
public function handleBossEvent(BossEventPacket $packet) : bool{ public function handleBossEvent(BossEventPacket $packet) : bool{
return false; return false; //TODO
} }
public function handleShowCredits(ShowCreditsPacket $packet) : bool{ public function handleShowCredits(ShowCreditsPacket $packet) : bool{
return false; return false; //TODO: handle resume
} }
public function handleAvailableCommands(AvailableCommandsPacket $packet) : bool{ public function handleAvailableCommands(AvailableCommandsPacket $packet) : bool{
@ -446,11 +515,11 @@ abstract class NetworkSession{
} }
public function handleCommandRequest(CommandRequestPacket $packet) : bool{ public function handleCommandRequest(CommandRequestPacket $packet) : bool{
return false; return $this->player->chat($packet->command);
} }
public function handleCommandBlockUpdate(CommandBlockUpdatePacket $packet) : bool{ public function handleCommandBlockUpdate(CommandBlockUpdatePacket $packet) : bool{
return false; return false; //TODO
} }
public function handleCommandOutput(CommandOutputPacket $packet) : bool{ public function handleCommandOutput(CommandOutputPacket $packet) : bool{
@ -474,7 +543,7 @@ abstract class NetworkSession{
} }
public function handleResourcePackChunkRequest(ResourcePackChunkRequestPacket $packet) : bool{ public function handleResourcePackChunkRequest(ResourcePackChunkRequestPacket $packet) : bool{
return false; return $this->player->handleResourcePackChunkRequest($packet);
} }
public function handleTransfer(TransferPacket $packet) : bool{ public function handleTransfer(TransferPacket $packet) : bool{
@ -510,7 +579,7 @@ abstract class NetworkSession{
} }
public function handlePlayerSkin(PlayerSkinPacket $packet) : bool{ public function handlePlayerSkin(PlayerSkinPacket $packet) : bool{
return false; return $this->player->changeSkin($packet->skin, $packet->newSkinName, $packet->oldSkinName);
} }
public function handleSubClientLogin(SubClientLoginPacket $packet) : bool{ public function handleSubClientLogin(SubClientLoginPacket $packet) : bool{
@ -526,7 +595,7 @@ abstract class NetworkSession{
} }
public function handleBookEdit(BookEditPacket $packet) : bool{ public function handleBookEdit(BookEditPacket $packet) : bool{
return false; return $this->player->handleBookEdit($packet);
} }
public function handleNpcRequest(NpcRequestPacket $packet) : bool{ public function handleNpcRequest(NpcRequestPacket $packet) : bool{
@ -542,11 +611,11 @@ abstract class NetworkSession{
} }
public function handleModalFormResponse(ModalFormResponsePacket $packet) : bool{ public function handleModalFormResponse(ModalFormResponsePacket $packet) : bool{
return false; return false; //TODO: GUI stuff
} }
public function handleServerSettingsRequest(ServerSettingsRequestPacket $packet) : bool{ public function handleServerSettingsRequest(ServerSettingsRequestPacket $packet) : bool{
return false; return false; //TODO: GUI stuff
} }
public function handleServerSettingsResponse(ServerSettingsResponsePacket $packet) : bool{ public function handleServerSettingsResponse(ServerSettingsResponsePacket $packet) : bool{

View File

@ -1,281 +0,0 @@
<?php
/*
*
* ____ _ _ __ __ _ __ __ ____
* | _ \ ___ ___| | _____| |_| \/ (_)_ __ ___ | \/ | _ \
* | |_) / _ \ / __| |/ / _ \ __| |\/| | | '_ \ / _ \_____| |\/| | |_) |
* | __/ (_) | (__| < __/ |_| | | | | | | | __/_____| | | | __/
* |_| \___/ \___|_|\_\___|\__|_| |_|_|_| |_|\___| |_| |_|_|
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* @author PocketMine Team
* @link http://www.pocketmine.net/
*
*
*/
declare(strict_types=1);
namespace pocketmine\network\mcpe;
use pocketmine\event\server\DataPacketReceiveEvent;
use pocketmine\event\server\DataPacketSendEvent;
use pocketmine\network\mcpe\protocol\AdventureSettingsPacket;
use pocketmine\network\mcpe\protocol\AnimatePacket;
use pocketmine\network\mcpe\protocol\BlockEntityDataPacket;
use pocketmine\network\mcpe\protocol\BlockPickRequestPacket;
use pocketmine\network\mcpe\protocol\BookEditPacket;
use pocketmine\network\mcpe\protocol\BossEventPacket;
use pocketmine\network\mcpe\protocol\ClientToServerHandshakePacket;
use pocketmine\network\mcpe\protocol\CommandBlockUpdatePacket;
use pocketmine\network\mcpe\protocol\CommandRequestPacket;
use pocketmine\network\mcpe\protocol\ContainerClosePacket;
use pocketmine\network\mcpe\protocol\CraftingEventPacket;
use pocketmine\network\mcpe\protocol\DataPacket;
use pocketmine\network\mcpe\protocol\DisconnectPacket;
use pocketmine\network\mcpe\protocol\EntityEventPacket;
use pocketmine\network\mcpe\protocol\EntityFallPacket;
use pocketmine\network\mcpe\protocol\EntityPickRequestPacket;
use pocketmine\network\mcpe\protocol\InteractPacket;
use pocketmine\network\mcpe\protocol\InventoryTransactionPacket;
use pocketmine\network\mcpe\protocol\ItemFrameDropItemPacket;
use pocketmine\network\mcpe\protocol\LevelSoundEventPacket;
use pocketmine\network\mcpe\protocol\LoginPacket;
use pocketmine\network\mcpe\protocol\MapInfoRequestPacket;
use pocketmine\network\mcpe\protocol\MobArmorEquipmentPacket;
use pocketmine\network\mcpe\protocol\MobEquipmentPacket;
use pocketmine\network\mcpe\protocol\ModalFormResponsePacket;
use pocketmine\network\mcpe\protocol\MovePlayerPacket;
use pocketmine\network\mcpe\protocol\PlayerActionPacket;
use pocketmine\network\mcpe\protocol\PlayerHotbarPacket;
use pocketmine\network\mcpe\protocol\PlayerInputPacket;
use pocketmine\network\mcpe\protocol\PlayerSkinPacket;
use pocketmine\network\mcpe\protocol\RequestChunkRadiusPacket;
use pocketmine\network\mcpe\protocol\ResourcePackChunkRequestPacket;
use pocketmine\network\mcpe\protocol\ResourcePackClientResponsePacket;
use pocketmine\network\mcpe\protocol\ServerSettingsRequestPacket;
use pocketmine\network\mcpe\protocol\SetPlayerGameTypePacket;
use pocketmine\network\mcpe\protocol\ShowCreditsPacket;
use pocketmine\network\mcpe\protocol\SpawnExperienceOrbPacket;
use pocketmine\network\mcpe\protocol\TextPacket;
use pocketmine\network\NetworkInterface;
use pocketmine\Player;
use pocketmine\Server;
use pocketmine\timings\Timings;
class PlayerNetworkSessionAdapter extends NetworkSession{
/** @var Server */
private $server;
/** @var Player */
private $player;
/** @var NetworkInterface */
private $interface;
public function __construct(Server $server, Player $player, NetworkInterface $interface){
$this->server = $server;
$this->player = $player;
$this->interface = $interface;
}
public function handleDataPacket(DataPacket $packet) : void{
$timings = Timings::getReceiveDataPacketTimings($packet);
$timings->startTiming();
$packet->decode();
if(!$packet->feof() and !$packet->mayHaveUnreadBytes()){
$remains = substr($packet->buffer, $packet->offset);
$this->server->getLogger()->debug("Still " . strlen($remains) . " bytes unread in " . $packet->getName() . ": 0x" . bin2hex($remains));
}
$this->server->getPluginManager()->callEvent($ev = new DataPacketReceiveEvent($this->player, $packet));
if(!$ev->isCancelled() and !$packet->handle($this)){
$this->server->getLogger()->debug("Unhandled " . $packet->getName() . " received from " . $this->player->getName() . ": 0x" . bin2hex($packet->buffer));
}
$timings->stopTiming();
}
public function sendDataPacket(DataPacket $packet, bool $immediate = false) : bool{
$timings = Timings::getSendDataPacketTimings($packet);
$timings->startTiming();
try{
$this->server->getPluginManager()->callEvent($ev = new DataPacketSendEvent($this->player, $packet));
if($ev->isCancelled()){
return false;
}
$this->interface->putPacket($this->player, $packet, false, $immediate);
return true;
}finally{
$timings->stopTiming();
}
}
public function serverDisconnect(string $reason, bool $notify = true) : void{
if($notify){
$pk = new DisconnectPacket();
$pk->message = $reason;
$pk->hideDisconnectionScreen = $reason === "";
$this->sendDataPacket($pk, true);
}
$this->interface->close($this->player, $notify ? $reason : "");
}
public function handleLogin(LoginPacket $packet) : bool{
return $this->player->handleLogin($packet);
}
public function handleClientToServerHandshake(ClientToServerHandshakePacket $packet) : bool{
return false; //TODO
}
public function handleResourcePackClientResponse(ResourcePackClientResponsePacket $packet) : bool{
return $this->player->handleResourcePackClientResponse($packet);
}
public function handleText(TextPacket $packet) : bool{
if($packet->type === TextPacket::TYPE_CHAT){
return $this->player->chat($packet->message);
}
return false;
}
public function handleMovePlayer(MovePlayerPacket $packet) : bool{
return $this->player->handleMovePlayer($packet);
}
public function handleLevelSoundEvent(LevelSoundEventPacket $packet) : bool{
return $this->player->handleLevelSoundEvent($packet);
}
public function handleEntityEvent(EntityEventPacket $packet) : bool{
return $this->player->handleEntityEvent($packet);
}
public function handleInventoryTransaction(InventoryTransactionPacket $packet) : bool{
return $this->player->handleInventoryTransaction($packet);
}
public function handleMobEquipment(MobEquipmentPacket $packet) : bool{
return $this->player->handleMobEquipment($packet);
}
public function handleMobArmorEquipment(MobArmorEquipmentPacket $packet) : bool{
return true; //Not used
}
public function handleInteract(InteractPacket $packet) : bool{
return $this->player->handleInteract($packet);
}
public function handleBlockPickRequest(BlockPickRequestPacket $packet) : bool{
return $this->player->handleBlockPickRequest($packet);
}
public function handleEntityPickRequest(EntityPickRequestPacket $packet) : bool{
return false; //TODO
}
public function handlePlayerAction(PlayerActionPacket $packet) : bool{
return $this->player->handlePlayerAction($packet);
}
public function handleEntityFall(EntityFallPacket $packet) : bool{
return true; //Not used
}
public function handleAnimate(AnimatePacket $packet) : bool{
return $this->player->handleAnimate($packet);
}
public function handleContainerClose(ContainerClosePacket $packet) : bool{
return $this->player->handleContainerClose($packet);
}
public function handlePlayerHotbar(PlayerHotbarPacket $packet) : bool{
return true; //this packet is useless
}
public function handleCraftingEvent(CraftingEventPacket $packet) : bool{
return true; //this is a broken useless packet, so we don't use it
}
public function handleAdventureSettings(AdventureSettingsPacket $packet) : bool{
return $this->player->handleAdventureSettings($packet);
}
public function handleBlockEntityData(BlockEntityDataPacket $packet) : bool{
return $this->player->handleBlockEntityData($packet);
}
public function handlePlayerInput(PlayerInputPacket $packet) : bool{
return false; //TODO
}
public function handleSetPlayerGameType(SetPlayerGameTypePacket $packet) : bool{
return $this->player->handleSetPlayerGameType($packet);
}
public function handleSpawnExperienceOrb(SpawnExperienceOrbPacket $packet) : bool{
return false; //TODO
}
public function handleMapInfoRequest(MapInfoRequestPacket $packet) : bool{
return false; //TODO
}
public function handleRequestChunkRadius(RequestChunkRadiusPacket $packet) : bool{
$this->player->setViewDistance($packet->radius);
return true;
}
public function handleItemFrameDropItem(ItemFrameDropItemPacket $packet) : bool{
return $this->player->handleItemFrameDropItem($packet);
}
public function handleBossEvent(BossEventPacket $packet) : bool{
return false; //TODO
}
public function handleShowCredits(ShowCreditsPacket $packet) : bool{
return false; //TODO: handle resume
}
public function handleCommandRequest(CommandRequestPacket $packet) : bool{
return $this->player->chat($packet->command);
}
public function handleCommandBlockUpdate(CommandBlockUpdatePacket $packet) : bool{
return false; //TODO
}
public function handleResourcePackChunkRequest(ResourcePackChunkRequestPacket $packet) : bool{
return $this->player->handleResourcePackChunkRequest($packet);
}
public function handlePlayerSkin(PlayerSkinPacket $packet) : bool{
return $this->player->changeSkin($packet->skin, $packet->newSkinName, $packet->oldSkinName);
}
public function handleBookEdit(BookEditPacket $packet) : bool{
return $this->player->handleBookEdit($packet);
}
public function handleModalFormResponse(ModalFormResponsePacket $packet) : bool{
return false; //TODO: GUI stuff
}
public function handleServerSettingsRequest(ServerSettingsRequestPacket $packet) : bool{
return false; //TODO: GUI stuff
}
}