2resources/maps.json)L resources/config.ymlͤ<src/sergittos/bedwars/session/scoreboard/LobbyScoreboard.php8i;src/sergittos/bedwars/session/scoreboard/GameScoreboard.php&&xŝ>src/sergittos/bedwars/session/scoreboard/WaitingScoreboard.php;;s@7src/sergittos/bedwars/session/scoreboard/Scoreboard.phpჾ)src/sergittos/bedwars/session/Session.php==8f.0src/sergittos/bedwars/session/SessionFactory.phpPP+A7src/sergittos/bedwars/session/settings/GameSettings.php?? Zp<src/sergittos/bedwars/session/settings/SpectatorSettings.php [դ=src/sergittos/bedwars/session/setup/step/AddGeneratorStep.phpxxțH Asrc/sergittos/bedwars/session/setup/step/SetTeamGeneratorStep.php?src/sergittos/bedwars/session/setup/step/SetBedPositionStep.phpRRuBCsrc/sergittos/bedwars/session/setup/step/SetShopAndUpgradesStep.phpKKjӤ1src/sergittos/bedwars/session/setup/step/Step.php =src/sergittos/bedwars/session/setup/step/PreparingMapStep.phpa>#>src/sergittos/bedwars/session/setup/step/area/SetClaimStep.php  Q=src/sergittos/bedwars/session/setup/step/area/SetAreaStep.php  ݀=src/sergittos/bedwars/session/setup/step/area/SetZoneStep.php  0src/sergittos/bedwars/session/setup/MapSetup.php[[:src/sergittos/bedwars/session/setup/builder/MapBuilder.php Du;src/sergittos/bedwars/session/setup/builder/TeamBuilder.phpii~v0src/sergittos/bedwars/command/BedWarsCommand.phpII/Xʤ)src/sergittos/bedwars/utils/GameUtils.php Ms,src/sergittos/bedwars/utils/ConfigGetter.php@@XBX)src/sergittos/bedwars/utils/MathUtils.php  V *src/sergittos/bedwars/utils/ColorUtils.php 488src/sergittos/bedwars/provider/sqlite/SqliteProvider.phpK K 'asrc/sergittos/bedwars/provider/mysql/task/CreateTablesTask.phpmmA裤=src/sergittos/bedwars/provider/mysql/task/UpdateCoinsTask.phpZ8*6src/sergittos/bedwars/provider/mysql/MysqlProvider.phpggktTk+src/sergittos/bedwars/provider/Provider.phpHD4src/sergittos/bedwars/provider/json/JsonProvider.php0src/sergittos/bedwars/form/shop/CategoryForm.php &,src/sergittos/bedwars/form/shop/ShopForm.php__C2src/sergittos/bedwars/form/queue/SelectMapForm.php ;src/sergittos/bedwars/form/queue/element/PlayGameButton.php: '4src/sergittos/bedwars/form/queue/PlayBedwarsForm.phpXX{)src/sergittos/bedwars/form/CustomForm.php}}Cl)src/sergittos/bedwars/form/SimpleForm.phpL7src/sergittos/bedwars/form/spectator/TeleporterForm.php>src/sergittos/bedwars/form/spectator/SpectatorSettingsForm.php}73src/sergittos/bedwars/form/setup/SetupTeamsForm.phpD8src/sergittos/bedwars/form/setup/RemoveGeneratorForm.php%%^#8src/sergittos/bedwars/form/setup/SetupGeneratorsForm.phpnneb-3src/sergittos/bedwars/form/setup/ManageMapsForm.phpҟ0src/sergittos/bedwars/form/setup/BedwarsForm.php_ש9src/sergittos/bedwars/form/setup/RemoveGeneratorsForm.phpxxn1src/sergittos/bedwars/form/setup/SetupMapForm.phpR%5src/sergittos/bedwars/form/setup/AddGeneratorForm.php4oX2src/sergittos/bedwars/form/setup/RemoveMapForm.php24src/sergittos/bedwars/form/setup/TeamOptionsForm.php4\ 3src/sergittos/bedwars/form/setup/MapOptionsForm.php  q4src/sergittos/bedwars/form/setup/SpawnEntityForm.phpBYR2src/sergittos/bedwars/form/setup/CreateMapForm.php..8uT!src/sergittos/bedwars/BedWars.php// ?2src/sergittos/bedwars/entity/PlayBedwarsEntity.php &k*src/sergittos/bedwars/item/BedwarsItem.php$ 7src/sergittos/bedwars/item/spectator/TeleporterItem.phpaa6src/sergittos/bedwars/item/spectator/SpectatorItem.php͢3>src/sergittos/bedwars/item/spectator/SpectatorSettingsItem.php 6src/sergittos/bedwars/item/spectator/PlayAgainItem.phpH:src/sergittos/bedwars/item/spectator/ReturnToLobbyItem.phplld^+src/sergittos/bedwars/item/BedwarsItems.php 99src/sergittos/bedwars/item/setup/SetTeamGeneratorItem.phpTi5src/sergittos/bedwars/item/setup/ClaimingWandItem.phpls2src/sergittos/bedwars/item/setup/ExitSetupItem.phpXX17src/sergittos/bedwars/item/setup/SetBedPositionItem.phpZ.src/sergittos/bedwars/item/setup/SetupItem.phpWW_o/src/sergittos/bedwars/item/setup/CancelItem.phpuΤ2src/sergittos/bedwars/item/setup/CreateMapItem.phpWWxV6src/sergittos/bedwars/item/setup/ConfigurationItem.phpllˤ5src/sergittos/bedwars/item/setup/AddGeneratorItem.phpK$d4src/sergittos/bedwars/item/setup/AddVillagerItem.phpggz_,src/sergittos/bedwars/item/game/Fireball.phpIIR,3src/sergittos/bedwars/item/game/TrackerShopItem.phpɤ1src/sergittos/bedwars/item/game/LeaveGameItem.phpr9/~:src/sergittos/bedwars/listener/SpawnProtectionListener.php__u2src/sergittos/bedwars/listener/SessionListener.phpt2src/sergittos/bedwars/listener/WaitingListener.phpff60src/sergittos/bedwars/listener/SetupListener.php~fͭ/src/sergittos/bedwars/listener/ItemListener.phpC1/src/sergittos/bedwars/listener/GameListener.phpbDbDc2src/sergittos/bedwars/game/generator/Generator.phpi i E:Asrc/sergittos/bedwars/game/generator/presets/DiamondGenerator.php6>src/sergittos/bedwars/game/generator/presets/IronGenerator.php:&Asrc/sergittos/bedwars/game/generator/presets/EmeraldGenerator.phpx>src/sergittos/bedwars/game/generator/presets/GoldGenerator.phpEsrc/sergittos/bedwars/game/generator/presets/TeamEmeraldGenerator.php++?>src/sergittos/bedwars/game/generator/presets/TextGenerator.php6src/sergittos/bedwars/game/generator/GeneratorText.php`x+n-src/sergittos/bedwars/game/generator/Tier.php88+06src/sergittos/bedwars/game/generator/GeneratorType.phpxx"-,src/sergittos/bedwars/game/GameHeartbeat.phpI/src/sergittos/bedwars/game/shop/ShopFactory.php>(src/sergittos/bedwars/game/shop/Shop.phpaaB,src/sergittos/bedwars/game/shop/Category.php,+src/sergittos/bedwars/game/shop/Product.phpe7src/sergittos/bedwars/game/shop/tracker/TrackerShop.phpXF;src/sergittos/bedwars/game/shop/tracker/TrackerCategory.phpɗ:src/sergittos/bedwars/game/shop/tracker/TrackerProduct.php@@R9src/sergittos/bedwars/game/shop/upgrades/UpgradesShop.phpXXL%<src/sergittos/bedwars/game/shop/upgrades/UpgradesProduct.phpgg@ @src/sergittos/bedwars/game/shop/upgrades/product/TrapProduct.phpaaalCsrc/sergittos/bedwars/game/shop/upgrades/product/UpgradeProduct.phpjceFsrc/sergittos/bedwars/game/shop/upgrades/category/UpgradesCategory.phpؒKCsrc/sergittos/bedwars/game/shop/upgrades/category/TrapsCategory.php61src/sergittos/bedwars/game/shop/item/ItemShop.php4src/sergittos/bedwars/game/shop/item/ItemProduct.phpS?src/sergittos/bedwars/game/shop/item/category/MeleeCategory.php,IAsrc/sergittos/bedwars/game/shop/item/category/PotionsCategory.php1@src/sergittos/bedwars/game/shop/item/category/RangedCategory.php44M@src/sergittos/bedwars/game/shop/item/category/BlocksCategory.phpvv)yc?src/sergittos/bedwars/game/shop/item/category/ArmorCategory.php%%)`>src/sergittos/bedwars/game/shop/item/category/MiscCategory.php&?src/sergittos/bedwars/game/shop/item/category/ToolsCategory.php /-src/sergittos/bedwars/game/map/MapFactory.php}15src/sergittos/bedwars/game/map/task/DeleteMapTask.php  K]5src/sergittos/bedwars/game/map/task/CreateMapTask.phpM3ڤ0src/sergittos/bedwars/game/map/MapProperties.php;;&src/sergittos/bedwars/game/map/Map.php gGsrc/sergittos/bedwars/game/event/presets/UpgradeGeneratorsTierEvent.php&i?src/sergittos/bedwars/game/event/presets/EndGameInATieEvent.php k͙@src/sergittos/bedwars/game/event/presets/BedDestructionEvent.php]]kS*src/sergittos/bedwars/game/event/Event.phpEE4,src/sergittos/bedwars/game/team/Upgrades.phpb b w/$(src/sergittos/bedwars/game/team/Team.phpZZhnr(src/sergittos/bedwars/game/team/Area.phpQCEҤ3src/sergittos/bedwars/game/team/upgrade/Upgrade.phpݻ'Csrc/sergittos/bedwars/game/team/upgrade/presets/ArmorProtection.phpLLb=src/sergittos/bedwars/game/team/upgrade/presets/IronForge.php{FCsrc/sergittos/bedwars/game/team/upgrade/presets/SharpenedSwords.phpm!`?src/sergittos/bedwars/game/team/upgrade/presets/ManiacMiner.php9tK<src/sergittos/bedwars/game/team/upgrade/presets/HealPool.php;;S5src/sergittos/bedwars/game/team/upgrade/trap/Trap.phppd<src/sergittos/bedwars/game/team/upgrade/trap/DefaultTrap.php\NEsrc/sergittos/bedwars/game/team/upgrade/trap/CounterOffensiveTrap.php;JAsrc/sergittos/bedwars/game/team/upgrade/trap/MinerFatigueTrap.php55:src/sergittos/bedwars/game/team/upgrade/trap/AlarmTrap.php[82src/sergittos/bedwars/game/team/TeamProperties.phpT;4Q2src/sergittos/bedwars/game/task/RemoveGameTask.php#[4src/sergittos/bedwars/game/task/GenerateGameTask.phpI*src/sergittos/bedwars/game/stage/Stage.phpA2src/sergittos/bedwars/game/stage/StartingStage.phpѤ8src/sergittos/bedwars/game/stage/trait/JoinableTrait.phpb1src/sergittos/bedwars/game/stage/WaitingStage.php.8s11src/sergittos/bedwars/game/stage/PlayingStage.php||a*src/sergittos/bedwars/game/GameManager.php- - q#src/sergittos/bedwars/game/Game.php##aTt;src/sergittos/bedwars/game/entity/shop/ItemShopVillager.php""}ܤ3src/sergittos/bedwars/game/entity/shop/Villager.php; ; r?src/sergittos/bedwars/game/entity/shop/UpgradesShopVillager.phpu?3src/sergittos/bedwars/game/entity/misc/Fireball.php plugin.yml1r|_[]# The version version: 1.0 # The IP that will be showed on the scoreboard and the bossbar ip: "play.server.net" # Players won't be able to break/place blocks or receive damage on the lobby if this is enabled spawn-protection: true # Provider # Available providers: sqlite, mysql, json provider: "sqlite" # MySQL mysql-credentials: hostname: "127.0.0.1" username: "root" password: "" database: "bedwars" port: 3306 " ", 6 => "{WHITE}Coins: {GREEN}" . $session->getCoins(), 5 => " ", 4 => "{WHITE}Total Kills: {GREEN}" . $session->getKills(), 3 => "{WHITE}Total Wins: {GREEN}" . $session->getWins(), ]; } }hasGame()) { return []; } $stage = $session->getGame()->getStage(); if(!$stage instanceof PlayingStage) { return []; } $event = $stage->getNextEvent(); return [ 14 => "{GRAY}" . date("m/d/y"), 13 => " ", 12 => "{WHITE}" . $event->getName() . " in: {GREEN}" . gmdate("i:s", $event->getTimeRemaining()) . " ", 11 => " ", ] + $this->getTeams($session); } private function getTeams(Session $session): array { $teams = []; $score = 10; foreach($session->getGame()->getTeams() as $team) { $teams[$score] = ColorUtils::translate( $team->getColor() . $team->getFirstLetter() . " {WHITE}" . $team->getName() . ": " . $this->getBedStatus($team) . ($team->hasMember($session) ? " {GRAY}YOU" : " ") ); $score--; } return $teams; } private function getBedStatus(Team $team): string { return !$team->isAlive() ? "{RED}X" : "{GREEN}" . ($team->isBedDestroyed() ? $team->getMembersCount() : "Alive"); } }getGame(); $map = $game->getMap(); $stage = $game->getStage(); return [ 10 => " ", 9 => "{WHITE}Map: {GREEN}" . $map->getName(), 8 => "{WHITE}Players: {GREEN}" . $game->getPlayersCount() . "/" . $map->getMaxCapacity(), 7 => " ", 6 => !$stage instanceof StartingStage ? "{WHITE}Waiting..." : "{WHITE}Starting in {GREEN}" . $stage->getCountdown() . "s", 5 => " ", 4 => "{WHITE}Mode: {GREEN}" . GameUtils::getMode($map->getPlayersPerTeam()), 3 => "{WHITE}Version: {GRAY}v" . ConfigGetter::getVersion() ]; } }isOnline()) { $this->hide($session); $packet = new SetDisplayObjectivePacket(); $packet->displaySlot = SetDisplayObjectivePacket::DISPLAY_SLOT_SIDEBAR; $packet->objectiveName = $session->getUsername(); $packet->displayName = ColorUtils::translate(self::TITLE); $packet->criteriaName = "dummy"; $packet->sortOrder = SetDisplayObjectivePacket::SORT_ORDER_DESCENDING; $session->sendDataPacket($packet); foreach($this->getLines($session) as $score => $line) { $this->addLine($score, " " . $line, $session); } $this->addLine(2, " ", $session); $this->addLine(1, " {YELLOW}" . ConfigGetter::getIP(), $session); } } private function addLine(int $score, string $text, Session $session): void { $entry = new ScorePacketEntry(); $entry->objectiveName = $session->getUsername(); $entry->type = ScorePacketEntry::TYPE_FAKE_PLAYER; $entry->customName = ColorUtils::translate($text); $entry->score = $score; $entry->scoreboardId = $score; $packet = new SetScorePacket(); $packet->type = SetScorePacket::TYPE_CHANGE; $packet->entries[] = $entry; $session->sendDataPacket($packet); } private function hide(Session $session): void { if($session->isOnline()) { $packet = new RemoveObjectivePacket(); $packet->objectiveName = $session->getUsername(); $session->sendDataPacket($packet); } } /** * @return string[] */ abstract protected function getLines(Session $session): array; }player = $player; $this->game_settings = new GameSettings($this); $this->load(); $this->setEffectHooks(); } public function getPlayer(): Player { return $this->player; } public function getUsername(): string { return $this->player->getName(); } public function getColoredUsername(): string { $username = $this->getUsername(); if($this->hasTeam()) { return $this->team->getColor() . $username; } return $username; } public function getGameSettings(): GameSettings { return $this->game_settings; } public function getSpectatorSettings(): SpectatorSettings { return $this->spectator_settings; } public function getGame(): ?Game { return $this->game; } public function getTeam(): ?Team { return $this->team; } public function getMapSetup(): ?MapSetup { return $this->mapSetup; } public function getLastSessionHit(): ?Session { if($this->last_session_hit_time === null) { return null; } if(time() - $this->last_session_hit_time <= 10) { return $this->last_session_hit; } return null; } public function getTrackingSession(): ?Session { return $this->tracking_session; } public function getCoins(): int { return $this->coins; } public function getKills(): int { return $this->kills; } public function getWins(): int { return $this->wins; } public function resetSettings(): void { $this->game_settings = new GameSettings($this); $this->respawn_time = null; } public function setSpectatorSettings(SpectatorSettings $spectator_settings): void { $this->spectator_settings = $spectator_settings; } public function setScoreboard(Scoreboard $scoreboard): void { $this->scoreboard = $scoreboard; $this->updateScoreboard(); } public function setGame(?Game $game): void { $this->game = $game; } public function setTeam(?Team $team): void { $this->team = $team; } public function setMapSetup(?MapSetup $mapSetup): void { $this->mapSetup = $mapSetup; } public function setLastSessionHit(?Session $last_session_hit): void { $this->last_session_hit = $last_session_hit; $this->last_session_hit_time = time(); } public function setTrackingSession(?Session $tracking_session): void { $this->tracking_session = $tracking_session; $this->updateCompassDirection(); } public function updateCompassDirection(): void { $this->player->getNetworkSession()->syncWorldSpawnPoint( $this->tracking_session !== null ? $this->tracking_session->getPlayer()->getPosition() : $this->player->getWorld()->getSpawnLocation() ); } public function updateScoreboard(): void { $this->scoreboard->show($this); } public function attemptToRespawn(): void { if($this->respawn_time <= 0) { $this->respawn_time = null; $this->respawn(); return; } if($this->respawn_time < 5) { $message = "{YELLOW}You will respawn in {RED}" . $this->respawn_time . " {YELLOW}" . ($this->respawn_time === 1 ? "second" : "seconds") . "!"; $this->title("{RED}YOU DIED!", $message); $this->message($message); } $this->respawn_time--; } private function respawn(): void { $this->message("{YELLOW}You have respawned!"); $this->title("{GREEN}RESPAWNED!", "", 7, 21, 7); $this->game_settings->apply(); $this->player->setGamemode(GameMode::SURVIVAL()); $this->player->setHealth($this->player->getMaxHealth()); $this->player->teleport($this->team->getSpawnPoint()); } public function setCoins(int $coins): void { $this->coins = $coins; if(!$this->loading_data) { BedWars::getInstance()->getProvider()->updateCoins($this); } } public function addCoins(int $coins): void { $this->setCoins($this->coins + $coins); } public function setKills(int $kills): void { $this->kills = $kills; if(!$this->loading_data) { BedWars::getInstance()->getProvider()->updateKills($this); } } public function addKill(): void { $this->setKills($this->kills + 1); } public function setWins(int $wins): void { $this->wins = $wins; if(!$this->loading_data) { BedWars::getInstance()->getProvider()->updateWins($this); } } public function addWin(): void { $this->setWins($this->wins + 1); } public function isPlaying(): bool { return $this->hasGame() and $this->game->isPlaying($this); } public function isSpectator(): bool { return $this->hasGame() and $this->game->isSpectator($this); } public function hasGame(): bool { return $this->game !== null; } public function hasTeam(): bool { return $this->team !== null; } public function isCreatingMap(): bool { return $this->mapSetup !== null; } public function isRespawning(): bool { return $this->respawn_time !== null; } public function isOnline(): bool { return $this->player->isOnline(); } public function showBossBar(string $title): void { $this->hideBossBar(); $this->sendDataPacket( BossEventPacket::show($this->player->getId(), ColorUtils::translate($title), 10, false, 0, BossBarColor::BLUE) ); } public function hideBossBar(): void { $this->sendDataPacket(BossEventPacket::hide($this->player->getId())); } public function sendDataPacket(ClientboundPacket $packet): void { $this->player->getNetworkSession()->sendDataPacket($packet); } public function playSound(string $sound, float $volume = 1.0, float $pitch = 1.0): void { $location = $this->player->getLocation(); $this->sendDataPacket(PlaySoundPacket::create( $sound, $location->getX(), $location->getY(), $location->getZ(), $volume, $pitch )); } public function clearAllInventories(): void { $this->clearCommonInventories(); $this->player->getEnderInventory()->clearAll(); } public function clearCommonInventories(): void { $this->player->getCursorInventory()->clearAll(); $this->player->getOffHandInventory()->clearAll(); $this->player->getArmorInventory()->clearAll(); $this->player->getInventory()->clearAll(); } public function giveCreatingMapItems(): void { $this->clearAllInventories(); $inventory = $this->player->getInventory(); $inventory->setItem(0, BedwarsItems::CONFIGURATION()->asItem()); $inventory->setItem(4, BedwarsItems::CREATE_MAP()->asItem()); $inventory->setItem(8, BedwarsItems::EXIT_SETUP()->asItem()); } public function giveWaitingItems(): void { $this->clearAllInventories(); $this->player->getInventory()->setItem(8, BedwarsItems::LEAVE_GAME()->asItem()); } public function giveSpectatorItems(): void { $this->clearAllInventories(); $inventory = $this->player->getInventory(); $inventory->setItem(0, BedwarsItems::TELEPORTER()->asItem()); $inventory->setItem(4, BedwarsItems::SPECTATOR_SETTINGS()->asItem()); $inventory->setItem(7, BedwarsItems::PLAY_AGAIN()->asItem()); $inventory->setItem(8, BedwarsItems::RETURN_TO_LOBBY()->asItem()); } public function addEffect(EffectInstance $effect_instance): void { $this->player->getEffects()->add($effect_instance); } public function teleportToWaitingWorld(): void { $this->player->teleport($this->game->getMap()->getWaitingWorld()->getSafeSpawn()); } public function teleportToHub(): void { $this->player->getEffects()->clear(); $this->player->setGamemode(GameMode::ADVENTURE()); $this->player->setHealth($this->player->getMaxHealth()); $this->player->setNameTag($this->player->getDisplayName()); $this->player->teleport(Server::getInstance()->getWorldManager()->getDefaultWorld()->getSafeSpawn()); $this->clearAllInventories(); $this->setTrackingSession(null); $this->setScoreboard(new LobbyScoreboard()); $this->showBossBar("{DARK_GREEN}You are playing on {AQUA}" . strtoupper(ConfigGetter::getIP())); } public function kill(int $cause): void { $killer_session = $this->getLastSessionHit(); $session_username = $this->getColoredUsername(); if($killer_session !== null) { $killer_session->addCoins(8); // TODO: Check for final kill $killer_session->addKill(); $killer_session->playSound("random.orb"); $killer_username = $killer_session->getColoredUsername(); if($cause === EntityDamageEvent::CAUSE_ENTITY_ATTACK) { $this->game->broadcastMessage($session_username . " {GRAY}was killed by " . $killer_username . "{GRAY}."); } elseif($cause === EntityDamageEvent::CAUSE_VOID) { $this->game->broadcastMessage($session_username . " {GRAY}was knocked into the void by " . $killer_username . "{GRAY}."); } if(!$killer_session->isSpectator()) { foreach($this->player->getInventory()->getContents() as $item) { if(!in_array($item->getTypeId(), [ItemTypeIds::IRON_INGOT, ItemTypeIds::GOLD_INGOT, ItemTypeIds::DIAMOND, ItemTypeIds::EMERALD])) { continue; } $killer_session->getPlayer()->getInventory()->addItem($item); } } } if($cause === EntityDamageEvent::CAUSE_VOID and $killer_session === null) { $this->game->broadcastMessage($session_username . " {GRAY}fell to the void."); } $this->player->getEffects()->clear(); $this->player->teleport($this->game->getMap()->getSpectatorSpawnPosition()); $this->player->setGamemode(GameMode::SPECTATOR()); $this->game_settings->decreasePickaxeTier(); $this->game_settings->decreaseAxeTier(); if($this->hasTeam() and $this->team->isBedDestroyed()) { $this->game->removePlayer($this, false, true); return; } elseif($this->game->getStage() instanceof EndingStage) { return; } $this->respawn_time = self::RESPAWN_DURATION; $this->clearCommonInventories(); $this->title( "{RED}YOU DIED!", $message = "{YELLOW}You will respawn in {RED}" . self::RESPAWN_DURATION . " {YELLOW}seconds!", 0, 41 ); $this->message($message); } private function setEffectHooks(): void { $effects = $this->player->getEffects(); $effects->getEffectAddHooks()->add(function(EffectInstance $effect_instance): void { if($effect_instance->getType() instanceof InvisibilityEffect and $this->isPlaying()) { $this->vanish(); } }); $effects->getEffectRemoveHooks()->add(function(EffectInstance $effect_instance): void { if($effect_instance->getType() instanceof InvisibilityEffect and $this->isPlaying()) { $this->unvanish(); } }); } private function vanish(): void { $id = $this->player->getId(); $item = ItemStackWrapper::legacy(TypeConverter::getInstance()->coreItemStackToNet(VanillaItems::AIR())); $slot = $this->player->getInventory()->getHeldItemIndex(); foreach($this->game->getPlayers() as $session) { $session = $session->getPlayer()->getNetworkSession(); $session->sendDataPacket(MobEquipmentPacket::create($id, $item, $slot, $slot, ContainerIds::INVENTORY)); $session->sendDataPacket(MobArmorEquipmentPacket::create($id, $item, $item, $item, $item)); } } private function unvanish(): void { foreach($this->game->getPlayers() as $session) { $network_session = $session->getPlayer()->getNetworkSession(); $broadcaster = $network_session->getEntityEventBroadcaster(); $broadcaster->onMobArmorChange([$network_session], $this->player); $broadcaster->onMobMainHandItemChange([$network_session], $this->player); } } public function load(): void { $this->loading_data = true; BedWars::getInstance()->getProvider()->loadSession($this); $this->loading_data = false; } public function save(): void { BedWars::getInstance()->getProvider()->saveSession($this); } public function title(string $title, string $subtitle = "", int $fade_in = 0, int $stay = 21, int $fade_out = 0): void { $this->player->sendTitle( ColorUtils::translate($title), ColorUtils::translate($subtitle), $fade_in, $stay, $fade_out ); } public function message(string $message): void { $this->player->sendMessage(ColorUtils::translate($message)); } } getName())]); } static public function getSession(Player $player): ?Session { return self::$sessions[strtolower($player->getName())] ?? null; } static public function getSessionByName(string $name): ?Session { return self::$sessions[strtolower($name)] ?? null; } static public function createSession(Player $player): void { self::$sessions[strtolower($player->getName())] = new Session($player); } static public function removeSession(Player $player): void { self::getSession($player)->save(); unset(self::$sessions[strtolower($player->getName())]); } }session = $session; } public function hasPermanentShears(): bool { return $this->permanent_shears; } public function hasArmor(): bool { return $this->armor !== null; } public function isUnderMagicMilkEffect(): bool { return time() - $this->magic_milk_time < 30; } public function isPickaxeFullUpgraded(): bool { return $this->pickaxe_tier >= 4; } public function isAxeFullUpgraded(): bool { return $this->axe_tier >= 4; } public function getArmor(): ?string { return $this->armor; } public function getPickaxeTier(): int { return $this->pickaxe_tier; } public function getAxeTier(): int { return $this->axe_tier; } public function setPermanentShears(): void { $this->permanent_shears = true; } public function setMagicMilk(): void { $this->magic_milk_time = time(); } public function incrasePickaxeTier(): void { $this->pickaxe_tier++; } public function incraseAxeTier(): void { $this->axe_tier++; } public function decreasePickaxeTier(): void { if($this->pickaxe_tier > 1) { $this->pickaxe_tier--; } } public function decreaseAxeTier(): void { if($this->axe_tier > 1) { $this->axe_tier--; } } public function setArmor(?string $armor): void { $this->armor = $armor; $this->applyArmor(); } public function apply(): void { $player = $this->session->getPlayer(); if(!$player->isConnected()) { return; } $inventory = $player->getInventory(); $inventory->addItem(VanillaItems::WOODEN_SWORD()->setUnbreakable()); $inventory->setItem(8, BedwarsItems::TRACKER_SHOP()->asItem()); if($this->permanent_shears) { $inventory->addItem(VanillaItems::SHEARS()); } if($this->pickaxe_tier > 0) { $inventory->addItem($this->getTool("pickaxe", $this->pickaxe_tier)); } if($this->axe_tier > 0) { $inventory->addItem($this->getTool("axe", $this->axe_tier)); } $inventory = $player->getArmorInventory(); $inventory->setHelmet($this->getLeatherArmor(VanillaItems::LEATHER_CAP())); $inventory->setChestplate($this->getLeatherArmor(VanillaItems::LEATHER_TUNIC())); $this->applyArmor(); foreach($this->session->getTeam()->getUpgrades()->getAll() as $upgrade) { $upgrade->applySession($this->session); } } private function applyArmor(): void { $inventory = $this->session->getPlayer()->getArmorInventory(); if($this->armor !== null) { $inventory->setLeggings($this->getArmorPiece("leggings")); $inventory->setBoots($this->getArmorPiece("boots")); } else { $inventory->setLeggings($this->getLeatherArmor(VanillaItems::LEATHER_PANTS())); $inventory->setBoots($this->getLeatherArmor(VanillaItems::LEATHER_BOOTS())); } } public function getTool(string $name, int $tier): Tool { /** @var Tool $item */ $item = StringToItemParser::getInstance()->parse(strtolower($this->getMaterial($tier) . "_" . $name)); $item->setUnbreakable(); $item->addEnchantment(new EnchantmentInstance(VanillaEnchantments::EFFICIENCY(), $tier !== 4 ? $tier : 3)); if($tier === 3) { $item->addEnchantment(new EnchantmentInstance(VanillaEnchantments::SHARPNESS(), 3)); } return $item; } private function getLeatherArmor(Armor $armor): Armor { return $this->addComponents($armor->setCustomColor($this->session->getTeam()->getDyeColor()->getRgbValue()))->setUnbreakable(); } private function getArmorPiece(string $piece): Armor { return $this->addComponents(StringToItemParser::getInstance()->parse(strtolower($this->armor) . "_" . strtolower($piece)))->setUnbreakable(); } private function addComponents(Item $item): Armor|Item { $protection_level = $this->session->getTeam()?->getUpgrades()->getArmorProtection()->getLevel(); if($protection_level >= 1) { $item->addEnchantment(new EnchantmentInstance(VanillaEnchantments::PROTECTION(), $protection_level)); } $item->getNamedTag()->setByte("bedwars_item", 1); return $item; } public function getMaterial(int $tier): string { return match($tier) { 0, 1 => "Wooden", 2 => "Iron", 3 => "Golden", 4, 5 => "Diamond" }; } }session = $session; $this->flying_speed = $flying_speed; $this->auto_teleport = $auto_teleport; $this->night_vision = $night_vision; } static public function fromData(Session $session, array $data): SpectatorSettings { return new SpectatorSettings($session, (int) $data["flying_speed"], (bool) $data["auto_teleport"], (bool) $data["night_vision"]); } public function getFlyingSpeed(): int { return $this->flying_speed; } public function getAutoTeleport(): bool { return $this->auto_teleport; } public function getNightVision(): bool { return $this->night_vision; } public function setFlyingSpeed(int $flying_speed): void { $this->flying_speed = $flying_speed; if($this->flying_speed !== 0) { $this->session->message("{GREEN}You now have Speed " . GameUtils::intToRoman($flying_speed) . "!"); } else { $this->session->message("{RED}You no longer have any speed effects!"); } } public function setAutoTeleport(bool $auto_teleport): void { $this->auto_teleport = $auto_teleport; if($this->auto_teleport) { $this->session->message("{GREEN}Once you select a player using your compass, it will auto teleport you to them!"); } else { $this->session->message("{RED}You will no longer auto teleport to targets!"); } } public function setNightVision(bool $night_vision): void { $this->night_vision = $night_vision; if($this->night_vision) { $this->session->message("{GREEN}You now have night vision!"); } else { $this->session->message("{RED}You no longer have night vision!"); } } public function apply(): void { $this->session->getPlayer()->getEffects()->clear(); if($this->flying_speed !== 0) { $this->session->addEffect(new EffectInstance(VanillaEffects::SPEED(), Limits::INT32_MAX, $this->flying_speed - 1, false)); } if($this->night_vision) { $this->session->addEffect(new EffectInstance(VanillaEffects::NIGHT_VISION(), Limits::INT32_MAX, 0, false)); } } }type = $type; } protected function onStart(): void { $block = match($this->type) { GeneratorType::DIAMOND => BedwarsItems::DIAMOND_GENERATOR(), GeneratorType::EMERALD => BedwarsItems::EMERALD_GENERATOR() }; $this->session->clearAllInventories(); $this->session->message("{YELLOW}Break the block below the generator with the item you have received in your inventory to set the generator."); $inventory = $this->session->getPlayer()->getInventory(); $inventory->setItem(0, $block->asItem()); $inventory->setItem(8, BedwarsItems::CANCEL()->asItem()); } public function onBlockBreak(Block $block, BedwarsItem $item): void { if($item instanceof AddGeneratorItem) { $position = $block->getPosition(); $position->getWorld()->setBlock($position, $item->asItem()->getBlock()); $setup = $this->session->getMapSetup(); $setup->getMapBuilder()->addGenerator(GeneratorType::toGenerator($position, $this->type)); $setup->setStep(new PreparingMapStep()); $this->session->message("{GREEN}You have successfully set the generator."); } } }team = $team; } protected function onStart(): void { $this->session->clearAllInventories(); $this->session->message("{YELLOW}Break the block below the generator with the item you have received in your inventory to set the generator."); $inventory = $this->session->getPlayer()->getInventory(); $inventory->setItem(0, BedwarsItems::TEAM_GENERATOR()->asItem()); $inventory->setItem(8, BedwarsItems::CANCEL()->asItem()); } public function onBlockBreak(Block $block, BedwarsItem $item): void { if($item instanceof SetTeamGeneratorItem) { $this->team->setGeneratorPosition($block->getPosition()); $this->session->getMapSetup()->setStep(new PreparingMapStep()); $this->session->message("{GREEN}You have successfully set the generator."); } } }team = $team; } protected function onStart(): void { $this->session->clearAllInventories(); $this->session->message("{YELLOW}Place the bed you received in your inventory to set the position."); $inventory = $this->session->getPlayer()->getInventory(); $inventory->setItem(0, BedwarsItems::BED_POSITION()->setColor($this->team->getDyeColor())->asItem()); $inventory->setItem(8, BedwarsItems::CANCEL()->asItem()); } public function onBlockInteract(Vector3 $touch_vector, int $action, Cancellable $event, BedwarsItem $item): void { if($item instanceof SetBedPositionItem and $action === PlayerInteractEvent::RIGHT_CLICK_BLOCK) { $this->team->setBedPosition($touch_vector); $this->session->getMapSetup()->setStep(new PreparingMapStep()); $this->session->message("{GREEN}You have successfully set the bed position."); $event->uncancel(); } } }session->clearAllInventories(); $this->session->message("{YELLOW}Use the eggs you received in your inventory to set the shop and upgrades of the team"); $inventory = $this->session->getPlayer()->getInventory(); $inventory->setItem(0, BedwarsItems::ITEM_VILLAGER()->asItem()); $inventory->setItem(1, BedwarsItems::UPGRADES_VILLAGER()->asItem()); $inventory->setItem(8, BedwarsItems::CANCEL()->asItem()->setCustomName(TextFormat::GREEN . "Done")); } public function onBlockInteract(Vector3 $touch_vector, int $action, Cancellable $event, BedwarsItem $item): void { if($action !== PlayerInteractEvent::RIGHT_CLICK_BLOCK or !$item instanceof AddVillagerItem) { return; } $map = $this->session->getMapSetup()->getMapBuilder(); $name = $item->getName(); match($name) { Shop::ITEM => $map->addShopPosition($touch_vector), Shop::UPGRADES => $map->addUpgradesPosition($touch_vector) }; $this->session->message("{GREEN}You have successfully set the $name position."); } }session = $session; $this->onStart(); } abstract protected function onStart(): void; public function onBlockBreak(Block $block, BedwarsItem $item): void {} public function onBlockInteract(Vector3 $touch_vector, int $action, Cancellable $event, BedwarsItem $item): void {} public function onInteract(BedwarsItem $item): void {} }session->giveCreatingMapItems(); } }team->setClaim($area); } }team = $team; } protected function onStart(): void { $this->session->clearAllInventories(); $this->session->message("{GOLD}Set team area started."); $this->session->message("{YELLOW}Left click at a corner of the area you'd like to set."); $this->session->message("{YELLOW}Right click on the second corner of the area you'd like to set."); $this->session->message("{YELLOW}Sneak and click to set your area."); $this->session->message("{GREEN}Gave you a claim wand."); $inventory = $this->session->getPlayer()->getInventory(); $inventory->setItem(0, BedwarsItems::CLAIMING_WAND()->asItem()); $inventory->setItem(8, BedwarsItems::CANCEL()->asItem()); } public function onBlockInteract(Vector3 $touch_vector, int $action, Cancellable $event, BedwarsItem $item): void { if(!$item instanceof ClaimingWandItem) { return; } switch($action) { case PlayerInteractEvent::LEFT_CLICK_BLOCK: $this->first_position = $touch_vector; $this->session->message("{GREEN}First position set."); break; case PlayerInteractEvent::RIGHT_CLICK_BLOCK: $this->second_position = $touch_vector; $this->session->message("{GREEN}Second position set."); break; } } public function onInteract(BedwarsItem $item): void { if(!$this->session->getPlayer()->isSneaking() or !$item instanceof ClaimingWandItem) { return; } if(!isset($this->first_position) or !isset($this->second_position)) { $this->session->message("{RED}You must set both positions before setting the area."); return; } $this->setArea(new Area($this->first_position, $this->second_position)); $this->session->getMapSetup()->setStep(new PreparingMapStep()); $this->session->message("{GREEN}You have successfully set the area."); } abstract protected function setArea(Area $area): void; }team->setZone($area); } }session = $session; $this->map_builder = $map_builder; $this->setStep(new PreparingMapStep()); } public function getMapBuilder(): MapBuilder { return $this->map_builder; } public function getStep(): Step { return $this->step; } public function setStep(Step $step): void { $this->step = $step; $this->step->start($this->session); } public function createMap(): void { Server::getInstance()->getAsyncPool()->submitTask(new CreateMapTask($this->map_builder)); } }name = $name; $this->waiting_world = $waiting_world; $this->playing_world = $playing_world; $this->players_per_team = $players_per_team; $this->max_capacity = $max_capacity; $this->setDefaultTeams(); } public function getPlayingWorld(): string { return $this->playing_world; } public function setSpectatorSpawnPosition(Vector3 $spectator_spawn_position): void { $this->spectator_spawn_position = $spectator_spawn_position; } public function addShopPosition(Vector3 $position): void { $this->shop_positions[] = $position; } public function addUpgradesPosition(Vector3 $position): void { $this->upgrades_positions[] = $position; } public function addGenerator(Generator $generator): void { $this->generators[] = $generator; } public function removeGenerator(Generator $generator): void { unset($this->generators[array_search($generator, $this->generators, true)]); } private function addTeam(string $name): void { $this->teams[] = new TeamBuilder($name); } private function setDefaultTeams(): void { $teams = ["Red", "Blue", "Yellow", "Green", "Cyan", "Gray", "Orange", "Magenta"]; for($i = 0; $i < $this->getTeamsCount(); $i++) { $this->addTeam($teams[$i]); } } private function getTeamsCount(): int { return (int) ($this->max_capacity / $this->players_per_team); } /** * @return TeamBuilder[] */ public function getTeams(): array { return $this->teams; } public function canBeBuilt(): bool { $can_build = true; foreach($this->teams ?? [] as $team) { if(!$team->canBeBuilt()) { $can_build = false; break; } } $is_set = isset( $this->spectator_spawn_position, $this->generators, $this->teams, $this->shop_positions, $this->upgrades_positions ); return $is_set and $can_build; } public function build(): Map { return new Map( $this->name, $this->spectator_spawn_position, $this->players_per_team, $this->max_capacity, $this->waiting_world, $this->generators, array_map(function(TeamBuilder $team_builder): Team { return $team_builder->build($this); }, $this->teams), $this->shop_positions, $this->upgrades_positions ); } }name = $name; $this->color = ColorUtils::translate("{" . strtoupper($name) . "}"); } public function setSpawnPoint(Vector3 $spawn_point): void { $this->spawn_point = $spawn_point; } public function setBedPosition(Vector3 $bed_position): void { $this->bed_position = $bed_position; } public function setZone(Area $zone): void { $this->zone = $zone; } public function setClaim(Area $claim): void { $this->claim = $claim; } public function setGeneratorPosition(Vector3 $generator_position): void { $this->generator_position = $generator_position; } public function canBeBuilt(): bool { return isset( $this->spawn_point, $this->bed_position, $this->zone, $this->claim, $this->generator_position ); } public function build(MapBuilder $map_builder): Team { return new Team( $this->name, $map_builder->getPlayersPerTeam(), $this->spawn_point, $this->bed_position, $this->zone, $this->claim, [ new IronGenerator($this->generator_position), new GoldGenerator($this->generator_position) ] ); } }setPermission(DefaultPermissions::ROOT_OPERATOR); parent::__construct("bedwars", "Setup your BedWars games!"); } public function execute(CommandSender $sender, string $commandLabel, array $args): void { if(!$sender instanceof Player) { return; } $session = SessionFactory::getSession($sender); if($session->isCreatingMap()) { if($session->getMapSetup()->getStep() instanceof PreparingMapStep) { $sender->sendForm(new SetupMapForm($session)); } } else { $sender->sendForm(new BedwarsForm()); } } public function getOwningPlugin(): Plugin { return BedWars::getInstance(); } } "Solo", 2 => "Duos", 4 => "Squads", default => "Unknown" }; } static public function getGeneratorColor(string $name): string { return match(strtolower($name)) { "emerald" => "{DARK_GREEN}", "diamond" => "{AQUA}", "gold" => "{GOLD}", "iron" => "{WHITE}", default => "" }; } static public function intToRoman(int $number): string { return match($number) { 1 => "I", 2 => "II", 3 => "III", 4 => "IV", 5 => "MAX", default => "" }; } static public function getTrapByName(string $name): Trap { return match($name) { "It's a trap" => new DefaultTrap(), "Counter-Offensive Trap" => new CounterOffensiveTrap(), "Alarm Trap" => new AlarmTrap(), "Miner Fatigue Trap" => new MinerFatigueTrap() }; } static public function getEffectDuration(EffectInstance $effect): int { return match($effect->getType()) { VanillaEffects::SPEED(), VanillaEffects::JUMP_BOOST() => 45, VanillaEffects::INVISIBILITY() => 30, default => 0 } * 20; } static public function getEffectAmplifier(EffectInstance $effect): int { return match($effect->getType()) { VanillaEffects::SPEED() => 1, VanillaEffects::JUMP_BOOST() => 4, default => 0 }; } static public function getCountById(int $id): int { return match($id) { ItemTypeIds::IRON_INGOT => 48, ItemTypeIds::GOLD_INGOT => 16, ItemTypeIds::DIAMOND => 4, ItemTypeIds::EMERALD => 2, default => 64 }; } static public function getColoredTitleNumber(int $number): string { return match(true) { $number <= 3 => "{RED}", $number <= 5 => "{YELLOW}", default => "{GREEN}" } . $number; } static public function getColoredMessageNumber(int $number): string { return match(true) { $number <= 5 => "{RED}", $number <= 10 => "{GOLD}", $number <= 20 => "{AQUA}", default => "{GREEN}" } . $number; } }getConfig()->get($key, $default); } static public function getVersion(): int|float { return self::get("version", 1.0); } static public function getIP(): string { return self::get("ip", "play.server.net"); } static public function isSpawnProtectionEnabled(): bool { return self::get("spawn-protection", true); } static public function getProvider(): string { return self::get("provider", "sqlite"); } static public function getMysqlCredentials(): array { return self::get("mysql-credentials", []); } }getZ() - $entity_position->getZ(), $player_position->getX() - $entity_position->getX() )); } static public function calculatePitch(Position $player_position, Position $entity_position): float { $player_vector = new Vector2($player_position->getX(), $player_position->getZ()); $entity_vector = new Vector2($entity_position->getX(), $entity_position->getZ()); return self::toDegrees(atan2( $player_vector->distance($entity_vector), $player_position->getY() - $entity_position->getY() )); } static private function toDegrees(float $radians): float { return $radians * 180 / M_PI - 90; } } DyeColor::BLACK, TextFormat::DARK_BLUE => DyeColor::BLUE, TextFormat::DARK_GREEN => DyeColor::GREEN, TextFormat::DARK_PURPLE => DyeColor::MAGENTA, TextFormat::GOLD => DyeColor::ORANGE, TextFormat::GRAY => DyeColor::LIGHT_GRAY, TextFormat::DARK_GRAY => DyeColor::GRAY, TextFormat::BLUE => DyeColor::CYAN, TextFormat::GREEN => DyeColor::LIME, TextFormat::RED => DyeColor::RED, TextFormat::LIGHT_PURPLE => DyeColor::PINK, TextFormat::YELLOW => DyeColor::YELLOW, TextFormat::WHITE => DyeColor::WHITE, }; } }sqlite = new SQLite3(BedWars::getInstance()->getDataFolder() . "database.db"); $this->sqlite->exec( "CREATE TABLE IF NOT EXISTS bedwars_users ( xuid VARCHAR(16) PRIMARY KEY, coins INT, kills INT, wins INT, flying_speed INT, auto_teleport BOOL, night_vision BOOL );" ); } public function loadSession(Session $session): void { $xuid = $session->getPlayer()->getXuid(); $this->insertIfNotExists($xuid); $data = $this->fetchUserDetails($xuid); $session->setCoins($data["coins"]); $session->setKills($data["kills"]); $session->setWins($data["wins"]); $session->setSpectatorSettings(SpectatorSettings::fromData($session, $data)); } public function updateCoins(Session $session): void { $this->updateProperty($session, "coins"); } public function updateKills(Session $session): void { $this->updateProperty($session, "kills"); } public function updateWins(Session $session): void { $this->updateProperty($session, "wins"); } private function insertIfNotExists(string $xuid): void { $stmt = $this->sqlite->prepare("INSERT OR IGNORE INTO bedwars_users (xuid, coins, kills, wins, flying_speed, auto_teleport, night_vision) VALUES (:xuid, 0, 0, 0, 0, true, true)"); $stmt->bindParam(":xuid", $xuid); $stmt->execute(); } private function fetchUserDetails(string $xuid): array { $stmt = $this->sqlite->prepare("SELECT * FROM bedwars_users WHERE xuid = :xuid"); $stmt->bindParam(":xuid", $xuid); $result = $stmt->execute(); return $result->fetchArray(SQLITE3_ASSOC); } private function updateProperty(Session $session, string $property): void { $stmt = $this->sqlite->prepare("UPDATE bedwars_users SET $property = :value WHERE xuid = :xuid"); $stmt->bindValue(":value", $session->{'get' . ucfirst($property)}()); $stmt->bindValue(":xuid", $session->getPlayer()->getXuid()); $stmt->execute(); } public function saveSession(Session $session): void {} }credentials = $credentials ?? BedWars::getInstance()->getProvider()->getCredentials(); } public function onRun(): void { $mysqli = $this->credentials->getMysqli(); $this->onConnection($mysqli); $mysqli->close(); } abstract protected function onConnection(mysqli $mysqli): void; }hostname = $hostname; $this->username = $username; $this->password = $password; $this->database = $database; $this->port = $port; } static public function fromData(array $data): MysqlCredentials { return new MysqlCredentials($data["hostname"], $data["username"], $data["password"], $data["database"], $data["port"]); } public function getMysqli(): mysqli { return new mysqli($this->hostname, $this->username, $this->password, $this->database, $this->port); } }xuid = $session->getPlayer()->getXuid(); $this->kills = $session->getKills(); parent::__construct(); } protected function onConnection(mysqli $mysqli): void { $stmt = $mysqli->prepare("UPDATE bedwars_users SET kills = ? WHERE xuid = ?"); $stmt->bind_param("is", ...[$this->kills, $this->xuid]); $stmt->execute(); $stmt->close(); } }xuid = $session->getPlayer()->getXuid(); $this->username = $session->getUsername(); parent::__construct(); } protected function onConnection(mysqli $mysqli): void { $this->insertIfNotExists($mysqli); $this->fetchUserDetails($mysqli); } private function insertIfNotExists(mysqli $mysqli): void { $stmt = $mysqli->prepare("INSERT IGNORE INTO bedwars_users (xuid, coins, kills, wins, flying_speed, auto_teleport, night_vision) VALUES (?, 0, 0, 0, 0, true, true)"); $stmt->bind_param("s", ...[$this->xuid]); $stmt->execute(); $stmt->close(); } private function fetchUserDetails(mysqli $mysqli): void { $stmt = $mysqli->prepare("SELECT * FROM bedwars_users WHERE xuid = ?"); $stmt->bind_param("s", ...[$this->xuid]); $stmt->execute(); $result = $stmt->get_result(); $rows = $result->fetch_all(MYSQLI_ASSOC); $this->setResult($rows); $stmt->free_result(); $stmt->close(); } public function onCompletion(): void { $session = SessionFactory::getSessionByName($this->username); if($session === null) { return; } $rows = $this->getResult(); $data = $rows[0]; $session->setKills((int) $data["kills"]); $session->setWins((int) $data["wins"]); $session->setCoins((int) $data["coins"]); $session->setSpectatorSettings(SpectatorSettings::fromData($session, $data)); } }xuid = $session->getPlayer()->getXuid(); $this->wins = $session->getWins(); parent::__construct(); } protected function onConnection(mysqli $mysqli): void { $stmt = $mysqli->prepare("UPDATE bedwars_users SET wins = ? WHERE xuid = ?"); $stmt->bind_param("is", ...[$this->wins, $this->xuid]); $stmt->execute(); $stmt->close(); } }query( "CREATE TABLE IF NOT EXISTS bedwars_users ( xuid VARCHAR(16) PRIMARY KEY, coins INT, kills INT, wins INT, flying_speed INT, auto_teleport BOOL, night_vision BOOL )" ); } }xuid = $session->getPlayer()->getXuid(); $this->coins = $session->getCoins(); parent::__construct(); } protected function onConnection(mysqli $mysqli): void { $stmt = $mysqli->prepare("UPDATE bedwars_users SET coins = ? WHERE xuid = ?"); $stmt->bind_param("is", ...[$this->coins, $this->xuid]); $stmt->execute(); $stmt->close(); } }credentials = MysqlCredentials::fromData(ConfigGetter::getMysqlCredentials()); $this->scheduleAsyncTask(new CreateTablesTask($this->credentials)); } public function getCredentials(): MysqlCredentials { return $this->credentials; } public function loadSession(Session $session): void { $this->scheduleAsyncTask(new LoadSessionTask($session)); } public function updateCoins(Session $session): void { $this->scheduleAsyncTask(new UpdateCoinsTask($session)); } public function updateKills(Session $session): void { $this->scheduleAsyncTask(new UpdateKillsTask($session)); } public function updateWins(Session $session): void { $this->scheduleAsyncTask(new UpdateWinsTask($session)); } public function saveSession(Session $session): void {} private function scheduleAsyncTask(MysqlAsyncTask $task): void { Server::getInstance()->getAsyncPool()->submitTask($task); } }getUsersDir(); if(!is_dir($users_dir)) { mkdir($users_dir); } } public function loadSession(Session $session): void { $config = $this->getSessionConfig($session); $session->setCoins($config->get("coins")); $session->setKills($config->get("kills")); $session->setWins($config->get("wins")); $session->setSpectatorSettings(SpectatorSettings::fromData($session, $config->get("spectator_settings"))); } public function saveSession(Session $session): void { $config = $this->getSessionConfig($session); $config->set("coins", $session->getCoins()); $config->set("kills", $session->getKills()); $config->set("wins", $session->getWins()); $config->set("spectator_settings", [ "flying_speed" => $session->getSpectatorSettings()->getFlyingSpeed(), "auto_teleport" => $session->getSpectatorSettings()->getAutoTeleport(), "night_vision" => $session->getSpectatorSettings()->getNightVision() ]); $config->save(); } public function updateCoins(Session $session): void {} public function updateKills(Session $session): void {} public function updateWins(Session $session): void {} private function getSessionConfig(Session $session): Config { return new Config($this->getUsersDir() . $session->getPlayer()->getXuid() . ".json", Config::JSON, [ "coins" => 0, "kills" => 0, "wins" => 0, "spectator_settings" => [ "flying_speed" => 0, "auto_teleport" => true, "night_vision" => true ] ]); } private function getUsersDir(): string { return BedWars::getInstance()->getDataFolder() . "users/"; } }session = $session; $this->category = $category; parent::__construct($category->getName(), $this->getTrapsHeaderText()); } protected function onCreation(): void { if(!$this->session->isPlaying() or !$this->session->hasTeam()) { // This should never happen, but just in case return; } foreach($this->category->getProducts($this->session) as $product) { $button = new Button($product->getDisplayName($this->session) . "\n" . $product->getDescription($this->session)); $button->setSubmitListener(function(Player $player) use ($product) { $session = SessionFactory::getSession($player); if($session !== null and $session->isPlaying()) { $this->purchaseProduct($product); } }); $this->addButton($button); } } private function purchaseProduct(Product $product): void { if($this->canPurchaseProduct($product) and $product->onPurchase($this->session)) { $player = $this->session->getPlayer(); $player->getInventory()->removeItem($product->getOre()); $player->sendForm(new CategoryForm($this->session, $this->category)); $this->session->message("{GREEN}You purchased {GOLD}" . $product->getName()); } } private function canPurchaseProduct(Product $product): bool { if(!$product->canBePurchased($this->session)) { $this->session->message("{RED}You already have this product!"); return false; } $ore = $product->getOre(); $inventory = $this->session->getPlayer()->getInventory(); if(!$inventory->contains($ore)) { $count = 0; foreach($inventory->all($ore) as $item) { $count += $item->getCount(); } $count = $ore->getCount() - $count; $this->session->message(TextFormat::RED . "You don't have enough " . $ore->getName() . "! Need $count more!"); return false; } return true; } private function getTrapsHeaderText(): string { if(!$this->category instanceof TrapsCategory or !$this->session->hasTeam()) { return ""; } $traps = $this->session->getTeam()->getUpgrades()->getTraps(); $header_text = ""; for($i = 1; $i <= 3; $i++) { $trap = array_shift($traps); $header_text .= "Trap #" . $i . " - " . ($trap !== null ? $trap->getName() : "Empty") . "\n"; } return $header_text; } }session = $session; $this->shop = $shop; parent::__construct($name); } protected function onCreation(): void { foreach($this->shop->getCategories() as $category) { $this->addRedirectFormButton( ColorUtils::translate("{GOLD}{BOLD}" . $category->getName() . "{RESET}\n{YELLOW}Click to view!"), new CategoryForm($this->session, $category) ); } } }players_per_team = $players_per_team; parent::__construct("Select a map!"); } protected function onCreation(): void { foreach(MapFactory::getMapsByPlayers($this->players_per_team) as $map) { $this->addButton(new PlayGameButton($map->getName(), BedWars::getInstance()->getGameManager()->findGame($map))); } } }sendMessage(TextFormat::RED . "There are no games for this map! Try again in a few seconds"); return; } $session = SessionFactory::getSession($player); if($session->isSpectator()) { $session->getGame()->removeSpectator($session); } elseif($session->isPlaying()) { return; } $game->addPlayer($session); }); } }players_per_team = $players_per_team; parent::__construct("Play bedwars " . GameUtils::getMode($players_per_team)); } protected function onCreation(): void { $this->addButton(new PlayGameButton("Random map", BedWars::getInstance()->getGameManager()->findRandomGame($this->players_per_team))); $this->addSelectMapButton(); } private function addSelectMapButton(): void { $button = new Button("Select a map"); $button->setSubmitListener(function(Player $player) { $player->sendForm(new SelectMapForm($this->players_per_team)); }); $this->addButton($button); } }addOption(new Option((string) $players_per_team, GameUtils::getMode($players_per_team))); } $this->addElement("players_per_team", $dropdown); } }setSubmitListener(function(Player $player) use ($form) { $player->sendForm($form); }); $this->addButton($button); } protected function vectorToString(Vector3 $vector): string { // this function shouldn't be there return "X: " . $vector->getFloorX() . ", Y: " . $vector->getFloorY() . ", Z: " . $vector->getFloorZ(); } }session = $session; parent::__construct("Teleporter"); } protected function onCreation(): void { foreach($this->session->getGame()->getPlayers() as $target) { if(!$target->isRespawning()) { $this->addTeleportButton($target); } } } private function addTeleportButton(Session $target): void { $button = new Button($target->getUsername()); $button->setSubmitListener(function(Player $player) use ($target) { $session = SessionFactory::getSession($player); if(!$session->isSpectator()) { $session->message("{RED}You can't do this!"); return; } if(!$target->isPlaying()) { $session->message("{RED}The player you want to teleport is no longer playing!"); return; } if($target->isRespawning()) { $session->message("{RED}The player you want to teleport is dead!"); return; } $session->setTrackingSession(SessionFactory::getSession($player = $target->getPlayer())); $session->getPlayer()->teleport($player->getPosition()); $session->message("{GREEN}You teleported to " . $target->getUsername() . " successfully!"); }); $this->addButton($button); } }session = $session; parent::__construct("Spectator settings"); } protected function onCreation(): void { $settings = $this->session->getSpectatorSettings(); $this->addElement("label", new Label("Change the spectator settings in this window.")); $this->addElement("flying_speed", new Slider("Set your flying speed", 0, 4, $settings->getFlyingSpeed(), 1)); $this->addElement("auto_teleport", new Toggle("Auto Teleport", $settings->getAutoTeleport())); $this->addElement("night_vision", new Toggle("Night Vision", $settings->getNightVision())); } protected function onSubmit(Player $player, FormResponse $response): void { $flying_speed = (int) $response->getSliderSubmittedStep("flying_speed"); $auto_teleport = $response->getToggleSubmittedChoice("auto_teleport"); $night_vision = $response->getToggleSubmittedChoice("night_vision"); $settings = $this->session->getSpectatorSettings(); if($settings->getFlyingSpeed() !== $flying_speed) { $settings->setFlyingSpeed($flying_speed); } if($settings->getAutoTeleport() !== $auto_teleport) { $settings->setAutoTeleport($auto_teleport); } if($settings->getNightVision() !== $night_vision) { $settings->setNightVision($night_vision); } if($this->session->isSpectator()) { $settings->apply(); } } }session = $session; parent::__construct("Setup teams", "Select the team you want to setup"); } protected function onCreation(): void { foreach($this->session->getMapSetup()->getMapBuilder()->getTeams() as $team) { $description = !$team->canBeBuilt() ? "\n[PENDING]" : ""; $this->addRedirectFormButton($team->getName() . $description, new TeamOptionsForm($this->session, $team)); } } }generator = $generator; parent::__construct( "Remove " . $generator->getName() . " Generator", "Are you sure you want to delete this generator?", new ModalOption("Yes!"), new ModalOption("No!") ); } protected function onAccept(Player $player): void { $session = SessionFactory::getSession($player); if($session->isCreatingMap()) { $session->getMapSetup()->getMapBuilder()->removeGenerator($this->generator); $session->playSound("random.orb"); $session->message("{GREEN}You have removed the generator successfully!"); } } protected function onDeny(Player $player): void { $session = SessionFactory::getSession($player); if($session->isCreatingMap()) { $player->sendForm(new RemoveGeneratorsForm($session)); } } }session = $session; parent::__construct("Setup generators"); } protected function onCreation(): void { $this->addRedirectFormButton("Add generator", new AddGeneratorForm($this->session)); $this->addRedirectFormButton("Remove generator", new RemoveGeneratorsForm($this->session)); } }addRedirectFormButton($map->getName(), new MapOptionsForm($map)); } } }addRedirectFormButton("Create a map", new CreateMapForm()); $this->addRedirectFormButton("Manage maps", new ManageMapsForm()); $this->addRedirectFormButton("Spawn join game entity", new SpawnEntityForm()); } }session = $session; parent::__construct("Remove generators"); } protected function onCreation(): void { if(!$this->session->isCreatingMap()) { return; } foreach($this->session->getMapSetup()->getMapBuilder()->getGenerators() as $generator) { $this->addRedirectFormButton( $generator->getName() . " Generator" . ($this->isNearestGenerator($generator) ? "\nNearest Generator" : ""), new RemoveGeneratorForm($generator) ); } } private function isNearestGenerator(Generator $target): bool { $found = null; $lowest = PHP_INT_MAX; foreach($this->session->getMapSetup()->getMapBuilder()->getGenerators() as $generator) { $distance = $generator->getPosition()->distance($this->session->getPlayer()->getPosition()); if($distance < $lowest) { $lowest = $distance; $found = $generator; } } return $found === $target; } }session = $session; parent::__construct("Setup map", "What do you want to do?"); } protected function onCreation(): void { $this->addSetSpectatorSpawnButton(); $this->addShopAndUpgradesButton(); $this->addRedirectFormButton("Setup generators", new SetupGeneratorsForm($this->session)); $this->addRedirectFormButton("Setup teams", new SetupTeamsForm($this->session)); } private function addSetSpectatorSpawnButton(): void { $button = new Button("Set spectator spawn point"); $button->setSubmitListener(function(Player $player) { if($this->session->isCreatingMap()) { $position = $player->getPosition()->asVector3(); $this->session->getMapSetup()->getMapBuilder()->setSpectatorSpawnPosition($position); $this->session->message("{GREEN}Spectator spawn point set on: " . $this->vectorToString($position)); } }); $this->addButton($button); } private function addShopAndUpgradesButton(): void { $button = new Button("Set Shop & Upgrades"); $button->setSubmitListener(function(Player $player) { $this->session->getMapSetup()->setStep(new SetShopAndUpgradesStep()); }); $this->addButton($button); } }session = $session; parent::__construct("Add generator"); } protected function onCreation(): void { $dropdown = new Dropdown("Select the generator:"); $dropdown->addOption(new Option(GeneratorType::DIAMOND->name, "Diamond Generator")); $dropdown->addOption(new Option(GeneratorType::EMERALD->name, "Emerald Generator")); $this->addElement("id", $dropdown); } protected function onSubmit(Player $player, FormResponse $response): void { $this->session->getMapSetup()->setStep(new AddGeneratorStep( GeneratorType::fromString($response->getDropdownSubmittedOptionId("id")) )); } }map = $map; parent::__construct( "Remove " . $map->getName() . " map", "Are you sure you want to delete this map?", new ModalOption("Yes"), new ModalOption("No") ); } protected function onAccept(Player $player): void { Server::getInstance()->getAsyncPool()->submitTask(new DeleteMapTask($this->map)); $player->sendMessage(TextFormat::GREEN . "You've deleted the map " . $this->map->getName() . " successfully!"); } }session = $session; $this->team = $team; parent::__construct("What do you want to do?"); } protected function onCreation(): void { $this->addSetSpawnPointButton(); $this->addStepButton("Set generator", new SetTeamGeneratorStep($this->team)); $this->addStepButton("Set bed", new SetBedPositionStep($this->team)); $this->addStepButton("Set zone", new SetZoneStep($this->team)); $this->addStepButton("Set claim", new SetClaimStep($this->team)); } private function addSetSpawnPointButton(): void { $button = new Button("Set spawn point\nThis will set the spawn point in your location"); $button->setSubmitListener(function(Player $player) { $position = $player->getPosition(); $this->team->setSpawnPoint($position); $this->session->message("{GREEN}Spawn point set on: " . $this->vectorToString($player->getPosition())); }); $this->addButton($button); } private function addStepButton(string $name, Step $step): void { $button = new Button($name); $button->setSubmitListener(function(Player $player) use ($step) { $this->session->getMapSetup()->setStep($step); }); $this->addButton($button); } }map = $map; parent::__construct("Manage " . $map->getName() . " map", "What do you want to do?"); } protected function onCreation(): void { $this->addRedirectFormButton("Delete", new RemoveMapForm($this->map)); } }addSelectModeDropdown(); } protected function onSubmit(Player $player, FormResponse $response): void { $players_per_team = (int) $response->getDropdownSubmittedOptionId("players_per_team"); $entity = new PlayBedwarsEntity($player->getLocation(), $player->getSkin(), CompoundTag::create()->setInt("players_per_team", $players_per_team)); $entity->spawnToAll(); $player->sendMessage(TextFormat::GREEN . "You have spawned the entity successfully!"); } }addElement("name", new Input("Set a name:")); $this->addElement("teams", new Slider("Set the teams", 2, 8, 8, 1)); $this->addWorldsDropdown("waiting_world", "Set the waiting world:"); $this->addWorldsDropdown("playing_world", "Set the playing world:"); $this->addSelectModeDropdown(); } protected function onSubmit(Player $player, FormResponse $response): void { $name = $response->getInputSubmittedText("name"); $waiting_world = $response->getDropdownSubmittedOptionId("waiting_world"); $playing_world = $response->getDropdownSubmittedOptionId("playing_world"); $teams = $response->getSliderSubmittedStep("teams"); $players_per_team = (int) $response->getDropdownSubmittedOptionId("players_per_team"); if($name === "") { $player->sendMessage(TextFormat::RED . "You must set a name!"); return; } elseif(MapFactory::getMapByName($name) !== null) { $player->sendMessage(TextFormat::RED . "A map with that name already exists!"); return; } elseif($this->checkIfDefaultWorld($waiting_world) or $this->checkIfDefaultWorld($playing_world)) { $player->sendMessage(TextFormat::RED ."You world must not be the default world!"); return; } elseif($waiting_world === $playing_world) { $player->sendMessage(TextFormat::RED . "Your waiting world cannot be the same as the playing world!"); return; } $world_manager = Server::getInstance()->getWorldManager(); if(!$world_manager->loadWorld($playing_world)) { $player->sendMessage(TextFormat::RED . "Couldn't teleport to playing world ($playing_world) because the world has been unloaded."); return; } elseif(!$world_manager->loadWorld($waiting_world)) { $player->sendMessage(TextFormat::RED . "Couldn't load waiting world ($waiting_world)"); return; } $player->setGamemode(GameMode::CREATIVE()); $player->teleport($world_manager->getWorldByName($playing_world)->getSafeSpawn()); $session = SessionFactory::getSession($player); $session->setMapSetup(new MapSetup($session, new MapBuilder( $name, $world_manager->getWorldByName($waiting_world), $playing_world, $players_per_team, (int) ($teams * $players_per_team) ))); } private function addWorldsDropdown(string $id, string $name): void { $dropdown = new Dropdown($name); foreach(glob($this->getWorldsPath(), GLOB_ONLYDIR) as $world) { $dropdown->addOption(new Option($name = basename($world), $name)); } $this->addElement($id, $dropdown); } private function checkIfDefaultWorld(string $world): bool { return Server::getInstance()->getWorldManager()->getDefaultWorld()->getFolderName() === $world; } private function getWorldsPath(): string { return Path::join(Server::getInstance()->getDataPath(), "worlds", "*"); } }getDataFolder() . "worlds/"; if(!is_dir($worlds_dir)) { mkdir($worlds_dir); } $this->saveResource("maps.json"); } protected function onEnable(): void { MapFactory::init(); $this->provider = $this->obtainProvider(); $this->metrics = new Metrics($this, 29605); $this->game_manager = new GameManager(); $this->registerEntity(PlayBedwarsEntity::class); $this->registerEntity(ItemShopVillager::class); $this->registerEntity(UpgradesShopVillager::class); $this->registerFireball(); $this->registerListener(new GameListener()); $this->registerListener(new ItemListener()); $this->registerListener(new SessionListener()); $this->registerListener(new SetupListener()); $this->registerListener(new WaitingListener()); if(ConfigGetter::isSpawnProtectionEnabled()) { $this->registerListener(new SpawnProtectionListener()); } $this->getServer()->getCommandMap()->register("bedwars", new BedWarsCommand()); $this->getScheduler()->scheduleRepeatingTask(new GameHeartbeat(), 1); } protected function onDisable(): void { foreach(SessionFactory::getSessions() as $session) { $session->save(); } foreach($this->game_manager->getGames() as $game) { $game->unloadWorld(); $this->getServer()->getAsyncPool()->submitTask(new RemoveGameTask($game)); } } private function registerListener(Listener $listener): void { $this->getServer()->getPluginManager()->registerEvents($listener, $this); } private function registerEntity(string $class): void { EntityFactory::getInstance()->register($class, function(World $world, CompoundTag $nbt) use ($class): Entity { return new $class(EntityDataHelper::parseLocation($nbt, $world), Human::parseSkinNBT($nbt), $nbt); }, ["bedwars:" . basename($class)]); } private function registerFireball(): void { EntityFactory::getInstance()->register(Fireball::class, function(World $world, CompoundTag $nbt): Fireball { return new Fireball(EntityDataHelper::parseLocation($nbt, $world), null); }, ["bedwars:fireball"]); } private function obtainProvider(): Provider { return match(strtolower(ConfigGetter::getProvider())) { "mysql" => new MysqlProvider(), "sqlite", "sqlite3" => new SqliteProvider(), "json" => new JsonProvider(), default => throw new \Error("Invalid provider, check your config and try again.") }; } public function getProvider(): Provider { return $this->provider; } public function getMetrics(): Metrics { return $this->metrics; } public function getGameManager(): GameManager { return $this->game_manager; } }players_per_team = $nbt->getInt("players_per_team"); parent::__construct($location, $skin); } protected function initEntity(CompoundTag $nbt): void { parent::initEntity($nbt); $this->updateNameTag(); $this->setNameTagAlwaysVisible(); } public function updateNameTag(): void { $amount = $this->getSessionsCount(); $this->setNameTag(ColorUtils::translate( "{YELLOW}{BOLD}CLICK TO PLAY{RESET}\n" . "{AQUA}" . GameUtils::getMode($this->players_per_team) . " {GRAY}[v" . ConfigGetter::getVersion() . "]\n" . "{YELLOW}{BOLD}" . $amount . " " . ($amount === 1 ? "Player" : "Players") )); } public function attack(EntityDamageEvent $source): void { if($source instanceof EntityDamageByChildEntityEvent or !$source instanceof EntityDamageByEntityEvent) { return; } $damager = $source->getDamager(); if(!$damager instanceof Player) { return; } if($damager->hasPermission(DefaultPermissions::ROOT_OPERATOR) and $damager->getInventory()->getItemInHand()->getTypeId() === BlockTypeIds::BEDROCK) { $this->kill(); return; } $damager->sendForm(new PlayBedwarsForm($this->players_per_team)); } public function onInteract(Player $player, Vector3 $clickPos): bool { $player->sendForm(new PlayBedwarsForm($this->players_per_team)); return true; } public function saveNBT(): CompoundTag { return parent::saveNBT()->setInt("players_per_team", $this->players_per_team); } public function getPlayersPerTeam(): int { return $this->players_per_team; } private function getSessionsCount(): int { return count(array_filter(SessionFactory::getSessions(), function(Session $session) { return $session->isPlaying() and $session->getGame()->getMap()->getPlayersPerTeam() === $this->players_per_team; })); } }name = ColorUtils::translate($name); $this->disable_transactions = $disable_transactions; } public function asItem(): Item { $item = $this->realItem(); $item->setCustomName($this->name); $nbt = $item->getNamedTag(); $nbt->setString("bedwars_name", str_replace(" ", "_", TextFormat::clean($this->name))); if($this->disable_transactions) { $nbt->setByte("bedwars_item", 1); } return $item; } abstract public function onInteract(Session $session): void; abstract protected function realItem(): Item; }getPlayer()->sendForm(new TeleporterForm($session)); } protected function realItem(): Item { return VanillaItems::COMPASS(); } }isSpectator()) { $this->onSpectatorInteract($session); } } abstract protected function onSpectatorInteract(Session $session): void; }getPlayer()->sendForm(new SpectatorSettingsForm($session)); } protected function realItem(): Item { return VanillaBlocks::REDSTONE_COMPARATOR()->asItem(); } }getGame()->getMap()->getPlayersPerTeam()); $form->setTitle("Play again?"); $session->getPlayer()->sendForm($form); } protected function realItem(): Item { return VanillaItems::PAPER(); } }getGame()->removeSpectator($session); } protected function realItem(): Item { return VanillaBlocks::BED()->setColor(DyeColor::RED())->asItem(); } }asItem(); } }setMapSetup(null); $session->teleportToHub(); } protected function realItem(): Item { return VanillaBlocks::BED()->setColor(DyeColor::RED)->asItem(); } }color = $color; return $this; } public function onInteract(Session $session): void {} protected function realItem(): Item { $block = VanillaBlocks::BED(); if($this->color !== null) { $block->setColor($this->color); } return $block->asItem(); } }getNamedTag()->setByte("setup", 1); return $item; } }isCreatingMap()) { $session->getMapSetup()->setStep(new PreparingMapStep()); } } protected function realItem(): Item { return VanillaBlocks::BED()->setColor(DyeColor::RED)->asItem(); } }getMapSetup(); if($setup->getMapBuilder()->canBeBuilt()) { $session->teleportToHub(); $session->message("{GREEN}Map created successfully."); $setup->createMap(); } else { $session->message("{RED}You must set all the map properties before creating it."); } } protected function realItem(): Item { return VanillaItems::EMERALD(); } }getPlayer()->sendForm(new SetupMapForm($session)); } protected function realItem(): Item { return VanillaItems::PAPER(); } }type = $type; parent::__construct(GameUtils::getGeneratorColor($name = $type->toString()) . $name . " generator"); } protected function realItem(): Item { return StringToItemParser::getInstance()->parse(strtolower($this->type->toString()) . "_block"); } public function onInteract(Session $session): void {} }name = $name; parent::__construct($name . " villager"); } public function getName(): string { return $this->name; } public function onInteract(Session $session): void {} protected function realItem(): Item { return VanillaItems::VILLAGER_SPAWN_EGG(); } }setCustomName(TextFormat::RED . "Fireball"); } protected function createEntity(Location $location, Player $thrower): Throwable { return new FireballEntity($location, $thrower); } public function getThrowForce(): float { return 1.5; } }getPlayer()->sendForm(new ShopForm($session, "Tracker & Communication", ShopFactory::getShop(Shop::TRACKER), false)); } protected function realItem(): Item { return VanillaItems::COMPASS(); } }isPlaying()) { $session->getGame()->removePlayer($session); } } protected function realItem(): Item { return VanillaBlocks::BED()->setColor(DyeColor::RED())->asItem(); } }checkPlayerEvent($event); } public function onBlockBreak(BlockBreakEvent $event): void { $this->checkPlayerEvent($event); } public function onInteract(PlayerInteractEvent $event): void { $this->checkPlayerEvent($event); } public function onDrop(PlayerDropItemEvent $event): void { $this->checkPlayerEvent($event); } public function onDamage(EntityDamageEvent $event): void { $entity = $event->getEntity(); if($entity instanceof Player) { $this->checkWorldProtection($entity, $event); } } private function checkPlayerEvent(Cancellable $cancellable): void { $this->checkWorldProtection($cancellable->getPlayer(), $cancellable); } private function checkWorldProtection(Player $player, Cancellable $cancellable): void { if($player->getGamemode() !== GameMode::CREATIVE and $player->getWorld() === Server::getInstance()->getWorldManager()->getDefaultWorld()) { $cancellable->cancel(); } } }getPlayer()); } public function onJoin(PlayerJoinEvent $event): void { SessionFactory::getSession($event->getPlayer())->teleportToHub(); } /** * @priority HIGHEST */ public function onQuit(PlayerQuitEvent $event): void { SessionFactory::removeSession($event->getPlayer()); } }checkWorld($event->getPlayer())) { $event->cancel(); } } public function onPlace(BlockPlaceEvent $event): void { if($this->checkWorld($event->getPlayer())) { $event->cancel(); } } public function onInteract(PlayerInteractEvent $event): void { if($this->checkWorld($event->getPlayer())) { $event->cancel(); } } public function onReceiveDamage(EntityDamageEvent $event): void { $entity = $event->getEntity(); if($entity instanceof Player and $this->checkWorld($entity)) { $event->cancel(); } } private function checkWorld(Player $player): bool { $session = SessionFactory::getSession($player); return $session !== null and $session->isPlaying() and $session->getGame()->getMap()->getWaitingWorld() === $player->getWorld(); } }getPlayer()); if($this->isCreatingMap($session, $item = $event->getItem())) { $event->cancel(); $session->getMapSetup()->getStep()->onBlockBreak($event->getBlock(), $this->getBedwarsItem($item)); } } public function onItemUse(PlayerItemUseEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if($this->isCreatingMap($session, $item = $event->getItem())) { $event->cancel(); $session->getMapSetup()->getStep()->onInteract($this->getBedwarsItem($item)); } } public function onInteract(PlayerInteractEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if($this->isCreatingMap($session, $item = $event->getItem())) { $event->cancel(); $session->getMapSetup()->getStep()->onBlockInteract($event->getBlock()->getPosition(), $event->getAction(), $event, $this->getBedwarsItem($item)); } } private function getBedwarsItem(Item $item): BedwarsItem { return BedwarsItems::get($item->getNamedTag()->getString("bedwars_name")); } private function isCreatingMap(Session $session, Item $item): bool { return $session->isCreatingMap() and $item->getNamedTag()->getTag("setup") !== null; } }getTransaction()->getActions() as $action) { if($action->getSourceItem()->getNamedTag()->getTag("bedwars_item") !== null) { $event->cancel(); } } } public function onUse(PlayerItemUseEvent $event): void { $tag = $event->getItem()->getNamedTag()->getTag("bedwars_name"); if($tag === null) { return; } BedwarsItems::get(strtolower($tag->getValue()))->onInteract(SessionFactory::getSession($event->getPlayer())); // TODO: Clean } }getEntity(); if(!$entity instanceof Player) { return; } $session = SessionFactory::getSession($entity); if(!$session->isPlaying()) { return; } $effects = $entity->getEffects(); if($effects->has($effect = VanillaEffects::INVISIBILITY())) { $effects->remove($effect); $session->message("{RED}You took damage and lost your invisibility!"); } if($event->getCause() === EntityDamageEvent::CAUSE_ENTITY_EXPLOSION) { $event->setBaseDamage(0); } if($event->getFinalDamage() >= $entity->getHealth()) { $session->kill($event->getCause()); $event->cancel(); } } public function onEntityDamageByEntity(EntityDamageByEntityEvent $event): void { $damager = $event->getDamager(); $entity = $event->getEntity(); if(!$damager instanceof Player or !$entity instanceof Player or !SessionFactory::hasSession($damager) or !SessionFactory::hasSession($entity)) { return; } $damager_session = SessionFactory::getSession($damager); $entity_session = SessionFactory::getSession($entity); $entity_session->setLastSessionHit($damager_session); if($damager_session->isPlaying() and $entity_session->isPlaying() and $damager_session->hasTeam() and $entity_session->hasTeam() and $damager_session->getTeam()->hasMember($entity_session)) { $event->cancel(); } } public function onInteract(PlayerInteractEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if(!$session->isPlaying()) { return; } $block = $event->getBlock(); if(!$block instanceof Chest) { return; } $team = $this->getTeamByPosition($session->getGame(), $block->getPosition()); if($team !== null and $team->isAlive() and $team->getName() !== $session->getTeam()->getName()) { $session->message("{RED}You can't open this chest!"); $event->cancel(); } } public function onBreak(BlockBreakEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if(!$session->isPlaying()) { return; } $block = $event->getBlock(); $position = $block->getPosition(); $game = $session->getGame(); if($game->checkBlock($position)) { return; } elseif(!$block instanceof Bed) { $session->message("{RED}You can only break blocks placed by a player!"); $event->cancel(); return; } $other_half = $block->getOtherHalf(); if($other_half === null) { return; } $team = $this->getTeamByPosition($game, $position); if($team === null) { return; } $bed_position = $team->getBedPosition(); $half_position = $other_half->getPosition(); if($team->isBedDestroyed() or $half_position === null or (!$bed_position->equals($half_position) and !$bed_position->equals($position))) { return; } if($session->getTeam()->getName() !== $team->getName()) { $team->destroyBed($game, false); $game->broadcastMessage("{BOLD}{WHITE}BED DESTRUCTION > {RESET}" . $team->getColoredName() . " Bed {GRAY}was destroyed by " . $session->getColoredUsername() . "{GRAY}!"); $event->setDrops([]); } else { $session->message("{RED}You can't destroy your own bed!"); $event->cancel(); } } public function onPlace(BlockPlaceEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if(!$session->isPlaying()) { return; } $game = $session->getGame(); $position = $event->getBlockAgainst()->getPosition(); if($this->getTeamByPosition($game, $position)?->getClaim()->isInside($position)) { $session->message("{RED}You can't place blocks here!"); $event->cancel(); return; } foreach($event->getTransaction()->getBlocks() as [$x, $y, $z, $block]) { if($block instanceof TNT) { BedWars::getInstance()->getScheduler()->scheduleDelayedTask(new ClosureTask(function () use ($block) { $world = $block->getPosition()->world; if($world !== null and $world->isLoaded()) { $block->ignite(60); } }), 1); continue; } $session->getGame()->addBlock($block->getPosition()); } } public function onMove(PlayerMoveEvent $event): void { $player = $event->getPlayer(); $session = SessionFactory::getSession($player); if(!$session->isPlaying() or !$session->hasTeam()) { return; } $this->checkEntities($player); if($session->getGameSettings()->isUnderMagicMilkEffect()) { return; } $team = $this->getTeamByPosition($session->getGame(), $player->getPosition()); if($team === null or $team->isBedDestroyed() or $session->getTeam()->getName() === $team->getName()) { return; } $upgrades = $team->getUpgrades(); if($upgrades->canTriggerTrap()) { $upgrades->triggerPrimaryTrap($session, $team); } } public function onChat(PlayerChatEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if(!$session->hasGame()) { return; } $team = $session->getTeam(); if($session->isPlaying() and $team !== null) { $prefix = $team->getColor() . "[" . strtoupper($team->getName()) . "] "; } elseif($session->isSpectator()) { $prefix = TextFormat::DARK_GRAY . "[SPECTATOR] "; } else { $prefix = ""; } $event->setFormatter(new LegacyRawChatFormatter( $prefix . TextFormat::GRAY . "{%0}: {%1}" )); $event->setRecipients(array_map(function(Session $session) { return $session->getPlayer(); }, $session->getGame()->getPlayersAndSpectators())); } public function onEntityTeleport(EntityTeleportEvent $event): void { $entity = $event->getEntity(); if(!$entity instanceof Player) { return; } $session = SessionFactory::getSession($entity); if(!$session->isPlaying()) { return; } $stage = $session->getGame()->getStage(); if($stage instanceof PlayingStage and $stage->hasStarted() and $event->getFrom()->getWorld() !== $event->getTo()->getWorld()) { $session->getGame()->removePlayer($session); } } public function onEffectAdd(EntityEffectAddEvent $event): void { $entity = $event->getEntity(); if(!$entity instanceof Player or !SessionFactory::getSession($entity)?->isPlaying()) { return; } $effect = $event->getEffect(); $duration = GameUtils::getEffectDuration($effect); if($duration !== 0) { $effect->setDuration($duration); $effect->setAmplifier(GameUtils::getEffectAmplifier($effect)); $effect->setVisible(false); } } public function onEntityDamageByChildEntity(EntityDamageByChildEntityEvent $event): void { $damager = $event->getDamager(); $entity = $event->getEntity(); if((!$damager instanceof Player or !SessionFactory::getSession($damager)?->isPlaying()) or (!$entity instanceof Player or !SessionFactory::getSession($entity)?->isPlaying())) { return; } $child = $event->getChild(); if($child instanceof Arrow) { SessionFactory::getSession($damager)->playSound("random.orb"); } } public function onExplode(EntityExplodeEvent $event): void { $game = BedWars::getInstance()->getGameManager()->getGameByWorld($event->getPosition()->getWorld()); if($game === null) { return; } $block_list = []; foreach($event->getBlockList() as $block) { if($block instanceof StainedGlass) { continue; } if(!$game->checkBlock($block->getPosition())) { continue; } $block_list[] = $block; } $event->setBlockList($block_list); } public function onDataPacketSend(DataPacketSendEvent $event): void { foreach($event->getTargets() as $target) { $player = $target->getPlayer(); if($player === null or !SessionFactory::hasSession($player) or !SessionFactory::getSession($player)->isPlaying()) { continue; } foreach($event->getPackets() as $packet) { if(!$packet instanceof MobEquipmentPacket and !$packet instanceof MobArmorEquipmentPacket) { continue; } $target = $player->getWorld()->getEntity($packet->actorRuntimeId); if(!$target instanceof Player or !SessionFactory::getSession($target)->isPlaying() or !$target->getEffects()->has(VanillaEffects::INVISIBILITY())) { continue; } $item = ItemStackWrapper::legacy(TypeConverter::getInstance()->coreItemStackToNet(VanillaItems::AIR())); if($packet instanceof MobEquipmentPacket) { $packet->item = $item; } else { $packet->head = $item; $packet->chest = $item; $packet->legs = $item; $packet->feet = $item; } } } } public function onCraft(CraftItemEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if($session->isPlaying()) { $event->cancel(); } } public function onConsume(PlayerItemConsumeEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); if($session->isPlaying() and $event->getItem() instanceof MilkBucket) { $session->getGameSettings()->setMagicMilk(); } } public function onDrop(PlayerDropItemEvent $event): void { $session = SessionFactory::getSession($player = $event->getPlayer()); if($session->isPlaying() and in_array($event->getItem()->getTypeId(), [ItemTypeIds::IRON_INGOT, ItemTypeIds::GOLD_INGOT, ItemTypeIds::DIAMOND, ItemTypeIds::EMERALD]) and $player->getWorld()->getBlock($player->getPosition()->subtract(0, 2, 0)) instanceof Air) { $event->cancel(); } } public function onEntityEvent(ItemSpawnEvent $event): void { $entity = $event->getEntity(); if($entity->getOwner() === "generator") { $entity->setPickupDelay(0); } } public function onPickup(EntityItemPickupEvent $event): void { $origin = $event->getOrigin(); if(!$origin instanceof ItemEntity or $origin->getOwner() !== "generator") { return; } $event->cancel(); $world = $origin->getWorld(); foreach($world->getNearbyEntities($origin->getBoundingBox()->expandedCopy(1, 0.5, 1), $origin) as $entity) { if(!$entity instanceof Player) { continue; } NetworkBroadcastUtils::broadcastEntityEvent( $origin->getViewers(), fn(EntityEventBroadcaster $broadcaster, array $recipients) => $broadcaster->onPickUpItem($recipients, $entity, $origin) ); foreach($entity->getInventory()->addItem($event->getItem()) as $remains) { $world->dropItem($origin->getLocation(), $remains, new Vector3(0, 0, 0)); } } $origin->flagForDespawn(); } public function onMerge(ItemMergeEvent $event): void { $item = $event->getTarget()->getItem(); if($item->getCount() >= GameUtils::getCountById($item->getTypeId())) { $event->getEntity()->flagForDespawn(); $event->cancel(); } } public function onQuit(PlayerQuitEvent $event): void { $session = SessionFactory::getSession($event->getPlayer()); $game = $session->getGame(); if($session->isPlaying()) { $game->removePlayer($session, false); } elseif($session->isSpectator()) { $game->removeSpectator($session); } } public function onChunkUnload(ChunkUnloadEvent $event): void { $game = BedWars::getInstance()->getGameManager()->getGameByWorld($event->getWorld()); if($game !== null and $game->getStage() instanceof PlayingStage) { $event->cancel(); } } public function onExplosionPrime(EntityPreExplodeEvent $event): void { $event->setRadius(5); } public function onExhaust(PlayerExhaustEvent $event): void { $event->cancel(); } public function onBedEnter(PlayerBedEnterEvent $event): void { $event->cancel(); } /** * @handleCancelled */ public function onItemUse(PlayerItemUseEvent $event): void { if(SessionFactory::getSession($event->getPlayer())->isSpectator()) { $event->uncancel(); } } private function checkEntities(Player $player): void { $network_session = $player->getNetworkSession(); $position = $player->getPosition(); foreach($player->getWorld()->getNearbyEntities($player->getBoundingBox()->expandedCopy(12, 12, 12), $player) as $entity) { if(!$entity instanceof Villager) { continue; } $yaw = MathUtils::calculateYaw($position, $location = $entity->getLocation()); $pitch = MathUtils::calculatePitch($position, $location); $network_session->sendDataPacket(MoveActorAbsolutePacket::create( $entity->getId(), $location, $pitch, $yaw, $yaw, 0 )); } } private function getTeamByPosition(Game $game, Vector3 $position): ?Team { foreach($game->getTeams() as $team) { if($team->getZone()->isInside($position)) { return $team; } } return null; } } position = $position; $this->tier = Tier::I; $this->setSpeed($this->getInitialSpeed()); } public function getName(): string { $name = $this->getType()->toString(); return ColorUtils::translate(GameUtils::getGeneratorColor($name) . $name); } public function getPosition(): Vector3 { return $this->position; } public function getTier(): Tier { return $this->tier; } public function getSpeed(): int { return $this->speed; } public function getTime(): int { return $this->time; } public function setTier(Tier $tier): void { $this->tier = $tier; } public function setSpeed(int $speed): void { $this->speed = $speed; $this->setCountdown(1 / $speed); } public function setCountdown(float $countdown): void { // drops per second $this->countdown = (int) (20 / $countdown); $this->resetTime(); } private function resetTime(): void { $this->time = $this->countdown; } public function tick(Game $game): void { $this->time--; if($this->time <= 0) { $this->resetTime(); $this->dropItem($game->getWorld()); } } private function dropItem(World $world): void { $entity = $world->dropItem($this->position->add(0, 0.1, 0), clone $this->getItem(), Vector3::zero()); if($entity !== null) { $entity->setOwner("generator"); $this->onDropItem($world); } } public function reset(): void { $this->tier = Tier::I; $this->setSpeed($this->getInitialSpeed()); } public function onDropItem(World $world): void {} abstract public function getType(): GeneratorType; abstract public function getInitialSpeed(): int; abstract protected function getItem(): Item; }text = new GeneratorText(); } public function getText(): GeneratorText { return $this->text; } public function setTier(Tier $tier): void { parent::setTier($tier); $this->setSpeed($this->speed - 15); } public function tick(Game $game): void { parent::tick($game); if($this->time % 20 === 0) { $this->updateText($game->getWorld()); } } public function onDropItem(World $world): void { $this->updateText($world); } public function updateText(World $world): void { $this->text->update($this, $world); } public function __clone(): void { $this->text = clone $this->text; } }particles[0] = new FloatingTextParticle(""); $this->particles[1] = new FloatingTextParticle(""); $this->particles[2] = new FloatingTextParticle(""); } public function update(Generator $generator, World $world): void { $this->particles[0]->setText(TextFormat::YELLOW . "Tier " . TextFormat::RED . $generator->getTier()->name); $this->particles[1]->setText($generator->getName()); $this->particles[2]->setText(TextFormat::YELLOW . "Spawns in " . TextFormat::RED . ($time = ((int) ($generator->getTime() / 20))) . TextFormat::YELLOW . ($time === 1 ? " second" : " seconds")); foreach($this->particles as $index => $line) { $world->addParticle($generator->getPosition()->add(0, (3 - $index) / 2 + 1.25, 0), $line); } } public function despawnFrom(Session $session): void { foreach($this->particles as $line) { $line->setInvisible(); foreach($line->encode(Vector3::zero()) as $packet) { $session->sendDataPacket($packet); } $line->setInvisible(false); } } } "I", self::II => "II", self::III => "III" }; } } new IronGenerator($position), self::GOLD => new GoldGenerator($position), self::DIAMOND => new DiamondGenerator($position), self::EMERALD => new EmeraldGenerator($position), self::TEAM_EMERALD => new TeamEmeraldGenerator($position), }; } static public function fromString(string $type): self { return match(strtolower($type)) { "iron" => self::IRON, "gold" => self::GOLD, "diamond" => self::DIAMOND, "emerald" => self::EMERALD, "team_emerald" => self::TEAM_EMERALD, default => throw new \InvalidArgumentException("Invalid generator type: $type"), }; } public function toString(): string { return match($this) { self::IRON => "Iron", self::GOLD => "Gold", self::DIAMOND => "Diamond", self::EMERALD => "Emerald", self::TEAM_EMERALD => "Team Emerald", }; } } current_tick++; foreach(BedWars::getInstance()->getGameManager()->getGames() as $game) { if($game->getStage() instanceof PlayingStage) { $game->tickGenerators(); } if($this->current_tick % 20 === 0) { $game->getStage()->tick(); } } } }getId()] = $shop; } }name = $name; } public function getName(): string { return $this->name; } /** * @return Product[] */ abstract public function getProducts(Session $session): array; }id = $id; $this->name = $name; $this->price = $price; $this->ore = $ore->setCount($price); } public function getName(): string { return $this->name; } public function getPrice(): int { return $this->price; } public function getOre(): Item { return clone $this->ore; } public function getDisplayName(Session $session): string { $color = TextFormat::RED; if($session->getPlayer()->getInventory()->contains($this->ore)) { $color = TextFormat::GREEN; } return $color . $this->name; } public function getDescription(Session $session): string { $name = strtok(strtolower($this->ore->getVanillaName()), " "); $color = GameUtils::getGeneratorColor($name); if($name !== "iron" and $name !== "gold" and $this->price !== 1) { $name .= "s"; } $name = ucfirst($name); return ColorUtils::translate("{GRAY}Cost: " . $color . $this->price . " " . ucfirst($name)); } abstract public function canBePurchased(Session $session): bool; abstract public function onPurchase(Session $session): bool; }getName(), "Track Team " . $name); }, $session->getGame()->getTeams()); } }getGame()->getTeams(); foreach($teams as $team) { if($team->getName() === $this->id) { $tracking_team = $team; } if(!$team->isBedDestroyed()) { $session->message("{RED}Not all enemy beds are destroyed yet!"); return false; } } if($tracking_team === null) { // this should never happen return false; } elseif(!$tracking_team->isAlive()) { $session->message("{RED}You can't track an eliminated team!"); return false; } $members = $tracking_team->getMembers(); $session->setTrackingSession($members[array_rand($members)]); return true; } public function canBePurchased(Session $session): bool { return true; } }hasTeam()) { return false; } $team = $session->getTeam(); if(!$this->canBePurchased($session)) { $session->message("{RED}You already have this upgrade!"); return false; } $this->purchase($team); return true; } abstract protected function purchase(Team $team): void; }getTeam()->getUpgrades(); return !$upgrades->hasTrap($this->name) and $upgrades->getTrapsCount() < 3; } protected function purchase(Team $team): void { $team->getUpgrades()->addTrap(GameUtils::getTrapByName($this->name)); } public function getDescription(Session $session): string { $upgrades = $session->getTeam()->getUpgrades(); if($upgrades->hasTrap($this->name)) { return TextFormat::RED . "You already have this trap!"; } if($upgrades->getTrapsCount() >= 3) { return TextFormat::RED . "You cannot have more than 3 traps!"; } return parent::getDescription($session); } }getUpgrade($session->getTeam())->canLevelUp(); } protected function purchase(Team $team): void { $this->getUpgrade($team)->levelUp($team); } protected function canPurchase(Team $team): bool { $upgrade = $this->getUpgrade($team); if($upgrade->canLevelUp()) { $upgrade->levelUp($team); return true; } return false; } public function getDisplayName(Session $session): string { $upgrade = $this->getUpgrade($session->getTeam()); $level = $upgrade->getLevel(); $levels = $upgrade->getLevels(); $name = parent::getDisplayName($session); if($levels > 1 and $level !== $levels) { $name .= " " . GameUtils::intToRoman($level + 1); } return $name; } public function getDescription(Session $session): string { if(!$this->getUpgrade($session->getTeam())->canLevelUp()) { return TextFormat::RED . "You already have this upgrade!"; } return parent::getDescription($session); } private function getUpgrade(Team $team): Upgrade { return $team->getUpgrades()->getUpgrade($this->name); } }getTeam()->getUpgrades(); return [ new UpgradeProduct("Sharpened Swords", 4), new UpgradeProduct("Armor Protection", 2 ** ($upgrades->getArmorProtection()->getLevel() + 1)), new UpgradeProduct("Maniac Miner", 2 ** ($upgrades->getManiacMiner()->getLevel() + 1)), new UpgradeProduct("Iron Forge", 2 * ($upgrades->getIronForge()->getLevel() + 1)), new UpgradeProduct("Heal Pool", 1) ]; } }getTeam()->getUpgrades(); return [ $this->createTrapProduct("It's a trap", $upgrades), $this->createTrapProduct("Counter-Offensive Trap", $upgrades), $this->createTrapProduct("Alarm Trap", $upgrades), $this->createTrapProduct("Miner Fatigue Trap", $upgrades) ]; } private function createTrapProduct(string $name, Upgrades $upgrades): UpgradesProduct { return new TrapProduct($name, $upgrades->getTrapsCount() + 1); } }amount = $amount; $this->item = ($item instanceof Block ? $item->asItem() : $item)->setCount($amount); $this->on_purchase = $on_purchase; $this->can_be_purchased = $can_be_purchased; parent::__construct($name, $name, $price, $ore); } public function getItem(): Item { return clone $this->item; } public function canBePurchased(Session $session): bool { return $this->can_be_purchased; } public function getDisplayName(Session $session): string { $name = parent::getDisplayName($session); if(!$this->can_be_purchased) { $name = TextFormat::clean($name); $name = TextFormat::RED . $name; } if($this->amount > 1) { $name .= " x" . $this->amount; } return $name; } public function getDescription(Session $session): string { $description = parent::getDescription($session); if(!$this->can_be_purchased) { $description = TextFormat::RED . "You already have this product!"; } return $description; } public function onPurchase(Session $session): bool { $inventory = $session->getPlayer()->getInventory(); if(!$inventory->canAddItem($this->item)) { $session->message("{RED}Your inventory is full!"); return false; } $this->executePurchaseListener($session); $inventory->addItem($this->item); return true; } private function executePurchaseListener(Session $session): void { if($this->on_purchase !== null) { ($this->on_purchase)($session); } } }createMeleeProduct("stone", 10, VanillaItems::IRON_INGOT(), $session), $this->createMeleeProduct("iron", 7, VanillaItems::GOLD_INGOT(), $session), $this->createMeleeProduct("diamond", 4, VanillaItems::EMERALD(), $session), new ItemProduct( "Stick (Knockback I)", 5, 1, VanillaItems::STICK()->addEnchantment(new EnchantmentInstance(VanillaEnchantments::KNOCKBACK())), VanillaItems::GOLD_INGOT() ) ]; } private function createMeleeProduct(string $name, int $price, Item $ore, Session $session): ItemProduct { $sword = StringToItemParser::getInstance()->parse($name . "_sword"); if($sword instanceof Durable) { $sword->setUnbreakable(); } if(!$session->getTeam()->getUpgrades()->getSharpenedSwords()->canLevelUp()) { $sword->addEnchantment(new EnchantmentInstance(VanillaEnchantments::SHARPNESS())); } return new ItemProduct(ucfirst($name) . " Sword", $price, 1, $sword, $ore, function(Session $session) { $session->getPlayer()->getInventory()->remove(VanillaItems::WOODEN_SWORD()); }); } }setType(PotionType::SWIFTNESS()), VanillaItems::EMERALD()), new ItemProduct("Jump V Potion (45 seconds)", 1, 1, VanillaItems::POTION()->setType(PotionType::LEAPING()), VanillaItems::EMERALD()), new ItemProduct("Invisibility Potion (30 seconds)", 2, 1, VanillaItems::POTION()->setType(PotionType::INVISIBILITY()), VanillaItems::EMERALD()) ]; } }addEnchantment($power), VanillaItems::GOLD_INGOT()), new ItemProduct( "Bow (Power I, Punch I)", 6, 1, VanillaItems::BOW() ->addEnchantment($power) ->addEnchantment(new EnchantmentInstance(VanillaEnchantments::PUNCH())), VanillaItems::EMERALD() ), ]; } }getTeam()->getDyeColor(); return [ new ItemProduct("Wool", 4, 16, VanillaBlocks::WOOL()->setColor($color), VanillaItems::IRON_INGOT()), new ItemProduct("Hardened Clay", 12, 16, VanillaBlocks::STAINED_CLAY()->setColor($color), VanillaItems::IRON_INGOT()), new ItemProduct("Blast-Proof Glass", 12, 4, VanillaBlocks::STAINED_GLASS()->setColor($color), VanillaItems::IRON_INGOT()), new ItemProduct("End Stone", 24, 12, VanillaBlocks::END_STONE(), VanillaItems::IRON_INGOT()), new ItemProduct("Ladder", 4, 8, VanillaBlocks::LADDER(), VanillaItems::IRON_INGOT()), new ItemProduct("Oak Wood Planks", 4, 16, VanillaBlocks::OAK_WOOD(), VanillaItems::GOLD_INGOT()), new ItemProduct("Obsidian", 4, 4, VanillaBlocks::OBSIDIAN(), VanillaItems::EMERALD()) ]; } }getGameSettings(); return [ $this->createArmorProduct("chainmail", 30, VanillaItems::IRON_INGOT(), $settings), $this->createArmorProduct("iron", 12, VanillaItems::GOLD_INGOT(), $settings), $this->createArmorProduct("diamond", 6, VanillaItems::EMERALD(), $settings) ]; } private function createArmorProduct(string $armor, int $price, Item $ore, GameSettings $settings): ItemProduct { return new ItemProduct("Permanent " . ucfirst($armor) . " Armor", $price, 0, VanillaItems::AIR(), $ore, function(Session $session) use ($armor) { $session->getGameSettings()->setArmor($armor); }, $this->getPriority($settings->getArmor()) < $this->getPriority($armor)); } private function getPriority(?string $armor): int { return match($armor) { "chainmail" => 1, "iron" => 2, "diamond" => 3, default => 0 }; } }getGameSettings(); return [ new ItemProduct("Permanent Shears", 20, 1, VanillaItems::SHEARS(), VanillaItems::IRON_INGOT(), function(Session $session) { $session->getGameSettings()->setPermanentShears(); return true; }), $this->createToolProduct("Pickaxe", $settings->getPickaxeTier(), $settings, $settings->isPickaxeFullUpgraded(), function() use ($settings) { $settings->incrasePickaxeTier(); }), $this->createToolProduct("Axe", $settings->getAxeTier(), $settings, $settings->isAxeFullUpgraded(), function() use ($settings) { $settings->incraseAxeTier(); }) ]; } private function createToolProduct(string $name, int $tier, GameSettings $settings, bool $is_full_upgraded, Closure $on_purchase): ItemProduct { $tier++; return new ItemProduct( $settings->getMaterial($tier) . " $name " . ($tier <= 4 ? "Tier " . GameUtils::intToRoman($tier) : "MAX TIER"), $this->getPrice($tier), 1, $settings->getTool($name, $tier), $this->getOre($tier), function(Session $session) use ($name, $tier, $settings, $is_full_upgraded, $on_purchase) { $session->getPlayer()->getInventory()->remove($settings->getTool($name, $tier - 1)); $on_purchase(); }, !$is_full_upgraded); } private function getPrice(int $tier): int { return match($tier) { 1, 2 => 10, 3 => 3, 4 => 6, 5 => 0 }; } private function getOre(int $tier): Item { return match($tier) { 1, 2 => VanillaItems::IRON_INGOT(), 3, 4 => VanillaItems::GOLD_INGOT(), 5 => VanillaItems::AIR() }; } }getDataFolder() . "maps.json"), true) as $map_data) { $name = $map_data["name"]; $world_name = $map_data["waiting_world"]; $position_data = $map_data["spectator_spawn_position"]; $players_per_team = $map_data["players_per_team"]; $capacity = $map_data["max_capacity"]; $world_manager = Server::getInstance()->getWorldManager(); if(!$world_manager->loadWorld($world_name)) { throw new ServerException("Couldn't load " . $name . " map because the world doesn't exist. (" . $world_name . ")"); } $waiting_world = $world_manager->getWorldByName($world_name); $spectator_spawn_position = new Vector3($position_data["x"], $position_data["y"], $position_data["z"]); $generators = []; foreach($map_data["generators"] as $type => $generator_data) { foreach($generator_data as $position) { $generators[] = GeneratorType::toGenerator(self::createVector($position), GeneratorType::fromString($type)); } } $shop_locations = self::createPositions($map_data["shop_positions"]); $upgrades_locations = self::createPositions($map_data["upgrades_positions"]); $teams = []; foreach($map_data["teams"] as $data) { $generator_data = $data["generator"]; $areas_data = $data["areas"]; $bed_data = $data["bed"]; $team_generators = []; $team_generators[] = new IronGenerator(self::createVector($generator_data)); $team_generators[] = new GoldGenerator(self::createVector($generator_data)); $teams[] = new Team( ucfirst($data["name"]), $players_per_team, self::createVector($data["spawn_point"]), new Vector3($bed_data["x"], $bed_data["y"] + 1, $bed_data["z"]), Area::fromData($areas_data["zone"]), Area::fromData($areas_data["claim"]), $team_generators ); } self::addMap(new Map( $name, $spectator_spawn_position, $players_per_team, $capacity, $waiting_world, $generators, $teams, $shop_locations, $upgrades_locations )); } } /** * @return Map[] */ static public function getMaps(): array { return self::$maps; } /** * @return Map[] */ static public function getMapsByPlayers(int $players_per_team): array { return array_filter(self::$maps, function(Map $map) use ($players_per_team) { return $map->getPlayersPerTeam() === $players_per_team; }); } /** * @return Map[] */ static public function getMapsByName(string $name): array { $maps = []; foreach(self::$maps as $map) { if(strtolower($map->getName()) === strtolower($name)) { $maps[] = $map; } } return $maps; } static public function getMapByName(string $name): ?Map { foreach(self::$maps as $map) { if(strtolower($map->getName()) === strtolower($name)) { return $map; } } return null; } static public function getMapById(string $id): ?Map { return self::$maps[$id] ?? null; } static public function addMap(Map $map): void { self::$maps[$map->getId()] = $map; } static public function removeMap(string $id): void { unset(self::$maps[$id]); } static private function createVector(array $data): Vector3 { return new Vector3($data["x"] + 0.5, $data["y"] + 1.5, $data["z"] + 0.5); } static private function createPositions(array $positions): array { return array_map(function(array $data) { return self::createVector($data); }, $positions); } }storeLocal("map", $map); $this->world_path = BedWars::getInstance()->getDataFolder() . "worlds/" . $map->getName(); } public function onRun(): void { Filesystem::recursiveUnlink($this->world_path); } public function onCompletion(): void { // TODO: Do not reuse code $map = $this->fetchLocal("map"); $plugin = BedWars::getInstance(); $path = $plugin->getDataFolder() . "maps.json"; $data = json_decode(file_get_contents($path), true); $data = array_filter($data, function(array $map_data) use ($map): bool { return $map_data["name"] !== $map->getName(); }); file_put_contents($path, json_encode($data, JSON_THROW_ON_ERROR)); MapFactory::removeMap($map->getId()); } }storeLocal("map", $map); $this->world_path = Server::getInstance()->getDataPath() . "worlds/" . $map->getPlayingWorld(); $this->destination_path = BedWars::getInstance()->getDataFolder() . "worlds/" . $map->getName(); $world_manager = Server::getInstance()->getWorldManager(); $world_manager->unloadWorld($world_manager->getWorldByName($map->getPlayingWorld())); } public function onRun(): void { Filesystem::recursiveCopy($this->world_path, $this->destination_path); } public function onCompletion(): void { // TODO: Do not reuse code $map = $this->fetchLocal("map")->build(); $plugin = BedWars::getInstance(); $path = $plugin->getDataFolder() . "maps.json"; $data = json_decode(file_get_contents($path), true); $data[] = $map->jsonSerialize(); file_put_contents($path, json_encode($data, JSON_THROW_ON_ERROR)); MapFactory::addMap($map); $plugin->getGameManager()->generateGames($map); } }id; } public function getName(): string { return $this->name; } public function getSpectatorSpawnPosition(): Vector3 { return $this->spectator_spawn_position; } public function getPlayersPerTeam(): int { return $this->players_per_team; } public function getMaxCapacity(): int { return $this->max_capacity; } public function getWaitingWorld(): World { return $this->waiting_world; } /** * @return Generator[] */ public function getGenerators(): array { return $this->generators ?? []; } /** * @return Vector3[] */ public function getShopPositions(): array { return $this->shop_positions; } /** * @return Vector3[] */ public function getUpgradesPositions(): array { return $this->upgrades_positions; } }id = uniqid("map-"); $this->name = $name; $this->spectator_spawn_position = $spectator_spawn_position; $this->players_per_team = $players_per_team; $this->max_capacity = $max_capacity; $this->waiting_world = $waiting_world; $this->generators = $generators; $this->teams = $teams; $this->shop_positions = $shop_locations; $this->upgrades_positions = $upgrades_locations; } /** * @return Team[] */ public function getTeams(): array { return $this->teams; } public function jsonSerialize(): array { return [ "name" => $this->name, "waiting_world" => $this->waiting_world->getFolderName(), "spectator_spawn_position" => [ "x" => $this->spectator_spawn_position->getX(), "y" => $this->spectator_spawn_position->getY(), "z" => $this->spectator_spawn_position->getZ() ], "players_per_team" => $this->players_per_team, "max_capacity" => $this->max_capacity, "generators" => [ "diamond" => $this->jsonSerializePositions($this->getGeneratorPositions(GeneratorType::DIAMOND)), "emerald" => $this->jsonSerializePositions($this->getGeneratorPositions(GeneratorType::EMERALD)) ], "teams" => array_map(function(Team $team) { return $team->jsonSerialize(); }, $this->teams), "shop_positions" => $this->jsonSerializePositions($this->shop_positions), "upgrades_positions" => $this->jsonSerializePositions($this->upgrades_positions) ]; } private function getGeneratorPositions(GeneratorType $type): array { $positions = []; foreach($this->generators as $generator) { if($generator->getType() === $type) { $positions[] = $generator->getPosition(); } } return $positions; } private function jsonSerializePositions(array $positions): array { return array_map(function(Vector3 $position) { return [ "x" => $position->getX(), "y" => $position->getY(), "z" => $position->getZ() ]; }, $positions); } }type = $type; $this->tier = $tier; parent::__construct($type->toString() . " " . $tier->name, 6); } public function end(): void { foreach($this->game->getGenerators() as $generator) { if($generator->getType() !== $this->type) { continue; } $generator->setTier($this->tier); if($generator instanceof TextGenerator) { $generator->updateText($this->game->getWorld()); } } $this->game->broadcastMessage(GameUtils::getGeneratorColor($name = $this->type->toString()) . $name . " Generators {YELLOW}have been upgraded to Tier {RED}" . $this->tier->name); } public function getNextEvent(): ?Event { $next_type = match($this->type) { GeneratorType::DIAMOND => GeneratorType::EMERALD, GeneratorType::EMERALD => GeneratorType::DIAMOND }; $next_tier = $this->getNextTier($next_type); if($next_tier === null) { return new BedDestructionEvent(); } return new UpgradeGeneratorsTierEvent($next_type, $next_tier); } private function getNextTier(GeneratorType $type): ?Tier { if($type === GeneratorType::DIAMOND) { return match($this->tier) { Tier::I => Tier::II, Tier::II => Tier::III, Tier::III => null }; } return $this->tier; } }game->setStage(new EndingStage()); } public function getNextEvent(): ?Event { return null; } }game->getTeams() as $team) { if(!$team->isBedDestroyed()) { $team->destroyBed($this->game); } } $this->game->updateScoreboards(); } public function getNextEvent(): Event { return new EndGameInATieEvent(); } }name = $name; $this->duration = $duration * 60; } public function getName(): string { return $this->name; } private function getTimeElapsed(): int { return time() - $this->start_time; } public function getTimeRemaining(): int { return $this->duration - $this->getTimeElapsed(); } public function hasEnded(): bool { if($this->getTimeElapsed() >= $this->duration) { $this->end(); return true; } return false; } public function start(Game $game): void { $this->game = $game; $this->start_time = time(); } abstract protected function end(): void; abstract public function getNextEvent(): ?Event; }armor_protection = new ArmorProtection(); $this->maniac_miner = new ManiacMiner(); $this->iron_forge = new IronForge(); $this->sharpened_swords = new SharpenedSwords(); $this->heal_pool = new HealPool(); } /** * @return Upgrade[] */ public function getAll(): array { return [$this->armor_protection, $this->maniac_miner, $this->iron_forge, $this->sharpened_swords, $this->heal_pool]; } public function getArmorProtection(): ArmorProtection { return $this->armor_protection; } public function getManiacMiner(): ManiacMiner { return $this->maniac_miner; } public function getIronForge(): IronForge { return $this->iron_forge; } public function getSharpenedSwords(): SharpenedSwords { return $this->sharpened_swords; } public function getHealPool(): HealPool { return $this->heal_pool; } public function getUpgrade(string $name): ?Upgrade { foreach($this->getAll() as $upgrade) { if($upgrade->getName() === $name) { return $upgrade; } } return null; } public function canTriggerTrap(): bool { if(time() - $this->trap_trigger_time >= 30 and !empty($this->traps)) { $this->trap_trigger_time = time(); return true; } return false; } /** * @return Trap[] */ public function getTraps(): array { return $this->traps; } public function getTrapsCount(): int { return count($this->traps); } public function hasTrap(string $name): bool { return array_key_exists($name, $this->traps); } public function addTrap(Trap $trap): void { $this->traps[$trap->getName()] = $trap; } public function triggerPrimaryTrap(Session $session, Team $team): void { $trap = array_shift($this->traps); $trap->trigger($session, $team); $team->notifyTrap($trap, $session->getTeam()); } public function __clone(): void { $this->traps = Utils::cloneObjectArray($this->traps); } }name = $name; $this->color = ColorUtils::translate("{" . strtoupper($name) . "}"); $this->capacity = $capacity; $this->spawn_point = $spawn_point; $this->bed_position = $bed_position; $this->zone = $zone; $this->claim = $claim; $this->generators = $generators; $this->upgrades = new Upgrades(); } public function getColoredName(): string { return $this->color . $this->name; } public function getFirstLetter(): string { return $this->name[0]; } public function getUpgrades(): Upgrades { return $this->upgrades; } public function isBedDestroyed(): bool { return $this->bed_destroyed; } /** * @return Generator[] */ public function getGenerators(): array { return $this->generators; } /** * @return Session[] */ public function getMembers(): array { return $this->members; } public function getMembersCount(): int { return count($this->members); } public function isFull(): bool { return $this->getMembersCount() >= $this->capacity; } public function isEmpty(): bool { return empty($this->members); } public function isAlive(): bool { return !$this->isEmpty(); } public function hasMember(Session $session): bool { return in_array($session, $this->members, true); } public function destroyBed(Game $game, bool $break_block = true, bool $silent = false): void { $this->bed_destroyed = true; if($break_block) { $this->breakBedBlock($game); } if(!$silent) { foreach($game->getPlayersAndSpectators() as $session) { if(!$session->hasTeam() or $session->getTeam()->getName() !== $this->name) { $session->playSound("mob.enderdragon.growl"); } } foreach($this->members as $member) { $member->title("{RED}BED DESTROYED!", "{WHITE}You will no longer respawn!", 7, 30, 15); $member->playSound("mob.wither.death"); } } } private function breakBedBlock(Game $game): void { $world = $game->getWorld(); $position = Position::fromObject($this->bed_position, $world); $world->requestChunkPopulation($position->getX() >> Chunk::COORD_BIT_SIZE, $position->getZ() >> Chunk::COORD_BIT_SIZE, null)->onCompletion( function() use ($world, $position) { $blocks = $world->getBlock($position)->getAffectedBlocks(); foreach($blocks as $block) { if($block instanceof Air) { continue; } $block->onBreak(VanillaItems::AIR()); } }, function() {} ); } public function tickGenerators(Game $game): void { if($this->isAlive()) { foreach($this->generators as $generator) { $generator->tick($game); } } } public function addGenerator(Generator $generator): void { $this->generators[] = $generator; } private function removeEmeraldGenerator(): void { foreach($this->generators as $index => $generator) { if($generator->getType() === GeneratorType::TEAM_EMERALD) { unset($this->generators[$index]); break; } } } public function addMember(Session $session): void { $this->members[] = $session; $session->setTeam($this); $session->clearAllInventories(); $session->getGameSettings()->apply(); $player = $session->getPlayer(); $player->setNameTag($this->color . $this->getFirstLetter() . " " . $player->getName()); $player->setGamemode(GameMode::SURVIVAL()); $player->teleport(Position::fromObject($this->spawn_point, $session->getGame()->getWorld())); } public function removeMember(Session $session): void { unset($this->members[array_search($session, $this->members, true)]); if($this->isEmpty()) { $this->destroyBed($session->getGame()); } $session->setTeam(null); } public function notifyTrap(Trap $trap, Team $team): void { $name = $trap->getName(); if($trap instanceof AlarmTrap) { $title = "{BOLD}{RED}ALARM!!!"; $subtitle = "{WHITE}" . $name . " set off by " . $team->getColoredName() . "{WHITE} team!"; $message = "{BOLD}{RED}" . $name . " set off by " . $team->getColoredName() . "{RED} team!"; } else { $title = "{RED}TRAP TRIGGERED!"; $subtitle = "{WHITE}Your $name has been set off!"; $message = "{BOLD}{RED}" . $name . " was set off!"; } foreach($this->members as $member) { $member->title($title, $subtitle); $member->message($message); // TODO: Play sound } } public function reset(): void { $this->bed_destroyed = false; $this->upgrades = new Upgrades(); $this->removeEmeraldGenerator(); foreach($this->generators as $generator) { $generator->reset(); } foreach($this->members as $member) { $member->setTeam(null); } $this->members = []; } public function jsonSerialize(): array { return [ "name" => $this->name, "spawn_point" => [ "x" => $this->spawn_point->getX(), "y" => $this->spawn_point->getY(), "z" => $this->spawn_point->getZ() ], "bed" => [ "x" => $this->bed_position->getX(), "y" => $this->bed_position->getY(), "z" => $this->bed_position->getZ() ], "generator" => [ "x" => $this->generators[0]->getPosition()->getX(), "y" => $this->generators[0]->getPosition()->getY(), "z" => $this->generators[0]->getPosition()->getZ() ], "areas" => [ "zone" => $this->zone->jsonSerialize(), "claim" => $this->claim->jsonSerialize() ] ]; } public function __clone(): void { $this->upgrades = clone $this->upgrades; $this->generators = Utils::cloneObjectArray($this->generators); } }first_vector = $first_vector->floor(); $this->second_vector = $second_vector->floor(); } static public function fromData(array $data): Area { return new Area( new Vector3($data["first_x"], $data["first_y"], $data["first_z"]), new Vector3($data["second_x"], $data["second_y"], $data["second_z"]) ); } public function getMinX(): int { return min($this->first_vector->getFloorX(), $this->second_vector->getFloorX()); } public function getMinY(): int { return min($this->first_vector->getFloorY(), $this->second_vector->getFloorY()); } public function getMinZ(): int { return min($this->first_vector->getFloorZ(), $this->second_vector->getFloorZ()); } public function getMaxX(): int { return max($this->first_vector->getFloorX(), $this->second_vector->getFloorX()); } public function getMaxY(): int { return max($this->first_vector->getFloorY(), $this->second_vector->getFloorY()); } public function getMaxZ(): int { return max($this->first_vector->getFloorZ(), $this->second_vector->getFloorZ()); } public function isInside(Vector3 $position): bool { return $position->x >= $this->getMinX() && $position->x <= $this->getMaxX() and $position->z >= $this->getMinZ() && $position->z <= $this->getMaxZ(); } public function jsonSerialize(): array { return [ "first_x" => $this->first_vector->getFloorX(), "first_y" => $this->first_vector->getFloorY(), "first_z" => $this->first_vector->getFloorZ(), "second_x" => $this->second_vector->getFloorX(), "second_y" => $this->second_vector->getFloorY(), "second_z" => $this->second_vector->getFloorZ() ]; } }level; } public function canLevelUp(): bool { return $this->level < $this->getLevels(); } public function levelUp(Team $team): void { $this->level++; $this->internalLevelUp($team); foreach($team->getMembers() as $session) { $this->applySession($session); } } public function applySession(Session $session): void { if($this->level > 0) { $this->internalApplySession($session); } } protected function internalLevelUp(Team $team): void {} protected function internalApplySession(Session $session): void {} abstract public function getName(): string; abstract public function getLevels(): int; }getPlayer()->getArmorInventory(); foreach($inventory->getContents() as $index => $item) { $item->addEnchantment(new EnchantmentInstance(VanillaEnchantments::PROTECTION(), $this->level)); $inventory->setItem($index, $item); } } }getGenerators(); if($this->level === 3) { // generate emeralds $team->addGenerator(new TeamEmeraldGenerator($generators[array_rand($generators)]->getPosition())); return; } foreach($generators as $generator) { $speed = 1 / $generator->getInitialSpeed(); $generator->setCountdown($this->level / 2 * $speed + $speed); } } }getPlayer()->getInventory(); foreach($inventory->getContents() as $index => $item) { if($item instanceof Sword) { $item->addEnchantment(new EnchantmentInstance(VanillaEnchantments::SHARPNESS())); $inventory->setItem($index, $item); } } } }addEffect(new EffectInstance(VanillaEffects::HASTE(), Limits::INT32_MAX, $this->level - 1, false)); } }name = $name; } public function getName(): string { return $this->name; } abstract public function trigger(Session $session, Team $team): void; }addEffect(new EffectInstance(VanillaEffects::BLINDNESS(), 20 * 8, 0, false)); $session->addEffect(new EffectInstance(VanillaEffects::SLOWNESS(), 20 * 8, 0, false)); } }getMembers() as $member) { $member->addEffect(new EffectInstance(VanillaEffects::SPEED(), 20 * 15, 1, false)); $member->addEffect(new EffectInstance(VanillaEffects::JUMP_BOOST(), 20 * 15, 1, false)); } } }addEffect(new EffectInstance(VanillaEffects::MINING_FATIGUE(), 20 * 10, 0, false)); } }getPlayer()->getEffects()->remove(VanillaEffects::INVISIBILITY()); } }name; } public function getColor(): string { return $this->color; } public function getDyeColor(): DyeColor { return ColorUtils::getDye($this->color); } public function getSpawnPoint(): Vector3 { return $this->spawn_point; } public function getBedPosition(): Vector3 { return $this->bed_position; } public function getZone(): Area { return $this->zone; } public function getClaim(): Area { return $this->claim; } }id = $game->getId(); $this->world_path = Server::getInstance()->getDataPath() . "worlds/" . $game->getMap()->getName() . "-" . $this->id; } public function onRun(): void { Filesystem::recursiveUnlink($this->world_path); } public function onCompletion(): void { BedWars::getInstance()->getGameManager()->removeGame($this->id); } }id = $id; $this->map_id = $map->getId(); $this->map_name = $map->getName(); $this->world_path = BedWars::getInstance()->getDataFolder() . "worlds/" . $this->map_name; $this->destination_path = Server::getInstance()->getDataPath() . "worlds/" . $this->map_name . "-" . $id; } public function onRun(): void { Filesystem::recursiveCopy($this->world_path, $this->destination_path); } public function onCompletion(): void { BedWars::getInstance()->getGameManager()->addGame(new Game(MapFactory::getMapById($this->map_id), $this->id)); } }game = $game; $this->onStart(); foreach($this->game->getPlayers() as $session) { $this->onJoin($session); } } protected function onStart(): void {} /* * Called when someone joins the game in this stage */ public function onJoin(Session $session): void {} /* * Called when someone quits the game in this stage */ public function onQuit(Session $session): void {} abstract public function tick(): void; }countdown; } public function onQuit(Session $session): void { $this->onSessionQuit($session); if(count($this->game->getPlayers()) < ($this->game->getMap()->getMaxCapacity() / 2)) { $this->game->setStage(new WaitingStage()); } } public function tick(): void { if($this->countdown <= 0) { $this->game->setStage(new PlayingStage()); } elseif($this->countdown <= 5) { $this->broadcastCountdownTitle(); } if($this->countdown > 0) { $this->game->broadcastMessage($this->getStartingMessage()); } if($this->countdown === 5) { $this->game->setupWorld(); } elseif($this->countdown === 10) { $this->broadcastCountdownTitle(); } $this->game->updateScoreboards(); $this->countdown--; } private function getStartingMessage(): string { $message = "{YELLOW}The game is starting within {time} {YELLOW}seconds!"; if($this->countdown <= 10) { $message = "{YELLOW}The game starts in {time} {YELLOW}" . ($this->countdown === 1 ? "second" : "seconds") . "!"; } $message = str_replace("{time}", GameUtils::getColoredMessageNumber($this->countdown), $message); return $message; } private function broadcastCountdownTitle(): void { $this->game->broadcastTitle(GameUtils::getColoredTitleNumber($this->countdown)); $this->game->broadcastSound(new ClickSound()); } }game = $game; } public function onJoin(Session $session): void { $session->showBossBar("{YELLOW}Playing {WHITE}BED WARS {YELLOW}on {GREEN}" . strtoupper(ConfigGetter::getIP())); $session->getPlayer()->getEffects()->clear(); $session->giveWaitingItems(); $session->setGame($this->game); $session->setScoreboard(new WaitingScoreboard()); $session->teleportToWaitingWorld(); $this->game->broadcastMessage( "{GRAY}" . $session->getUsername() . " {YELLOW}has joined ({AQUA}" . $this->game->getPlayersCount() . "{YELLOW}/{AQUA}" . $this->game->getMap()->getMaxCapacity() . "{YELLOW})!" ); } public function onQuit(Session $session): void { $this->game->broadcastMessage("{GRAY}" . $session->getUsername() . " {YELLOW}has quit!"); } }onSessionJoin($session); $this->startIfReady(); } private function startIfReady(): void { $map = $this->game->getMap(); $count = $this->game->getPlayersCount(); if($count > $map->getPlayersPerTeam() and $count >= ($map->getMaxCapacity() / 2)) { $this->game->setStage(new StartingStage()); } } public function tick(): void {} }next_event; } public function hasStarted(): bool { return $this->next_event !== null; } private function startNextEvent(?Event $event = null): void { $this->next_event = $event ?? $this->next_event->getNextEvent(); $this->next_event?->start($this->game); } protected function onStart(): void { $teams = $this->game->getTeams(); shuffle($teams); foreach($teams as $team) { foreach($this->game->getPlayers() as $session) { if(!$team->isFull() and !$session->hasTeam()) { $team->addMember($session); if($team->isFull()) { continue 2; } } } if(!$team->isAlive()) { $team->destroyBed($this->game, true, true); } } $this->startNextEvent(new UpgradeGeneratorsTierEvent(GeneratorType::DIAMOND, Tier::II)); } public function onJoin(Session $session): void { $session->setScoreboard(new GameScoreboard()); } public function onQuit(Session $session): void { $session->title("{RED}GAME OVER!"); $session->resetSettings(); $session->setTrackingSession(null); if($session->hasTeam()) { $team = $session->getTeam(); $team->removeMember($session); if(!$team->isAlive()) { $this->game->broadcastMessage("{BOLD}{WHITE}TEAM ELIMINATED > {RESET}" . $team->getColoredName() . " Team {RED}has been eliminated!"); } } $this->game->despawnGeneratorsFrom($session); if(count($this->game->getAliveTeams()) === 1) { $this->game->setStage(new EndingStage()); } } public function tick(): void { if($this->next_event->hasEnded()) { $this->startNextEvent(); } $this->game->updateScoreboards(); $this->tickPlayersAndSpectators(); } private function tickPlayersAndSpectators(): void { foreach($this->game->getPlayers() as $session) { $this->checkTrackingSession($session); if($session->isRespawning()) { $session->attemptToRespawn(); } if(!$session->hasTeam()) { continue; } $team = $session->getTeam(); if($team->getUpgrades()->getHealPool()->canLevelUp()) { continue; } if($team->getZone()->isInside($session->getPlayer()->getPosition())) { $session->addEffect(new EffectInstance(VanillaEffects::REGENERATION(), Limits::INT32_MAX, 0, false)); } else { $session->getPlayer()->getEffects()->remove(VanillaEffects::REGENERATION()); } } foreach($this->game->getSpectators() as $session) { $this->checkTrackingSession($session); } } private function checkTrackingSession(Session $session): void { $tracking_session = $session->getTrackingSession(); if($tracking_session === null) { return; } $player = $session->getPlayer(); if($tracking_session->isRespawning()) { $player->sendPopup(TextFormat::RED . "Target lost"); $session->setTrackingSession(null); return; } $session->updateCompassDirection(); $position = $tracking_session->getPlayer()->getPosition(); $distance = $player->getPosition()->distance($position); $player->sendPopup(ColorUtils::translate( "Target: {GREEN}{BOLD}" . $tracking_session->getUsername() . " {RESET}{WHITE}Distance: {GREEN}{BOLD}" . round($distance, 1) . "m" )); if($session->isSpectator() and $session->getSpectatorSettings()->getAutoTeleport() and $distance >= 10) { $player->teleport($position); } } } game->getSpectators() as $session) { $session->title("{RED}GAME OVER!"); } $this->tie = count($this->game->getAliveTeams()) > 1; } public function onJoin(Session $session): void { if(!$this->tie) { $session->addWin(); $session->addCoins(140); } $session->title($this->getTitle(), "", 0, $this->time * 20); $session->resetSettings(); } public function onQuit(Session $session): void { $this->game->despawnGeneratorsFrom($session); } public function tick(): void { $this->time--; if($this->time <= 0) { $this->game->reset(); } } private function getTitle(): string { return $this->tie ? "{ORANGE}TIE!" : "{GOLD}VICTORY!"; } }generateGames($map); } } public function getNextGameId(): int { return $this->next_game_id++; } /** * @return Game[] */ public function getGames(): array { return $this->games; } public function getGamesCount(Map $map): int { return count($this->getGamesByMap($map)); } /** * @return Game[] */ public function getGamesByMap(Map $map): array { $games = []; foreach($this->games as $game) { if($game->getMap()->getId() === $map->getId()) { $games[] = $game; } } return $games; } public function getGameByWorld(World $world): ?Game { foreach(BedWars::getInstance()->getGameManager()->getGames() as $game) { if($game->getWorld() === $world) { return $game; } } return null; } public function findRandomGame(int $players_per_team): ?Game { $maps = MapFactory::getMapsByPlayers($players_per_team); if($maps !== []) { $map = $maps[array_rand($maps)]; return $this->findGame($map); } return null; } public function findGame(Map $map): ?Game { $games = []; foreach($this->getGamesByMap($map) as $game) { $stage = $game->getStage(); if($stage instanceof WaitingStage or ($stage instanceof StartingStage and !$game->isFull())) { $games[] = $game; } } if(empty($games)) { $this->generateGames($map); return null; } $found = null; $index = PHP_INT_MIN; foreach($games as $game) { $count = $game->getPlayersCount(); if($count > $index) { $index = $count; $found = $game; } } return $found; } public function generateGames(Map $map): void { for($i = 0; $i < 3; ++$i) { Server::getInstance()->getAsyncPool()->submitTask(new GenerateGameTask( $this->getNextGameId(), $map )); } } public function addGame(Game $game): void { $this->games[$game->getId()] = $game; } public function removeGame(int $id): void { unset($this->games[$id]); } }id = $id; $this->map = $map; $this->teams = Utils::cloneObjectArray($map->getTeams()); $this->generators = Utils::cloneObjectArray($map->getGenerators()); $this->setStage(new WaitingStage()); } public function getId(): int { return $this->id; } public function getStage(): Stage { return $this->stage; } public function getMap(): Map { return $this->map; } public function getWorld(): ?World { return $this->world; } /** * @return Generator[] */ public function getGenerators(): array { return $this->generators; } /** * @return Team[] */ public function getTeams(): array { return $this->teams; } /** * @return Team[] */ public function getAliveTeams(): array { $teams = []; foreach($this->teams as $team) { if($team->isAlive()) { $teams[] = $team; } } return $teams; } /** * @return Session[] */ public function getPlayers(): array { return $this->players; } /** * @return Session[] */ public function getSpectators(): array { return $this->spectators; } /** * @return Session[] */ public function getPlayersAndSpectators(): array { return array_merge($this->players, $this->spectators); } public function getPlayersCount(): int { return count($this->players); } public function isFull(): bool { return $this->getPlayersCount() >= $this->map->getMaxCapacity(); } public function checkBlock(Position $position): bool { foreach($this->blocks as $index => $block) { if($block->equals($position)) { unset($this->blocks[$index]); return true; } } return false; } public function isPlaying(Session $session): bool { return in_array($session, $this->players, true); } public function isSpectator(Session $session): bool { return in_array($session, $this->spectators, true); } public function setStage(Stage $stage): void { $this->stage = $stage; $this->stage->start($this); } public function addBlock(Position $position): void { $this->blocks[] = $position; } public function addPlayer(Session $session): void { $this->players[] = $session; $this->stage->onJoin($session); $this->updateScoreboards(); $this->updatePlayEntities(); } public function removePlayer(Session $session, bool $teleport_to_hub = true, bool $set_spectator = false): void { unset($this->players[array_search($session, $this->players, true)]); $this->stage->onQuit($session); if($teleport_to_hub) { $session->teleportToHub(); } if($set_spectator) { $this->addSpectator($session); } else { $session->setGame(null); } $this->updateScoreboards(); $this->updatePlayEntities(); } public function addSpectator(Session $session): void { $this->spectators[] = $session; $session->giveSpectatorItems(); $session->getSpectatorSettings()->apply(); } public function removeSpectator(Session $session): void { unset($this->spectators[array_search($session, $this->spectators, true)]); $this->despawnGeneratorsFrom($session); $session->setGame(null); $session->teleportToHub(); } public function despawnGeneratorsFrom(Session $session): void { foreach($this->getGenerators() as $generator) { if($generator instanceof TextGenerator) { $generator->getText()->despawnFrom($session); } } } private function updatePlayEntities(): void { foreach(Server::getInstance()->getWorldManager()->getDefaultWorld()->getEntities() as $entity) { if($entity instanceof PlayBedwarsEntity and $entity->getPlayersPerTeam() === $this->map->getPlayersPerTeam()) { $entity->updateNameTag(); } } } private function spawnVillager(Villager $villager): void { $position = $villager->getPosition()->floor(); $this->world->requestChunkPopulation($position->getX() >> Chunk::COORD_BIT_SIZE, $position->getZ() >> Chunk::COORD_BIT_SIZE, null)->onCompletion( function() use ($villager) { $villager->spawnToAll(); }, function() {} ); } public function tickGenerators(): void { foreach($this->generators as $generator) { $generator->tick($this); } foreach($this->teams as $team) { $team->tickGenerators($this); } } public function updateScoreboards(): void { foreach($this->getPlayersAndSpectators() as $session) { $session->updateScoreboard(); } } public function broadcastTitle(string $title): void { foreach($this->players as $session) { $session->title($title); } } public function broadcastMessage(string $message): void { foreach($this->getPlayersAndSpectators() as $session) { $session->message($message); } } public function broadcastSound(Sound|string $sound): void { foreach($this->getPlayersAndSpectators() as $session) { if(is_string($sound)) { $session->playSound($sound); } else { $player = $session->getPlayer(); $player->broadcastSound($sound, [$player]); } } } public function setupWorld(): void { $name = $this->map->getName() . "-" . $this->id; $world_manager = Server::getInstance()->getWorldManager(); if(!$world_manager->loadWorld($name)) { throw new WorldException("Failed to load world"); } $this->world = $world_manager->getWorldByName($name); $this->world->setAutoSave(false); $this->world->setTime(World::TIME_DAY); $this->world->stopTime(); foreach($this->map->getShopPositions() as $position) { $this->spawnVillager(new ItemShopVillager(Location::fromObject($position, $this->world))); } foreach($this->map->getUpgradesPositions() as $position) { $this->spawnVillager(new UpgradesShopVillager(Location::fromObject($position, $this->world))); } } public function unloadWorld(): void { if($this->world !== null) { Server::getInstance()->getWorldManager()->unloadWorld($this->world); $this->world = null; $this->blocks = []; } } public function reset(): void { foreach($this->players as $session) { $this->removePlayer($session); } foreach($this->spectators as $spectator) { $this->removeSpectator($spectator); } foreach($this->generators as $generator) { $generator->reset(); } $this->unloadWorld(); if(BedWars::getInstance()->getGameManager()->getGamesCount($this->map) > 5) { Server::getInstance()->getAsyncPool()->submitTask(new RemoveGameTask($this)); return; } foreach($this->teams as $team) { $team->reset(); } $this->setStage(new WaitingStage()); } }setNameTag(ColorUtils::translate("{AQUA}" . strtoupper($this->getName()) . "{RESET}\n{YELLOW}{BOLD}RIGHT CLICK")); $this->setNameTagAlwaysVisible(); } public function attack(EntityDamageEvent $source): void { if($source instanceof EntityDamageByChildEntityEvent or !$source instanceof EntityDamageByEntityEvent) { return; } $source->cancel(); $damager = $source->getDamager(); if(!$damager instanceof Player or !SessionFactory::hasSession($damager)) { return; } $session = SessionFactory::getSession($damager); if($session->isPlaying()) { $damager->sendForm($this->getForm($session)); } else { $session->message("{RED}You must be in game to do this!"); } } public function onInteract(Player $player, Vector3 $clickPos): bool { $player->sendForm($this->getForm(SessionFactory::getSession($player))); return true; } abstract protected function getName(): string; abstract protected function getForm(Session $session): Form; }getCategories()[0]); $form->addRedirectFormButton( ColorUtils::translate("{GOLD}{BOLD}Traps{RESET}\n{YELLOW}Click to view!"), new CategoryForm($session, $shop->getCategories()[1]) ); return $form; } }getRayTraceResult()->getHitVector(), $this->getWorld()), 4, $this); $explosion->explodeA(); $explosion->explodeB(); } }main: sergittos\bedwars\BedWars name: BedwarsPM api: 5.0.0 version: 1.1.0 author: Sergittos (@Sergittos) website: github.com/Sergittos description: 🛏️ A BedWars plugin for PocketMine-MP servers }EIL+ݳƽTݞ5>sj@]4GBMB