package me.ftl2nd.cloudClientChecker; import com.github.retrooper.packetevents.PacketEvents; import com.github.retrooper.packetevents.protocol.nbt.NBTByte; import com.github.retrooper.packetevents.protocol.nbt.NBTCompound; import com.github.retrooper.packetevents.protocol.nbt.NBTList; import com.github.retrooper.packetevents.protocol.nbt.NBTString; import com.github.retrooper.packetevents.protocol.nbt.NBTType; import com.github.retrooper.packetevents.protocol.world.blockentity.BlockEntityTypes; import com.github.retrooper.packetevents.protocol.world.states.WrappedBlockState; import com.github.retrooper.packetevents.util.Vector3i; import com.github.retrooper.packetevents.wrapper.play.server.WrapperPlayServerBlockChange; import com.github.retrooper.packetevents.wrapper.play.server.WrapperPlayServerBlockEntityData; import com.github.retrooper.packetevents.wrapper.play.server.WrapperPlayServerCloseWindow; import com.github.retrooper.packetevents.wrapper.play.server.WrapperPlayServerOpenSignEditor; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import java.util.logging.Logger; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer; import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer; import org.bukkit.ChatColor; import org.bukkit.Location; import org.bukkit.Material; import org.bukkit.block.Block; import org.bukkit.command.CommandSender; import org.bukkit.entity.Player; import org.bukkit.inventory.AnvilInventory; import org.bukkit.inventory.Inventory; import org.bukkit.inventory.ItemStack; import org.bukkit.inventory.meta.ItemMeta; import org.bukkit.plugin.java.JavaPlugin; public class Utils { private static final int MAX_KEYS_PER_LINE = 10; private static final int MAX_LINES_PER_SIGN = 4; private static final Component SPACER = Component.text(" "); public static void sendClientSideSign(Player player, JavaPlugin plugin, ConfigManager configManager) { Map bannedMods = configManager.getBannedMods(); List modNames = new ArrayList(bannedMods.keySet()); List translationKeys = new ArrayList(); boolean debug = configManager.isDebug(); PlayerCheckStatus.startCheck(player); PlayerCheckStatus.scheduleTimeout(player, plugin, 10); if (debug) { plugin.getLogger().info("Starting client-side sign check for " + player.getName()); plugin.getLogger().info("Found " + bannedMods.size() + " mods to check"); } Set detectedMods = MainListener.getDetectedMods(player.getUniqueId()); Iterator var8 = modNames.iterator(); while(var8.hasNext()) { String modName = (String)var8.next(); translationKeys.add((String)bannedMods.get(modName)); if (debug) { plugin.getLogger().info("Added translation key for mod: " + modName + " -> " + (String)bannedMods.get(modName)); } } MainListener.setModOrder(modNames); if (debug) { plugin.getLogger().info("Set mod order in MainListener"); } int currentIndex = 0; int batchCount; for(batchCount = 0; currentIndex < translationKeys.size(); ++batchCount) { int remainingMods = translationKeys.size() - currentIndex; int modsInThisBatch = Math.min(remainingMods, 40); List batchKeys = translationKeys.subList(currentIndex, currentIndex + modsInThisBatch); if (debug) { plugin.getLogger().info("Preparing batch #" + batchCount + " with " + batchKeys.size() + " keys"); } sendSignBatch(player, plugin, batchKeys, batchCount, debug); currentIndex += modsInThisBatch; } if (debug) { plugin.getLogger().info("Completed sending " + batchCount + " sign batches to " + player.getName()); } } private static void sendSignBatch(Player player, JavaPlugin plugin, List translationKeys, int batchIndex, boolean debug) { Location playerLoc = player.getLocation(); Location signLoc = playerLoc.clone().add(0.0D, -5.0D, 0.0D); Vector3i packetPosition = new Vector3i(signLoc.getBlockX(), signLoc.getBlockY(), signLoc.getBlockZ()); SignPositionTracker.trackSignPosition(player, packetPosition); if (debug) { Logger var10000 = plugin.getLogger(); int var10001 = packetPosition.getX(); var10000.info("Creating sign at position: " + var10001 + ", " + packetPosition.getY() + ", " + packetPosition.getZ()); } Block originalBlock = signLoc.getBlock(); WrappedBlockState originalBlockState = WrappedBlockState.getByString("minecraft:" + originalBlock.getType().toString().toLowerCase()); WrapperPlayServerBlockChange restoreBlockPacket; try { WrappedBlockState signBlockState = WrappedBlockState.getByString("minecraft:oak_sign[rotation=0,waterlogged=false]"); restoreBlockPacket = new WrapperPlayServerBlockChange(packetPosition, signBlockState.getGlobalId()); PacketEvents.getAPI().getPlayerManager().sendPacket(player, restoreBlockPacket); if (debug) { plugin.getLogger().info("Sent block change packet to create sign"); } Component[] signLines = createSignLines(translationKeys); NBTCompound nbtCompound = new NBTCompound(); NBTCompound frontText = new NBTCompound(); NBTList frontMessages = new NBTList(NBTType.STRING); Component[] var16 = signLines; int var17 = signLines.length; int i; for(i = 0; i < var17; ++i) { Component line = var16[i]; String jsonLine = (String)GsonComponentSerializer.gson().serialize(line); frontMessages.addTag(new NBTString(jsonLine)); if (debug) { plugin.getLogger().info("Sign line JSON: " + jsonLine); } } frontText.setTag("messages", frontMessages); frontText.setTag("color", new NBTString("black")); frontText.setTag("has_glowing_text", new NBTByte((byte)0)); NBTCompound backText = new NBTCompound(); NBTList backMessages = new NBTList(NBTType.STRING); for(i = 0; i < 4; ++i) { backMessages.addTag(new NBTString("{\"text\":\"\"}")); } backText.setTag("messages", backMessages); backText.setTag("color", new NBTString("black")); backText.setTag("has_glowing_text", new NBTByte((byte)0)); nbtCompound.setTag("is_waxed", new NBTByte((byte)0)); nbtCompound.setTag("front_text", frontText); nbtCompound.setTag("back_text", backText); plugin.getServer().getScheduler().runTaskLater(plugin, () -> { WrapperPlayServerBlockEntityData blockEntityDataPacket = new WrapperPlayServerBlockEntityData(packetPosition, BlockEntityTypes.SIGN, nbtCompound); PacketEvents.getAPI().getPlayerManager().sendPacket(player, blockEntityDataPacket); if (debug) { plugin.getLogger().info("Sent block entity data packet with sign content"); } }, 1L); plugin.getServer().getScheduler().runTaskLater(plugin, () -> { WrapperPlayServerCloseWindow closeWindowPacket1 = new WrapperPlayServerCloseWindow(0); PacketEvents.getAPI().getPlayerManager().sendPacket(player, closeWindowPacket1); WrapperPlayServerOpenSignEditor openSignPacket = new WrapperPlayServerOpenSignEditor(packetPosition, true); PacketEvents.getAPI().getPlayerManager().sendPacket(player, openSignPacket); WrapperPlayServerCloseWindow closeWindowPacket2 = new WrapperPlayServerCloseWindow(0); PacketEvents.getAPI().getPlayerManager().sendPacket(player, closeWindowPacket2); WrapperPlayServerBlockChange restorePacket = new WrapperPlayServerBlockChange(packetPosition, originalBlockState.getGlobalId()); PacketEvents.getAPI().getPlayerManager().sendPacket(player, restorePacket); if (debug) { plugin.getLogger().info("Opened sign editor GUI for player & Closed sign editor GUI & Restored original block"); } }, 2L); if (debug) { plugin.getLogger().info("Sent client-side sign batch #" + batchIndex + " to " + player.getName() + " with keys: " + String.join(", ", translationKeys)); } } catch (Exception var21) { plugin.getLogger().warning("Error sending client-side sign: " + var21.getMessage()); var21.printStackTrace(); restoreBlockPacket = new WrapperPlayServerBlockChange(packetPosition, originalBlockState.getGlobalId()); PacketEvents.getAPI().getPlayerManager().sendPacket(player, restoreBlockPacket); } } private static Component[] createSignLines(List translationKeys) { Component[] lines = new Component[4]; int keyIndex = 0; for(int lineIndex = 0; lineIndex < 4; ++lineIndex) { Component line = Component.text(""); for(int keysInThisLine = 0; keyIndex < translationKeys.size() && keysInThisLine < 10; ++keysInThisLine) { if (keysInThisLine > 0) { line = ((Component)line).append(SPACER); } line = ((Component)line).append(Component.translatable((String)translationKeys.get(keyIndex))); ++keyIndex; } lines[lineIndex] = (Component)line; } return lines; } public static void sendMeteorClientCheckAnvil(Player player, JavaPlugin plugin, CommandSender sender) { checkMeteorKey(player, plugin, sender, "key.meteor-client.open-gui", () -> { checkMeteorKey(player, plugin, sender, "key.meteor-client.open-commands", (Runnable)null); }); } private static void checkMeteorKey(Player player, JavaPlugin plugin, CommandSender sender, String key, Runnable nextCheck) { player.openAnvil((Location)null, true); String expectedRawKey = LegacyComponentSerializer.legacySection().serialize(Component.translatable(key)); if (player.isOnline()) { Inventory topInventory = player.getOpenInventory().getTopInventory(); if (!(topInventory instanceof AnvilInventory)) { player.closeInventory(); } else { AnvilInventory anvil = (AnvilInventory)topInventory; ItemStack paper = new ItemStack(Material.PAPER); ItemMeta meta = paper.getItemMeta(); if (meta != null) { meta.displayName(Component.translatable(key)); paper.setItemMeta(meta); } anvil.setItem(0, paper); plugin.getServer().getScheduler().runTaskLater(plugin, () -> { if (player.isOnline()) { ItemStack currentResult = anvil.getItem(2); boolean detected = false; if (currentResult != null && currentResult.hasItemMeta() && currentResult.getItemMeta().hasDisplayName()) { String resultName = currentResult.getItemMeta().getDisplayName(); if (!resultName.equals(expectedRawKey)) { detected = true; } } anvil.clear(); player.closeInventory(); String var10001; if (detected) { var10001 = String.valueOf(ChatColor.RED); sender.sendMessage(var10001 + "Người chơi " + player.getName() + " đã được phát hiện sử dụng Meteor Client!"); } else if (nextCheck != null) { nextCheck.run(); } else { var10001 = String.valueOf(ChatColor.GREEN); sender.sendMessage(var10001 + "Người chơi " + player.getName() + " không sử dụng Meteor Client."); } } }, 2L); } } } }