making tile spawn compound cache use CacheableNbt instead of strings

This commit is contained in:
Dylan K. Taylor 2020-05-04 12:35:13 +01:00
parent c2857a91bd
commit a73c54bdd0
5 changed files with 40 additions and 23 deletions

View File

@ -24,12 +24,15 @@ declare(strict_types=1);
namespace pocketmine\block\tile; namespace pocketmine\block\tile;
use pocketmine\nbt\tag\CompoundTag; use pocketmine\nbt\tag\CompoundTag;
use pocketmine\nbt\TreeRoot;
use pocketmine\network\mcpe\protocol\serializer\NetworkNbtSerializer; use pocketmine\network\mcpe\protocol\serializer\NetworkNbtSerializer;
use pocketmine\network\mcpe\protocol\types\CacheableNbt;
use function get_class; use function get_class;
abstract class Spawnable extends Tile{ abstract class Spawnable extends Tile{
/** @var string|null */ /**
* @var CacheableNbt|null
* @phpstan-var CacheableNbt<\pocketmine\nbt\tag\CompoundTag>|null
*/
private $spawnCompoundCache = null; private $spawnCompoundCache = null;
/** @var bool */ /** @var bool */
private $dirty = true; //default dirty, until it's been spawned appropriately on the world private $dirty = true; //default dirty, until it's been spawned appropriately on the world
@ -55,15 +58,11 @@ abstract class Spawnable extends Tile{
* Returns encoded NBT (varint, little-endian) used to spawn this tile to clients. Uses cache where possible, * Returns encoded NBT (varint, little-endian) used to spawn this tile to clients. Uses cache where possible,
* populates cache if it is null. * populates cache if it is null.
* *
* @return string encoded NBT * @phpstan-return CacheableNbt<\pocketmine\nbt\tag\CompoundTag>
*/ */
final public function getSerializedSpawnCompound() : string{ final public function getSerializedSpawnCompound() : CacheableNbt{
if($this->spawnCompoundCache === null){ if($this->spawnCompoundCache === null){
if(self::$nbtWriter === null){ $this->spawnCompoundCache = new CacheableNbt($this->getSpawnCompound());
self::$nbtWriter = new NetworkNbtSerializer();
}
$this->spawnCompoundCache = self::$nbtWriter->write(new TreeRoot($this->getSpawnCompound()));
} }
return $this->spawnCompoundCache; return $this->spawnCompoundCache;

View File

@ -36,7 +36,7 @@ use pocketmine\item\VanillaItems;
use pocketmine\item\WritableBook; use pocketmine\item\WritableBook;
use pocketmine\item\WrittenBook; use pocketmine\item\WrittenBook;
use pocketmine\math\Vector3; use pocketmine\math\Vector3;
use pocketmine\nbt\NbtDataException; use pocketmine\nbt\tag\CompoundTag;
use pocketmine\nbt\tag\StringTag; use pocketmine\nbt\tag\StringTag;
use pocketmine\network\BadPacketException; use pocketmine\network\BadPacketException;
use pocketmine\network\mcpe\convert\SkinAdapterSingleton; use pocketmine\network\mcpe\convert\SkinAdapterSingleton;
@ -72,7 +72,6 @@ use pocketmine\network\mcpe\protocol\PlayerHotbarPacket;
use pocketmine\network\mcpe\protocol\PlayerInputPacket; use pocketmine\network\mcpe\protocol\PlayerInputPacket;
use pocketmine\network\mcpe\protocol\PlayerSkinPacket; use pocketmine\network\mcpe\protocol\PlayerSkinPacket;
use pocketmine\network\mcpe\protocol\RequestChunkRadiusPacket; use pocketmine\network\mcpe\protocol\RequestChunkRadiusPacket;
use pocketmine\network\mcpe\protocol\serializer\NetworkNbtSerializer;
use pocketmine\network\mcpe\protocol\ServerSettingsRequestPacket; use pocketmine\network\mcpe\protocol\ServerSettingsRequestPacket;
use pocketmine\network\mcpe\protocol\SetPlayerGameTypePacket; use pocketmine\network\mcpe\protocol\SetPlayerGameTypePacket;
use pocketmine\network\mcpe\protocol\ShowCreditsPacket; use pocketmine\network\mcpe\protocol\ShowCreditsPacket;
@ -87,6 +86,7 @@ use pocketmine\network\mcpe\protocol\types\inventory\ReleaseItemTransactionData;
use pocketmine\network\mcpe\protocol\types\inventory\UseItemOnEntityTransactionData; use pocketmine\network\mcpe\protocol\types\inventory\UseItemOnEntityTransactionData;
use pocketmine\network\mcpe\protocol\types\inventory\UseItemTransactionData; use pocketmine\network\mcpe\protocol\types\inventory\UseItemTransactionData;
use pocketmine\player\Player; use pocketmine\player\Player;
use pocketmine\utils\AssumptionFailedError;
use function array_push; use function array_push;
use function base64_encode; use function base64_encode;
use function count; use function count;
@ -554,12 +554,8 @@ class InGamePacketHandler extends PacketHandler{
} }
$block = $this->player->getLocation()->getWorldNonNull()->getBlock($pos); $block = $this->player->getLocation()->getWorldNonNull()->getBlock($pos);
try{ $nbt = $packet->namedtag->getRoot();
$offset = 0; if(!($nbt instanceof CompoundTag)) throw new AssumptionFailedError("PHPStan should ensure this is a CompoundTag"); //for phpstorm's benefit
$nbt = (new NetworkNbtSerializer())->read($packet->namedtag, $offset, 512)->mustGetCompoundTag();
}catch(NbtDataException $e){
throw BadPacketException::wrap($e);
}
if($block instanceof Sign){ if($block instanceof Sign){
if($nbt->hasTag("Text", StringTag::class)){ if($nbt->hasTag("Text", StringTag::class)){
@ -580,7 +576,7 @@ class InGamePacketHandler extends PacketHandler{
return true; return true;
} }
$this->session->getLogger()->debug("Invalid sign update data: " . base64_encode($packet->namedtag)); $this->session->getLogger()->debug("Invalid sign update data: " . base64_encode($packet->namedtag->getEncodedNbt()));
} }
return false; return false;

View File

@ -25,7 +25,10 @@ namespace pocketmine\network\mcpe\protocol;
#include <rules/DataPacket.h> #include <rules/DataPacket.h>
use pocketmine\nbt\NbtDataException;
use pocketmine\network\mcpe\protocol\serializer\NetworkBinaryStream; use pocketmine\network\mcpe\protocol\serializer\NetworkBinaryStream;
use pocketmine\network\mcpe\protocol\serializer\NetworkNbtSerializer;
use pocketmine\network\mcpe\protocol\types\CacheableNbt;
class BlockActorDataPacket extends DataPacket implements ClientboundPacket, ServerboundPacket{ class BlockActorDataPacket extends DataPacket implements ClientboundPacket, ServerboundPacket{
public const NETWORK_ID = ProtocolInfo::BLOCK_ACTOR_DATA_PACKET; public const NETWORK_ID = ProtocolInfo::BLOCK_ACTOR_DATA_PACKET;
@ -36,10 +39,16 @@ class BlockActorDataPacket extends DataPacket implements ClientboundPacket, Serv
public $y; public $y;
/** @var int */ /** @var int */
public $z; public $z;
/** @var string */ /**
* @var CacheableNbt
* @phpstan-var CacheableNbt<\pocketmine\nbt\tag\CompoundTag>
*/
public $namedtag; public $namedtag;
public static function create(int $x, int $y, int $z, string $nbt) : self{ /**
* @phpstan-param CacheableNbt<\pocketmine\nbt\tag\CompoundTag> $nbt
*/
public static function create(int $x, int $y, int $z, CacheableNbt $nbt) : self{
$result = new self; $result = new self;
[$result->x, $result->y, $result->z] = [$x, $y, $z]; [$result->x, $result->y, $result->z] = [$x, $y, $z];
$result->namedtag = $nbt; $result->namedtag = $nbt;
@ -48,12 +57,20 @@ class BlockActorDataPacket extends DataPacket implements ClientboundPacket, Serv
protected function decodePayload(NetworkBinaryStream $in) : void{ protected function decodePayload(NetworkBinaryStream $in) : void{
$in->getBlockPosition($this->x, $this->y, $this->z); $in->getBlockPosition($this->x, $this->y, $this->z);
$this->namedtag = $in->getRemaining(); try{
$offset = $in->getOffset();
$this->namedtag = new CacheableNbt(
(new NetworkNbtSerializer())->read($this->getBinaryStream()->getBuffer(), $offset, 512)->mustGetCompoundTag()
);
$in->setOffset($offset);
}catch(NbtDataException $e){
throw PacketDecodeException::wrap($e, "Failed decoding block actor NBT");
}
} }
protected function encodePayload(NetworkBinaryStream $out) : void{ protected function encodePayload(NetworkBinaryStream $out) : void{
$out->putBlockPosition($this->x, $this->y, $this->z); $out->putBlockPosition($this->x, $this->y, $this->z);
$out->put($this->namedtag); $out->put($this->namedtag->getEncodedNbt());
} }
public function handle(PacketHandlerInterface $handler) : bool{ public function handle(PacketHandlerInterface $handler) : bool{

View File

@ -90,7 +90,7 @@ final class ChunkSerializer{
$stream = new BinaryStream(); $stream = new BinaryStream();
foreach($chunk->getTiles() as $tile){ foreach($chunk->getTiles() as $tile){
if($tile instanceof Spawnable){ if($tile instanceof Spawnable){
$stream->put($tile->getSerializedSpawnCompound()); $stream->put($tile->getSerializedSpawnCompound()->getEncodedNbt());
} }
} }

View File

@ -30,6 +30,11 @@ parameters:
count: 3 count: 3
path: ../../../src/item/Item.php path: ../../../src/item/Item.php
-
message: "#^Instanceof between pocketmine\\\\nbt\\\\tag\\\\CompoundTag and pocketmine\\\\nbt\\\\tag\\\\CompoundTag will always evaluate to true\\.$#"
count: 1
path: ../../../src/network/mcpe/handler/InGamePacketHandler.php
- -
message: "#^Call to function is_array\\(\\) with array\\<string, mixed\\> will always evaluate to true\\.$#" message: "#^Call to function is_array\\(\\) with array\\<string, mixed\\> will always evaluate to true\\.$#"
count: 1 count: 1