Grass::class, Block::SAPLING => Sapling::class, Block::LEAVES => Leaves::class, Block::WHEAT_BLOCK => Wheat::class, Block::FARMLAND => Farmland::class, Block::SNOW_LAYER => SnowLayer::class, Block::ICE => Ice::class, Block::CACTUS => Cactus::class, Block::SUGARCANE_BLOCK => Sugarcane::class, Block::RED_MUSHROOM => RedMushroom::class, Block::BROWN_MUSHROOM => BrownMushroom::class, Block::PUMPKIN_STEM => PumpkinStem::class, Block::MELON_STEM => MelonStem::class, //Block::VINE => true, Block::MYCELIUM => Mycelium::class, //Block::COCOA_BLOCK => true, Block::CARROT_BLOCK => Carrot::class, Block::POTATO_BLOCK => Potato::class, Block::LEAVES2 => Leaves2::class, Block::BEETROOT_BLOCK => Beetroot::class, ]; /** @var LevelTimings */ public $timings; protected $generator; /** * Returns the chunk unique hash/key * * @param int $x * @param int $z * * @return string */ public static function chunkHash($x, $z){ return $x . ":" . $z; } public static function getXZ($hash, &$x, &$z){ list($x, $z) = explode(":", $hash); $x = (int) $x; $z = (int) $z; } /** * Init the default level data * * @param Server $server * @param string $name * @param string $path * @param string $provider Class that extends LevelProvider * * @throws \Exception */ public function __construct(Server $server, $name, $path, $provider){ $this->levelId = static::$levelIdCounter++; $this->blockMetadata = new BlockMetadataStore($this); $this->server = $server; $this->autoSave = $server->getAutoSave(); /** @var LevelProvider $provider */ if(is_subclass_of($provider, LevelProvider::class, true)){ $this->provider = new $provider($this, $path); }else{ throw new \Exception("Provider is not a subclass of LevelProvider"); } $this->server->getLogger()->info("Preparing level \"" . $this->provider->getName() . "\""); $this->generator = Generator::getGenerator($this->provider->getGenerator()); $this->blockOrder = $provider::getProviderOrder(); $this->useSections = $provider::usesChunkSection(); $this->folderName = $name; $this->updateQueue = new ReversePriorityQueue(); $this->updateQueue->setExtractFlags(\SplPriorityQueue::EXTR_BOTH); $this->time = (int) $this->provider->getTime(); $this->chunkTickRadius = min($this->server->getViewDistance(), max(1, (int) $this->server->getProperty("chunk-ticking.tick-radius", 3))); $this->chunksPerTick = (int) $this->server->getProperty("chunk-ticking.per-tick", 80); $this->chunkTickList = []; $this->clearChunksOnTick = (bool) $this->server->getProperty("chunk-ticking.clear-tick-list", false); $this->timings = new LevelTimings($this); } public function initLevel(){ $this->server->getGenerationManager()->openLevel($this, $this->generator, $this->provider->getGeneratorOptions()); } /** * @return BlockMetadataStore */ public function getBlockMetadata(){ return $this->blockMetadata; } /** * @return Server */ public function getServer(){ return $this->server; } /** * @return LevelProvider */ final public function getProvider(){ return $this->provider; } /** * Returns the unique level identifier * * @return int */ final public function getID(){ return $this->levelId; } public function close(){ if($this->getAutoSave()){ $this->save(); } foreach($this->chunks as $chunk){ $this->unloadChunk($chunk->getX(), $chunk->getZ(), false); } $this->server->getGenerationManager()->closeLevel($this); $this->provider->close(); $this->provider = null; $this->blockMetadata = null; $this->blockCache = []; } /** * @return bool */ public function getAutoSave(){ return $this->autoSave === true; } /** * @param bool $value */ public function setAutoSave($value){ $this->autoSave = $value; } /** * Unloads the current level from memory safely * * @param bool $force default false, force unload of default level * * @return bool */ public function unload($force = false){ $ev = new LevelUnloadEvent($this); if($this === $this->server->getDefaultLevel() and $force !== true){ $ev->setCancelled(true); } $this->server->getPluginManager()->callEvent($ev); if(!$force and $ev->isCancelled()){ return false; } $this->server->getLogger()->info("Unloading level \"" . $this->getName() . "\""); $defaultLevel = $this->server->getDefaultLevel(); foreach($this->getPlayers() as $player){ if($this === $defaultLevel or $defaultLevel === null){ $player->close(TextFormat::YELLOW . $player->getName() . " has left the game", "Forced default level unload"); }elseif($defaultLevel instanceof Level){ $player->teleport($this->server->getDefaultLevel()->getSafeSpawn()); } } if($this === $defaultLevel){ $this->server->setDefaultLevel(null); } $this->close(); return true; } /** * Gets the chunks being used by players * * @param int $X * @param int $Z * * @return Player[] */ public function getUsingChunk($X, $Z){ return isset($this->usedChunks[$index = "$X:$Z"]) ? $this->usedChunks[$index] : []; } /** * WARNING: Do not use this, it's only for internal use. * Changes to this function won't be recorded on the version. * * @param int $X * @param int $Z * @param Player $player */ public function useChunk($X, $Z, Player $player){ $index = Level::chunkHash($X, $Z); $this->loadChunk($X, $Z); $this->usedChunks[$index][$player->getID()] = $player; } /** * WARNING: Do not use this, it's only for internal use. * Changes to this function won't be recorded on the version. * * @param Player $player */ public function freeAllChunks(Player $player){ foreach($this->usedChunks as $i => $c){ unset($this->usedChunks[$i][$player->getID()]); } } /** * WARNING: Do not use this, it's only for internal use. * Changes to this function won't be recorded on the version. * * @param int $X * @param int $Z * @param Player $player */ public function freeChunk($X, $Z, Player $player){ unset($this->usedChunks[$index = Level::chunkHash($X, $Z)][$player->getID()]); $this->unloadChunkRequest($X, $Z, true); } /** * WARNING: Do not use this, it's only for internal use. * Changes to this function won't be recorded on the version. */ public function checkTime(){ if($this->stopTime == true){ return; }else{ $this->time += 2.5; } } /** * WARNING: Do not use this, it's only for internal use. * Changes to this function won't be recorded on the version. */ public function sendTime(){ $pk = SetTimePacket::getFromPool(); $pk->time = (int) $this->time; $pk->started = $this->stopTime == false; Server::broadcastPacket($this->players, $pk); } /** * WARNING: Do not use this, it's only for internal use. * Changes to this function won't be recorded on the version. * * @param int $currentTick * * @return bool */ public function doTick($currentTick){ $this->timings->doTick->startTiming(); $this->checkTime(); if(($currentTick % 200) === 0){ $this->sendTime(); } $this->unloadChunks(); $X = null; $Z = null; //Do block updates $this->timings->doTickPending->startTiming(); while($this->updateQueue->count() > 0 and $this->updateQueue->current()["priority"] <= $currentTick){ $block = $this->getBlock($this->updateQueue->extract()["data"]); unset($this->updateQueueIndex["{$block->x}:{$block->y}:{$block->z}"]); $block->onUpdate(self::BLOCK_UPDATE_SCHEDULED); } $this->timings->doTickPending->stopTiming(); $this->timings->entityTick->startTiming(); //Update entities that need update Timings::$tickEntityTimer->startTiming(); foreach($this->updateEntities as $id => $entity){ if($entity->closed or !$entity->onUpdate($currentTick)){ unset($this->updateEntities[$id]); } } Timings::$tickEntityTimer->stopTiming(); $this->timings->entityTick->stopTiming(); $this->timings->tileEntityTick->startTiming(); //Update tiles that need update if(count($this->updateTiles) > 0){ //Timings::$tickTileEntityTimer->startTiming(); foreach($this->updateTiles as $id => $tile){ if($tile->onUpdate() !== true){ unset($this->updateTiles[$id]); } } //Timings::$tickTileEntityTimer->stopTiming(); } $this->timings->tileEntityTick->stopTiming(); $this->timings->doTickTiles->startTiming(); $this->tickChunks(); $this->timings->doTickTiles->stopTiming(); if(($currentTick % 200) === 0){ $this->blockCache = []; } if(count($this->changedCount) > 0){ if(count($this->players) > 0){ foreach($this->changedCount as $index => $mini){ for($Y = 0; $Y < 8; ++$Y){ if(($mini & (1 << $Y)) === 0){ continue; } if(count($this->changedBlocks[$index][$Y]) < 582){ //Optimal value, calculated using the relation between minichunks and single packets continue; }else{ $X = null; $Z = null; Level::getXZ($index, $X, $Z); foreach($this->getUsingChunk($X, $Z) as $p){ $p->unloadChunk($X, $Z); } unset($this->changedBlocks[$index][$Y]); } } } $this->changedCount = []; if(count($this->changedBlocks) > 0){ foreach($this->changedBlocks as $index => $mini){ foreach($mini as $blocks){ /** @var Block $b */ foreach($blocks as $b){ $pk = UpdateBlockPacket::getFromPool(); $pk->x = $b->x; $pk->y = $b->y; $pk->z = $b->z; $pk->block = $b->getID(); $pk->meta = $b->getDamage(); Server::broadcastPacket($this->getUsingChunk($b->x >> 4, $b->z >> 4), $pk); } } } $this->changedBlocks = []; } }else{ $this->changedCount = []; $this->changedBlocks = []; } } $this->processChunkRequest(); $this->timings->doTick->stopTiming(); } private function tickChunks(){ if($this->chunksPerTick <= 0 or count($this->players) === 0){ return; } $chunksPerPlayer = min(200, max(1, (int) ((($this->chunksPerTick - count($this->players)) / count($this->players)) + 0.5))); $randRange = 3 + $chunksPerPlayer / 30; $randRange = $randRange > $this->chunkTickRadius ? $this->chunkTickRadius : $randRange; foreach($this->players as $player){ $x = $player->x >> 4; $z = $player->x >> 4; $index = "$x:$z"; $existingPlayers = max(0, isset($this->chunkTickList[$index]) ? $this->chunkTickList[$index] : 0); $this->chunkTickList[$index] = $existingPlayers + 1; for($chunk = 0; $chunk < $chunksPerPlayer; ++$chunk){ $dx = mt_rand(-$randRange, $randRange); $dz = mt_rand(-$randRange, $randRange); $hash = ($dx + $x) .":". ($dz + $z); if(!isset($this->chunkTickList[$hash]) and $this->isChunkLoaded($dx + $x, $dz + $z)){ $this->chunkTickList[$hash] = -1; } } } $chunkX = $chunkZ = null; foreach($this->chunkTickList as $index => $players){ Level::getXZ($index, $chunkX, $chunkZ); if(!$this->isChunkLoaded($chunkX, $chunkZ) or isset($this->unloadQueue[$index]) and $players > 0){ unset($this->chunkTickList[$index]); continue; } $chunk = $this->getChunk($chunkX, $chunkZ, true); foreach($chunk->getEntities() as $entity){ $entity->scheduleUpdate(); } if($this->useSections){ foreach($chunk->getSections() as $section){ if(!($section instanceof EmptyChunkSection)){ $Y = $section->getY(); $k = mt_rand(0, PHP_INT_MAX); for($i = 0; $i < 3; ++$i){ $j = $k >> 2; $x = $j & 0x0f; $y = ($j >> 8) & 0x0f; $z = ($j >> 16) & 0x0f; $k %= 1073741827; $blockId = $section->getBlockId($x, $y, $z); if(isset($this->randomTickBlocks[$blockId])){ $class = $this->randomTickBlocks[$blockId]; /** @var Block $block */ $block = new $class($section->getBlockData($x, $y, $z)); $block->x = $chunkX * 16 + $x; $block->y = ($Y << 4) + $y; $block->z = $chunkZ * 16 + $z; $block->level = $this; $block->onUpdate(self::BLOCK_UPDATE_RANDOM); } } } } }else{ for($Y = 0; $Y < 8; ++$Y){ $k = mt_rand(0, PHP_INT_MAX); for($i = 0; $i < 3; ++$i){ $j = $k >> 2; $x = $j & 0x0f; $y = ($j >> 8) & 0x0f; $z = ($j >> 16) & 0x0f; $k %= 1073741827; $blockId = $chunk->getBlockId($x, $y + ($Y << 4), $z); if(isset($this->randomTickBlocks[$blockId])){ $class = $this->randomTickBlocks[$blockId]; /** @var Block $block */ $block = new $class($chunk->getBlockData($x, $y + ($Y << 4), $z)); $block->x = $chunkX * 16 + $x; $block->y = ($Y << 4) + $y; $block->z = $chunkZ * 16 + $z; $block->level = $this; $block->onUpdate(self::BLOCK_UPDATE_RANDOM); } } } } } if($this->clearChunksOnTick){ $this->chunkTickList = []; } } public function __debugInfo(){ return []; } /** * @param bool $force * * @return bool */ public function save($force = false){ if($this->getAutoSave() === false and $force === false){ return false; } $this->server->getPluginManager()->callEvent(new LevelSaveEvent($this)); $this->provider->setTime((int) $this->time); $this->saveChunks(); if($this->provider instanceof BaseLevelProvider){ $this->provider->saveLevelData(); } return true; } public function saveChunks(){ foreach($this->chunks as $chunk){ if($chunk->hasChanged()){ $this->provider->setChunk($chunk->getX(), $chunk->getZ(), $chunk); $this->provider->saveChunk($chunk->getX(), $chunk->getZ()); $chunk->setChanged(false); } } } /** * @param Vector3 $pos */ public function updateAround(Vector3 $pos){ if($pos instanceof Block){ $block = $pos; }else{ $block = $this->getBlock($pos); } for($side = 0; $side <= 5; ++$side){ $this->server->getPluginManager()->callEvent($ev = new BlockUpdateEvent($block->getSide($side))); if(!$ev->isCancelled()){ $ev->getBlock()->onUpdate(self::BLOCK_UPDATE_NORMAL); } } } /** * @param Vector3 $pos * @param int $delay */ public function scheduleUpdate(Vector3 $pos, $delay){ $index = "{$pos->x}:{$pos->y}:{$pos->z}"; if(isset($this->updateQueueIndex[$index]) and $this->updateQueueIndex[$index] <= $delay){ return; } $this->updateQueueIndex[$index] = $delay; $this->updateQueue->insert(new Vector3((int) $pos->x, (int) $pos->y, (int) $pos->z), (int) $delay + $this->server->getTick()); } /** * @param AxisAlignedBB $bb * * @return Block[] */ public function getCollisionBlocks(AxisAlignedBB $bb){ $minX = Math::floorFloat($bb->minX); $minY = Math::floorFloat($bb->minY); $minZ = Math::floorFloat($bb->minZ); $maxX = Math::floorFloat($bb->maxX + 1); $maxY = Math::floorFloat($bb->maxY + 1); $maxZ = Math::floorFloat($bb->maxZ + 1); $collides = []; $v = Vector3::createVector(0, 0, 0); for($v->z = $minZ; $v->z < $maxZ; ++$v->z){ for($v->x = $minX; $v->x < $maxX; ++$v->x){ for($v->y = $minY - 1; $v->y < $maxY; ++$v->y){ $block = $this->getBlock($v); if(!($block instanceof Air)){ $block->collidesWithBB($bb, $collides); } } } } return $collides; } /** * @param Vector3 $pos * * @return bool */ public function isFullBlock(Vector3 $pos){ if($pos instanceof Block){ $bb = $pos->getBoundingBox(); }else{ $bb = $this->getBlock($pos)->getBoundingBox(); } return $bb instanceof AxisAlignedBB and $bb->getAverageEdgeLength() >= 1; } /** * @param Entity $entity * @param AxisAlignedBB $bb * @param boolean $entities * * @return AxisAlignedBB[] */ public function getCollisionCubes(Entity $entity, AxisAlignedBB $bb, $entities = true){ $minX = Math::floorFloat($bb->minX); $minY = Math::floorFloat($bb->minY); $minZ = Math::floorFloat($bb->minZ); $maxX = Math::floorFloat($bb->maxX + 1); $maxY = Math::floorFloat($bb->maxY + 1); $maxZ = Math::floorFloat($bb->maxZ + 1); $collides = []; $v = Vector3::createVector(0, 0, 0); for($v->z = $minZ; $v->z < $maxZ; ++$v->z){ for($v->x = $minX; $v->x < $maxX; ++$v->x){ for($v->y = $minY - 1; $v->y < $maxY; ++$v->y){ $block = $this->getBlock($v); if(!($block instanceof Air)){ $block->collidesWithBB($bb, $collides); } } } } if($entities){ foreach($this->getCollidingEntities($bb->grow(0.25, 0.25, 0.25), $entity) as $ent){ $collides[] = AxisAlignedBB::cloneBoundingBoxFromPool($ent->boundingBox); } } return $collides; } /* public function rayTraceBlocks(Vector3 $pos1, Vector3 $pos2, $flag = false, $flag1 = false, $flag2 = false){ if(!is_nan($pos1->x) and !is_nan($pos1->y) and !is_nan($pos1->z)){ if(!is_nan($pos2->x) and !is_nan($pos2->y) and !is_nan($pos2->z)){ $x1 = (int) $pos1->x; $y1 = (int) $pos1->y; $z1 = (int) $pos1->z; $x2 = (int) $pos2->x; $y2 = (int) $pos2->y; $z2 = (int) $pos2->z; $block = $this->getBlock(Vector3::createVector($x1, $y1, $z1)); if(!$flag1 or $block->getBoundingBox() !== null){ $ob = $block->calculateIntercept($pos1, $pos2); if($ob !== null){ return $ob; } } $movingObjectPosition = null; $k = 200; while($k-- >= 0){ if(is_nan($pos1->x) or is_nan($pos1->y) or is_nan($pos1->z)){ return null; } if($x1 === $x2 and $y1 === $y2 and $z1 === $z2){ return $flag2 ? $movingObjectPosition : null; } $flag3 = true; $flag4 = true; $flag5 = true; $i = 999; $j = 999; $k = 999; if($x1 > $x2){ $i = $x2 + 1; }elseif($x1 < $x2){ $i = $x2; }else{ $flag3 = false; } if($y1 > $y2){ $j = $y2 + 1; }elseif($y1 < $y2){ $j = $y2; }else{ $flag4 = false; } if($z1 > $z2){ $k = $z2 + 1; }elseif($z1 < $z2){ $k = $z2; }else{ $flag5 = false; } //TODO } } } } */ /** * Gets the Block object on the Vector3 location * * @param Vector3 $pos * @param boolean $cached * * @return Block */ public function getBlock(Vector3 $pos, $cached = true){ $blockId = 0; $meta = 0; $index = "{$pos->x}:{$pos->y}:{$pos->z}"; if($cached and isset($this->blockCache[$index])){ return $this->blockCache[$index]; }elseif($pos->y >= 0 and $pos->y < 128 and ($chunk = $this->getChunk($pos->x >> 4, $pos->z >> 4, true)) !== null){ $chunk->getBlock($pos->x & 0x0f, $pos->y & 0x7f, $pos->z & 0x0f, $blockId, $meta); } if($blockId === 0){ $air = new Air(); $air->x = $pos->x; $air->y = $pos->y; $air->z = $pos->z; $air->level = $this; return $this->blockCache[$index] = $air; } return $this->blockCache[$index] = Block::get($blockId, $meta, new Position($pos->x, $pos->y, $pos->z, $this)); } /** * Sets on Vector3 the data from a Block object, * does block updates and puts the changes to the send queue. * * If $direct is true, it'll send changes directly to players. if false, it'll be queued * and the best way to send queued changes will be done in the next tick. * This way big changes can be sent on a single chunk update packet instead of thousands of packets. * * If $update is true, it'll get the neighbour blocks (6 sides) and update them. * If you are doing big changes, you might want to set this to false, then update manually. * * @param Vector3 $pos * @param Block $block * @param bool $direct * @param bool $update * * @return bool */ public function setBlock(Vector3 $pos, Block $block, $direct = false, $update = true){ if($pos->y < 0 or $pos->y >= 128 or !($block instanceof Block)){ return false; } unset($this->blockCache["{$pos->x}:{$pos->y}:{$pos->z}"]); if($this->getChunk($pos->x >> 4, $pos->z >> 4, true)->setBlock($pos->x & 0x0f, $pos->y & 0x7f, $pos->z & 0x0f, $block->getID(), $block->getDamage())){ if(!($pos instanceof Position)){ $pos = new Position($pos->x, $pos->y, $pos->z, $this); } $block->position($pos); $index = Level::chunkHash($pos->x >> 4, $pos->z >> 4); if(ADVANCED_CACHE == true){ Cache::remove("world:" . $this->getID() . ":" . $index); } //if($direct === true){ $pk = UpdateBlockPacket::getFromPool(); $pk->x = $pos->x; $pk->y = $pos->y; $pk->z = $pos->z; $pk->block = $block->getID(); $pk->meta = $block->getDamage(); Server::broadcastPacket($this->getUsingChunk($pos->x >> 4, $pos->z >> 4), $pk); /*}else{ if(!($pos instanceof Position)){ $pos = new Position($pos->x, $pos->y, $pos->z, $this); } $block->position($pos); if(!isset($this->changedBlocks[$index])){ $this->changedBlocks[$index] = []; $this->changedCount[$index] = 0; } $Y = $pos->y >> 4; if(!isset($this->changedBlocks[$index][$Y])){ $this->changedBlocks[$index][$Y] = []; $this->changedCount[$index] |= 1 << $Y; } $this->changedBlocks[$index][$Y][] = clone $block; }*/ if($update === true){ $this->updateAround($pos); $this->server->getPluginManager()->callEvent($ev = new BlockUpdateEvent($block)); if(!$ev->isCancelled()){ $ev->getBlock()->onUpdate(self::BLOCK_UPDATE_NORMAL); foreach($this->getNearbyEntities(AxisAlignedBB::getBoundingBoxFromPool($block->x - 1, $block->y - 1, $block->z - 1, $block->x + 2, $block->y + 2, $block->z + 2)) as $entity){ $entity->scheduleUpdate(); } } } } } /** * @param Vector3 $source * @param Item $item * @param Vector3 $motion * @param int $delay */ public function dropItem(Vector3 $source, Item $item, Vector3 $motion = null, $delay = 10){ $motion = $motion === null ? Vector3::createVector(lcg_value() * 0.2 - 0.1, 0.2, lcg_value() * 0.2 - 0.1) : $motion; if($item->getID() > 0 and $item->getCount() > 0){ $itemEntity = new DroppedItem($this->getChunk($source->getX() >> 4, $source->getZ() >> 4), new Compound("", [ "Pos" => new Enum("Pos", [ new Double("", $source->getX()), new Double("", $source->getY()), new Double("", $source->getZ()) ]), "Motion" => new Enum("Motion", [ new Double("", $motion->x), new Double("", $motion->y), new Double("", $motion->z) ]), "Rotation" => new Enum("Rotation", [ new Float("", lcg_value() * 360), new Float("", 0) ]), "Health" => new Short("Health", 5), "Item" => new Compound("Item", [ "id" => new Short("id", $item->getID()), "Damage" => new Short("Damage", $item->getDamage()), "Count" => new Byte("Count", $item->getCount()) ]), "PickupDelay" => new Short("PickupDelay", $delay) ])); $itemEntity->spawnToAll(); } } /** * Tries to break a block using a item, including Player time checks if available * It'll try to lower the durability if Item is a tool, and set it to Air if broken. * * @param Vector3 $vector * @param Item &$item (if null, can break anything) * @param Player $player * * @return boolean */ public function useBreakOn(Vector3 $vector, Item &$item = null, Player $player = null){ $target = $this->getBlock($vector); //TODO: Adventure mode checks if($item === null){ $item = Item::get(Item::AIR, 0, 0); } if($player instanceof Player){ $ev = new BlockBreakEvent($player, $target, $item, ($player->getGamemode() & 0x01) === 1 ? true : false); $lastTime = $player->lastBreak - 0.1; //TODO: replace with true lag if(($player->getGamemode() & 0x01) > 0){ $ev->setInstaBreak(true); }elseif(($lastTime + $target->getBreakTime($item)) >= microtime(true)){ $ev->setCancelled(); } if($item instanceof Item and !$target->isBreakable($item) and $ev->getInstaBreak() === false){ $ev->setCancelled(); } if(!$player->isOp() and ($distance = $this->server->getConfigInt("spawn-protection", 16)) > -1){ $t = new Vector2($target->x, $target->z); $s = new Vector2($this->getSpawnLocation()->x, $this->getSpawnLocation()->z); if($t->distance($s) <= $distance){ //set it to cancelled so plugins can bypass this $ev->setCancelled(); } } $this->server->getPluginManager()->callEvent($ev); if($ev->isCancelled()){ return false; } $player->lastBreak = microtime(true); }elseif($item instanceof Item and !$target->isBreakable($item)){ return false; } $level = $target->getLevel(); if($level instanceof Level){ $above = $level->getBlock(Vector3::createVector($target->x, $target->y + 1, $target->z)); if($above instanceof Block){ if($above->getID() === Item::FIRE){ $level->setBlock($above, new Air(), true); } } } $drops = $target->getDrops($item); //Fixes tile entities being deleted before getting drops $target->onBreak($item); $tile = $this->getTile($target); if($tile instanceof Tile){ if($tile instanceof InventoryHolder){ if($tile instanceof Chest){ $tile->unpair(); } foreach($tile->getInventory()->getContents() as $item){ $this->dropItem($target, $item); } } $tile->close(); } if($item instanceof Item){ $item->useOn($target); if($item->isTool() and $item->getDamage() >= $item->getMaxDurability()){ $item = Item::get(Item::AIR, 0, 0); } } if(!($player instanceof Player) or $player->isSurvival()){ foreach($drops as $drop){ if($drop[2] > 0){ $this->dropItem($vector->add(0.5, 0.5, 0.5), Item::get(...$drop)); } } } return true; } /** * Uses a item on a position and face, placing it or activating the block * * @param Vector3 $vector * @param Item $item * @param int $face * @param float $fx default 0.0 * @param float $fy default 0.0 * @param float $fz default 0.0 * @param Player $player default null * * @return boolean */ public function useItemOn(Vector3 $vector, Item &$item, $face, $fx = 0.0, $fy = 0.0, $fz = 0.0, Player $player = null){ $target = $this->getBlock($vector); $block = $target->getSide($face); if($block->y > 127 or $block->y < 0){ return false; } if($target->getID() === Item::AIR){ return false; } if($player instanceof Player){ $ev = new PlayerInteractEvent($player, $item, $target, $face); if(!$player->isOp() and ($distance = $this->server->getConfigInt("spawn-protection", 16)) > -1){ $t = new Vector2($target->x, $target->z); $s = new Vector2($this->getSpawnLocation()->x, $this->getSpawnLocation()->z); if($t->distance($s) <= $distance){ //set it to cancelled so plugins can bypass this $ev->setCancelled(); } } $this->server->getPluginManager()->callEvent($ev); if(!$ev->isCancelled()){ $target->onUpdate(self::BLOCK_UPDATE_TOUCH); if($target->isActivable === true and $target->onActivate($item, $player) === true){ return true; } if($item->isActivable and $item->onActivate($this, $player, $block, $target, $face, $fx, $fy, $fz)){ if($item->getCount() <= 0){ $item = Item::get(Item::AIR, 0, 0); return true; } } } }elseif($target->isActivable === true and $target->onActivate($item, $player) === true){ return true; } if($item->isPlaceable()){ $hand = $item->getBlock(); $hand->position($block); }elseif($block->getID() === Item::FIRE){ $this->setBlock($block, new Air(), true); return false; }else{ return false; } if(!($block->isReplaceable === true or ($hand->getID() === Item::SLAB and $block->getID() === Item::SLAB))){ return false; } if($target->isReplaceable === true){ $block = $target; $hand->position($block); //$face = -1; } if($hand->isSolid === true and $hand->getBoundingBox() !== null){ $entities = $this->getCollidingEntities($hand->getBoundingBox()); $realCount = 0; foreach($entities as $e){ if($e instanceof Arrow or $e instanceof DroppedItem){ continue; } ++$realCount; } if($realCount > 0){ return false; //Entity in block } } if($player instanceof Player){ $ev = new BlockPlaceEvent($player, $hand, $block, $target, $item); if(!$player->isOp() and ($distance = $this->server->getConfigInt("spawn-protection", 16)) > -1){ $t = new Vector2($target->x, $target->z); $s = new Vector2($this->getSpawnLocation()->x, $this->getSpawnLocation()->z); if($t->distance($s) <= $distance){ //set it to cancelled so plugins can bypass this $ev->setCancelled(); } } $this->server->getPluginManager()->callEvent($ev); if($ev->isCancelled()){ return false; } } if($hand->place($item, $block, $target, $face, $fx, $fy, $fz, $player) === false){ return false; } if($hand->getID() === Item::SIGN_POST or $hand->getID() === Item::WALL_SIGN){ $tile = new Sign($this->getChunk($block->x >> 4, $block->z >> 4), new Compound(false, [ "id" => new String("id", Tile::SIGN), "x" => new Int("x", $block->x), "y" => new Int("y", $block->y), "z" => new Int("z", $block->z), "Text1" => new String("Text1", ""), "Text2" => new String("Text2", ""), "Text3" => new String("Text3", ""), "Text4" => new String("Text4", "") ])); if($player instanceof Player){ $tile->namedtag->Creator = new String("Creator", $player->getName()); } } $item->setCount($item->getCount() - 1); if($item->getCount() <= 0){ $item = Item::get(Item::AIR, 0, 0); } return true; } /** * @param int $entityId * * @return Entity */ public function getEntity($entityId){ return isset($this->entities[$entityId]) ? $this->entities[$entityId] : null; } /** * Gets the list of all the entities in this level * * @return Entity[] */ public function getEntities(){ return $this->entities; } /** * Returns the entities colliding the current one inside the AxisAlignedBB * * @param AxisAlignedBB $bb * @param Entity $entity * * @return Entity[] */ public function getCollidingEntities(AxisAlignedBB $bb, Entity $entity = null){ $nearby = []; if($entity === null or $entity->canCollide){ $minX = Math::floorFloat(($bb->minX - 2) / 16); $maxX = Math::floorFloat(($bb->maxX + 2) / 16); $minZ = Math::floorFloat(($bb->minZ - 2) / 16); $maxZ = Math::floorFloat(($bb->maxZ + 2) / 16); for($x = $minX; $x <= $maxX; ++$x){ for($z = $minZ; $z <= $maxZ; ++$z){ foreach($this->getChunkEntities($x, $z) as $ent){ if($ent !== $entity and ($entity === null or $entity->canCollideWith($ent)) and $ent->boundingBox->intersectsWith($bb)){ $nearby[] = $ent; } } } } } return $nearby; } /** * Returns the entities near the current one inside the AxisAlignedBB * * @param AxisAlignedBB $bb * @param Entity $entity * * @return Entity[] */ public function getNearbyEntities(AxisAlignedBB $bb, Entity $entity = null){ $nearby = []; $minX = Math::floorFloat(($bb->minX - 2) / 16); $maxX = Math::floorFloat(($bb->maxX + 2) / 16); $minZ = Math::floorFloat(($bb->minZ - 2) / 16); $maxZ = Math::floorFloat(($bb->maxZ + 2) / 16); for($x = $minX; $x <= $maxX; ++$x){ for($z = $minZ; $z <= $maxZ; ++$z){ if($this->isChunkLoaded($x, $z)){ foreach($this->getChunkEntities($x, $z) as $ent){ if($ent !== $entity and $ent->boundingBox->intersectsWith($bb)){ $nearby[] = $ent; } } } } } return $nearby; } /** * Returns a list of the Tile entities in this level * * @return Tile[] */ public function getTiles(){ return $this->tiles; } /** * @param $tileId * * @return Tile */ public function getTileById($tileId){ return isset($this->tiles[$tileId]) ? $this->tiles[$tileId] : null; } /** * Returns a list of the players in this level * * @return Player[] */ public function getPlayers(){ return $this->players; } /** * Returns the Tile in a position, or false if not found * * @param Vector3 $pos * * @return bool|Tile */ public function getTile(Vector3 $pos){ if($pos instanceof Position and $pos->getLevel() !== $this){ return false; } $tiles = $this->getChunkTiles($pos->x >> 4, $pos->z >> 4); if(count($tiles) > 0){ foreach($tiles as $tile){ if($tile->x === (int) $pos->x and $tile->y === (int) $pos->y and $tile->z === (int) $pos->z){ return $tile; } } } return false; } /** * Returns a list of the entities on a given chunk * * @param int $X * @param int $Z * * @return Entity[] */ public function getChunkEntities($X, $Z){ return ($chunk = $this->getChunk($X, $Z)) instanceof FullChunk ? $chunk->getEntities() : []; } /** * Gives a list of the Tile entities on a given chunk * * @param int $X * @param int $Z * * @return Tile[] */ public function getChunkTiles($X, $Z){ return ($chunk = $this->getChunk($X, $Z)) instanceof FullChunk ? $chunk->getTiles() : []; } /** * Gets the raw block id. * * @param int $x * @param int $y * @param int $z * * @return int 0-255 */ public function getBlockIdAt($x, $y, $z){ return $this->getChunk($x >> 4, $z >> 4, true)->getBlockId($x & 0x0f, $y & 0x7f, $z & 0x0f); } /** * Sets the raw block id. * * @param int $x * @param int $y * @param int $z * @param int $id 0-255 */ public function setBlockIdAt($x, $y, $z, $id){ unset($this->blockCache["$x:$y:$z"]); $this->getChunk($x >> 4, $z >> 4, true)->setBlockId($x & 0x0f, $y & 0x7f, $z & 0x0f, $id & 0xff); } /** * Gets the raw block metadata * * @param int $x * @param int $y * @param int $z * * @return int 0-15 */ public function getBlockDataAt($x, $y, $z){ return $this->getChunk($x >> 4, $z >> 4, true)->getBlockData($x & 0x0f, $y & 0x7f, $z & 0x0f); } /** * Sets the raw block metadata. * * @param int $x * @param int $y * @param int $z * @param int $data 0-15 */ public function setBlockDataAt($x, $y, $z, $data){ unset($this->blockCache["$x:$y:$z"]); $this->getChunk($x >> 4, $z >> 4, true)->setBlockData($x & 0x0f, $y & 0x7f, $z & 0x0f, $data & 0x0f); } /** * Gets the raw block skylight level * * @param int $x * @param int $y * @param int $z * * @return int 0-15 */ public function getBlockSkyLightAt($x, $y, $z){ return $this->getChunk($x >> 4, $z >> 4, true)->getBlockSkyLight($x & 0x0f, $y & 0x7f, $z & 0x0f); } /** * Sets the raw block skylight level. * * @param int $x * @param int $y * @param int $z * @param int $level 0-15 */ public function setBlockSkyLightAt($x, $y, $z, $level){ $this->getChunk($x >> 4, $z >> 4, true)->setBlockSkyLight($x & 0x0f, $y & 0x7f, $z & 0x0f, $level & 0x0f); } /** * Gets the raw block light level * * @param int $x * @param int $y * @param int $z * * @return int 0-15 */ public function getBlockLightAt($x, $y, $z){ return $this->getChunk($x >> 4, $z >> 4, true)->getBlockLight($x & 0x0f, $y & 0x7f, $z & 0x0f); } /** * Sets the raw block light level. * * @param int $x * @param int $y * @param int $z * @param int $level 0-15 */ public function setBlockLightAt($x, $y, $z, $level){ $this->getChunk($x >> 4, $z >> 4, true)->setBlockLight($x & 0x0f, $y & 0x7f, $z & 0x0f, $level & 0x0f); } /** * @param int $x * @param int $z * * @return int */ public function getBiomeId($x, $z){ return $this->getChunk($x >> 4, $z >> 4, true)->getBiomeId($x & 0x0f, $z & 0x0f); } /** * @param int $x * @param int $z * * @return int[] */ public function getBiomeColor($x, $z){ return $this->getChunk($x >> 4, $z >> 4, true)->getBiomeColor($x & 0x0f, $z & 0x0f); } /** * @param int $x * @param int $z * @param int $biomeId */ public function setBiomeId($x, $z, $biomeId){ $this->getChunk($x >> 4, $z >> 4, true)->setBiomeId($x & 0x0f, $z & 0x0f, $biomeId); } /** * @param int $x * @param int $z * @param int $R * @param int $G * @param int $B */ public function setBiomeColor($x, $z, $R, $G, $B){ $this->getChunk($x >> 4, $z >> 4, true)->setBiomeColor($x & 0x0f, $z & 0x0f, $R, $G, $B); } /** * Gets the Chunk object * * @param int $x * @param int $z * @param bool $create Whether to generate the chunk if it does not exist * * @return Chunk */ public function getChunk($x, $z, $create = false){ if(isset($this->chunks[$index = "$x:$z"])){ return $this->chunks[$index]; }elseif($this->loadChunk($x, $z, $create) and $this->chunks[$index] instanceof FullChunk){ return $this->chunks[$index]; } return null; } /** * @param int $x * @param int $z * @param bool $create * * @return Chunk * * @deprecated */ public function getChunkAt($x, $z, $create = false){ return $this->getChunk($x, $z, $create); } public function generateChunkCallback($x, $z, FullChunk $chunk){ $oldChunk = $this->getChunk($x, $z); unset($this->chunkGenerationQueue["$x:$z"]); $this->setChunk($x, $z, $chunk); $chunk = $this->getChunk($x, $z); if($chunk instanceof FullChunk and (!($oldChunk instanceof FullChunk) or $oldChunk->isPopulated() === false) and $chunk->isPopulated()){ $this->server->getPluginManager()->callEvent(new ChunkPopulateEvent($chunk)); } } public function setChunk($x, $z, FullChunk $chunk, $unload = true){ $index = Level::chunkHash($x, $z); if($unload){ foreach($this->getUsingChunk($x, $z) as $player){ $player->unloadChunk($x, $z); } $this->provider->setChunk($x, $z, $chunk); $this->chunks[$index] = $chunk; }else{ $this->provider->setChunk($x, $z, $chunk); $this->chunks[$index] = $chunk; } $chunk->setChanged(); } /** * Gets the highest block Y value at a specific $x and $z * * @param int $x * @param int $z * * @return int 0-127 */ public function getHighestBlockAt($x, $z){ if(!$this->isChunkLoaded($x >> 4, $z >> 4)){ $this->loadChunk($x >> 4, $z >> 4); } return $this->getChunk($x >> 4, $z >> 4, true)->getHighestBlockAt($x & 0x0f, $z & 0x0f); } /** * @param int $x * @param int $z * * @return bool */ public function isChunkLoaded($x, $z){ return isset($this->chunks["$x:$z"]) or $this->provider->isChunkLoaded($x, $z); } /** * @param int $x * @param int $z * * @return bool */ public function isChunkGenerated($x, $z){ $chunk = $this->getChunk($x, $z); return $chunk instanceof FullChunk ? $chunk->isGenerated() : false; } /** * @param int $x * @param int $z * * @return bool */ public function isChunkPopulated($x, $z){ $chunk = $this->getChunk($x, $z); return $chunk instanceof FullChunk ? $chunk->isPopulated() : false; } /** * Returns a Position pointing to the spawn * * @return Position */ public function getSpawnLocation(){ return Position::fromObject($this->provider->getSpawn(), $this); } /** * Sets the level spawn location * * @param Vector3 $pos */ public function setSpawnLocation(Vector3 $pos){ $previousSpawn = $this->getSpawnLocation(); $this->provider->setSpawn($pos); $this->server->getPluginManager()->callEvent(new SpawnChangeEvent($this, $previousSpawn)); } public function requestChunk($x, $z, Player $player, $order = LevelProvider::ORDER_ZXY){ $index = Level::chunkHash($x, $z); if(!isset($this->chunkSendQueue[$index])){ $this->chunkSendQueue[$index] = []; } $this->chunkSendQueue[$index][spl_object_hash($player)] = $player; } protected function processChunkRequest(){ if(count($this->chunkSendQueue) > 0){ $x = null; $z = null; foreach($this->chunkSendQueue as $index => $players){ if(isset($this->chunkSendTasks[$index])){ continue; } Level::getXZ($index, $x, $z); if(ADVANCED_CACHE == true and ($cache = Cache::get("world:" . $this->getID() . ":" . $index)) !== false){ /** @var Player[] $players */ foreach($players as $player){ if(isset($player->usedChunks[$index])){ $player->sendChunk($x, $z, $cache); } } unset($this->chunkSendQueue[$index]); }else{ $this->chunkSendTasks[$index] = true; $task = $this->provider->requestChunkTask($x, $z); if($task instanceof AsyncTask){ $this->server->getScheduler()->scheduleAsyncTask($task); } } } } } public function chunkRequestCallback($x, $z, $payload){ $index = Level::chunkHash($x, $z); if(isset($this->chunkSendTasks[$index])){ if(ADVANCED_CACHE == true){ Cache::add("world:" . $this->getID() . ":" . $index, $payload, 60); } foreach($this->chunkSendQueue[$index] as $player){ /** @var Player $player */ if(isset($player->usedChunks[$index])){ $player->sendChunk($x, $z, $payload); } } unset($this->chunkSendQueue[$index]); unset($this->chunkSendTasks[$index]); } } /** * Removes the entity from the level index * * @param Entity $entity * * @throws \RuntimeException */ public function removeEntity(Entity $entity){ if($entity->getLevel() !== $this){ throw new \RuntimeException("Invalid Entity level"); } if($entity instanceof Player){ unset($this->players[$entity->getID()]); //$this->everyoneSleeping(); }else{ $entity->kill(); } unset($this->entities[$entity->getID()]); unset($this->updateEntities[$entity->getID()]); } /** * @param Entity $entity * * @throws \RuntimeException */ public function addEntity(Entity $entity){ if($entity->getLevel() !== $this){ throw new \RuntimeException("Invalid Entity level"); } if($entity instanceof Player){ $this->players[$entity->getID()] = $entity; } $this->entities[$entity->getID()] = $entity; } /** * @param Tile $tile * * @throws \RuntimeException */ public function addTile(Tile $tile){ if($tile->getLevel() !== $this){ throw new \RuntimeException("Invalid Tile level"); } $this->tiles[$tile->getID()] = $tile; } /** * @param Tile $tile * * @throws \RuntimeException */ public function removeTile(Tile $tile){ if($tile->getLevel() !== $this){ throw new \RuntimeException("Invalid Tile level"); } unset($this->tiles[$tile->getID()]); unset($this->updateTiles[$tile->getID()]); } /** * @param int $x * @param int $z * * @return bool */ public function isChunkInUse($x, $z){ return isset($this->usedChunks[Level::chunkHash($x, $z)]) and count($this->usedChunks[Level::chunkHash($x, $z)]) > 0; } /** * @param int $x * @param int $z * @param bool $generate * * @return bool */ public function loadChunk($x, $z, $generate = true){ if(isset($this->chunks[$index = Level::chunkHash($x, $z)])){ return true; } $this->cancelUnloadChunkRequest($x, $z); $chunk = $this->provider->getChunk($x, $z, $generate); if($chunk instanceof FullChunk){ $this->chunks[$index] = $chunk; $chunk->initChunk(); }else{ $this->timings->syncChunkLoadTimer->startTiming(); $this->provider->loadChunk($x, $z, $generate); $this->timings->syncChunkLoadTimer->stopTiming(); if(($chunk = $this->provider->getChunk($x, $z)) instanceof FullChunk){ $this->chunks[$index] = $chunk; $chunk->initChunk(); }else{ return false; } } $this->server->getPluginManager()->callEvent(new ChunkLoadEvent($chunk, !$chunk->isGenerated())); return true; } protected function queueUnloadChunk($x, $z){ $this->unloadQueue[Level::chunkHash($x, $z)] = microtime(true); } public function unloadChunkRequest($x, $z, $safe = true){ if($safe === true and $this->isChunkInUse($x, $z)){ return false; } $this->queueUnloadChunk($x, $z); return true; } public function cancelUnloadChunkRequest($x, $z){ unset($this->unloadQueue[Level::chunkHash($x, $z)]); } public function unloadChunk($x, $z, $safe = true){ if($safe === true and $this->isChunkInUse($x, $z)){ return false; } $this->timings->doChunkUnload->startTiming(); $index = "$x:$z"; $chunk = $this->getChunk($x, $z); if($chunk instanceof FullChunk){ $this->server->getPluginManager()->callEvent($ev = new ChunkUnloadEvent($chunk)); if($ev->isCancelled()){ return false; } } if($chunk instanceof FullChunk and $chunk->hasChanged() and $this->getAutoSave()){ $this->provider->setChunk($x, $z, $chunk); $this->provider->saveChunk($x, $z); } unset($this->chunks[$index]); $this->provider->unloadChunk($x, $z, $safe); unset($this->usedChunks[$index]); Cache::remove("world:" . $this->getID() . ":$x:$z"); $this->timings->doChunkUnload->stopTiming(); return true; } /** * Returns true if the spawn is part of the spawn * * @param int $X * @param int $Z * * @return bool */ public function isSpawnChunk($X, $Z){ $spawnX = $this->provider->getSpawn()->getX() >> 4; $spawnZ = $this->provider->getSpawn()->getZ() >> 4; return abs($X - $spawnX) <= 1 and abs($Z - $spawnZ) <= 1; } /** * Returns the raw spawnpoint * * @deprecated * @return Position */ public function getSpawn(){ return $this->getSpawnLocation(); } /** * @param Vector3 $spawn default null * * @return bool|Position */ public function getSafeSpawn($spawn = null){ if(!($spawn instanceof Vector3)){ $spawn = $this->getSpawnLocation(); } if($spawn instanceof Vector3){ $x = Math::floorFloat($spawn->x); $y = Math::floorFloat($spawn->y); $z = Math::floorFloat($spawn->z); $v = Vector3::createVector($x, $y, $z); for(; $v->y > 0; --$v->y){ $b = $this->getBlock($v->getSide(0)); if($b === null){ return $spawn; }elseif(!($b instanceof Air)){ break; } } for(; $v->y < 128; ++$v->y){ if($this->getBlock($v->getSide(1)) instanceof Air){ if($this->getBlock($v) instanceof Air){ return new Position($spawn->x, $v->y === Math::floorFloat($spawn->y) ? $spawn->y : $v->y, $spawn->z, $this); } }else{ ++$v->y; } } return new Position($spawn->x, $v->y, $spawn->z, $this); } return false; } /** * Sets the spawnpoint * * @param Vector3 $pos * * @deprecated */ public function setSpawn(Vector3 $pos){ $this->setSpawnLocation($pos); } /** * Gets the current time * * @return int */ public function getTime(){ return (int) $this->time; } /** * Returns the Level name * * @return string */ public function getName(){ return $this->provider->getName(); } /** * Returns the Level folder name * * @return string */ public function getFolderName(){ return $this->folderName; } /** * Sets the current time on the level * * @param int $time */ public function setTime($time){ $this->time = (int) $time; $this->sendTime(); } /** * Stops the time for the level, will not save the lock state to disk */ public function stopTime(){ $this->stopTime = true; $this->sendTime(); } /** * Start the time again, if it was stopped */ public function startTime(){ $this->stopTime = false; $this->sendTime(); } /** * Gets the level seed * * @return int */ public function getSeed(){ return $this->provider->getSeed(); } /** * Sets the seed for the level * * @param int $seed */ public function setSeed($seed){ $this->provider->setSeed($seed); } public function generateChunk($x, $z){ if(!isset($this->chunkGenerationQueue["$x:$z"])){ $this->chunkGenerationQueue["$x:$z"] = true; $this->server->getGenerationManager()->requestChunk($this, $x, $z); } } public function regenerateChunk($x, $z){ $this->unloadChunk($x, $z, false); $this->cancelUnloadChunkRequest($x, $z); $this->generateChunk($x, $z); //TODO: generate & refresh chunk from the generator object } public function doChunkGarbageCollection(){ $this->timings->doChunkGC->startTiming(); $X = null; $Z = null; foreach($this->chunks as $index => $chunk){ if(!isset($this->unloadQueue[$index]) and (!isset($this->usedChunks[$index]) or count($this->usedChunks[$index]) === 0)){ Level::getXZ($index, $X, $Z); if(!$this->isSpawnChunk($X, $Z)){ $this->unloadChunkRequest($X, $Z, true); } } } $this->timings->doChunkGC->stopTiming(); } protected function unloadChunks(){ if(count($this->unloadQueue) > 0){ $X = null; $Z = null; foreach($this->unloadQueue as $index => $time){ Level::getXZ($index, $X, $Z); //If the chunk can't be unloaded, it stays on the queue if($this->unloadChunk($X, $Z, true)){ unset($this->unloadQueue[$index]); } } } } public function setMetadata($metadataKey, MetadataValue $metadataValue){ $this->server->getLevelMetadata()->setMetadata($this, $metadataKey, $metadataValue); } public function getMetadata($metadataKey){ return $this->server->getLevelMetadata()->getMetadata($this, $metadataKey); } public function hasMetadata($metadataKey){ return $this->server->getLevelMetadata()->hasMetadata($this, $metadataKey); } public function removeMetadata($metadataKey, Plugin $plugin){ $this->server->getLevelMetadata()->removeMetadata($this, $metadataKey, $plugin); } }