zhdev/griefus
1
0
Fork 0
Code Issues Pull requests Activity

Split up PlayerInteractListener class

Browse source
This commit is contained in:
Intelli 2025-03-07 19:53:19 -07:00
parent d060a6354f
commit 1e32b20f86
7 changed files with 412 additions and 330 deletions
Download patch file Download diff file Expand all files Collapse all files

355
src/main/java/net/coreprotect/listener/player/PlayerInteractListener.java
View file

@ -1,7 +1,5 @@
package net.coreprotect.listener.player; package net.coreprotect.listener.player;
import java.sql.Connection;
import java.sql.Statement;
import java.util.Arrays; import java.util.Arrays;
import java.util.EnumSet; import java.util.EnumSet;
import java.util.List; import java.util.List;
@ -45,13 +43,12 @@ import net.coreprotect.bukkit.BukkitAdapter;
import net.coreprotect.config.Config; import net.coreprotect.config.Config;
import net.coreprotect.config.ConfigHandler; import net.coreprotect.config.ConfigHandler;
import net.coreprotect.consumer.Queue; import net.coreprotect.consumer.Queue;
import net.coreprotect.database.Database;
import net.coreprotect.database.lookup.BlockLookup;
import net.coreprotect.database.lookup.ChestTransactionLookup;
import net.coreprotect.database.lookup.InteractionLookup;
import net.coreprotect.database.lookup.SignMessageLookup;
import net.coreprotect.language.Phrase; import net.coreprotect.language.Phrase;
import net.coreprotect.listener.block.CampfireStartListener; import net.coreprotect.listener.block.CampfireStartListener;
import net.coreprotect.listener.player.inspector.BlockInspector;
import net.coreprotect.listener.player.inspector.ContainerInspector;
import net.coreprotect.listener.player.inspector.InteractionInspector;
import net.coreprotect.listener.player.inspector.SignInspector;
import net.coreprotect.model.BlockGroup; import net.coreprotect.model.BlockGroup;
import net.coreprotect.paper.PaperAdapter; import net.coreprotect.paper.PaperAdapter;
import net.coreprotect.thread.CacheHandler; import net.coreprotect.thread.CacheHandler;
@ -59,7 +56,6 @@ import net.coreprotect.thread.Scheduler;
import net.coreprotect.utility.Chat; import net.coreprotect.utility.Chat;
import net.coreprotect.utility.Color; import net.coreprotect.utility.Color;
import net.coreprotect.utility.ItemUtils; import net.coreprotect.utility.ItemUtils;
import net.coreprotect.utility.Util;
import net.coreprotect.utility.WorldUtils; import net.coreprotect.utility.WorldUtils;
public final class PlayerInteractListener extends Queue implements Listener { public final class PlayerInteractListener extends Queue implements Listener {
@ -67,6 +63,11 @@ public final class PlayerInteractListener extends Queue implements Listener {
public static ConcurrentHashMap<String, Object[]> lastInspectorEvent = new ConcurrentHashMap<>(); public static ConcurrentHashMap<String, Object[]> lastInspectorEvent = new ConcurrentHashMap<>();
public static ConcurrentHashMap<String, Object[]> suspiciousBlockEvent = new ConcurrentHashMap<>(); public static ConcurrentHashMap<String, Object[]> suspiciousBlockEvent = new ConcurrentHashMap<>();
private final BlockInspector blockInspector = new BlockInspector();
private final SignInspector signInspector = new SignInspector();
private final ContainerInspector containerInspector = new ContainerInspector();
private final InteractionInspector interactionInspector = new InteractionInspector();
@EventHandler(priority = EventPriority.LOWEST) @EventHandler(priority = EventPriority.LOWEST)
protected void onPlayerInspect(PlayerInteractEvent event) { protected void onPlayerInspect(PlayerInteractEvent event) {
Player player = event.getPlayer(); Player player = event.getPlayer();
@ -103,86 +104,27 @@ public final class PlayerInteractListener extends Queue implements Listener {
} }
} }
final BlockState blockFinal = checkBlock; blockInspector.performBlockLookup(player, checkBlock);
class BasicThread implements Runnable {
@Override
public void run() {
if (ConfigHandler.converterRunning) {
player.sendMessage(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.UPGRADE_IN_PROGRESS));
return;
}
if (ConfigHandler.purgeRunning) {
player.sendMessage(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.PURGE_IN_PROGRESS));
return;
}
if (ConfigHandler.lookupThrottle.get(player.getName()) != null) {
Object[] lookupThrottle = ConfigHandler.lookupThrottle.get(player.getName());
if ((boolean) lookupThrottle[0] || (System.currentTimeMillis() - (long) lookupThrottle[1]) < 100) {
player.sendMessage(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
return;
}
}
try (Connection connection = Database.getConnection(true)) {
if (connection != null) {
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { true, System.currentTimeMillis() });
Statement statement = connection.createStatement();
String resultData = BlockLookup.performLookup(null, statement, blockFinal, player, 0, 1, 7);
if (resultData.contains("\n")) {
for (String b : resultData.split("\n")) {
Chat.sendComponent(player, b);
}
}
else if (resultData.length() > 0) {
Chat.sendComponent(player, resultData);
}
statement.close();
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { false, System.currentTimeMillis() });
if (blockFinal instanceof Sign && player.getGameMode() != GameMode.CREATIVE) {
Thread.sleep(1500);
Sign sign = (Sign) blockFinal;
player.sendSignChange(sign.getLocation(), sign.getLines(), sign.getColor());
}
}
else {
player.sendMessage(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
}
catch (Exception e) {
e.printStackTrace();
}
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
if (checkBlockData instanceof Bisected) { if (checkBlockData instanceof Bisected) {
int worldMaxHeight = world.getMaxHeight(); PlayerInteractUtils.handleBisectedBlockVisualization(player, event.getClickedBlock(), world);
if (y < (worldMaxHeight - 1)) {
Block y1 = world.getBlockAt(x, y + 1, z);
player.sendBlockChange(y1.getLocation(), y1.getBlockData());
} }
else {
Block block = event.getClickedBlock();
int blockX = block.getX();
int blockY = block.getY();
int blockZ = block.getZ();
int worldMinHeight = BukkitAdapter.ADAPTER.getMinHeight(world); Block x1 = world.getBlockAt(blockX + 1, blockY, blockZ);
if (y > worldMinHeight) { Block x2 = world.getBlockAt(blockX - 1, blockY, blockZ);
Block y2 = world.getBlockAt(x, y - 1, z); Block z1 = world.getBlockAt(blockX, blockY, blockZ + 1);
player.sendBlockChange(y2.getLocation(), y2.getBlockData()); Block z2 = world.getBlockAt(blockX, blockY, blockZ - 1);
}
}
Block x1 = world.getBlockAt(x + 1, y, z);
Block x2 = world.getBlockAt(x - 1, y, z);
Block z1 = world.getBlockAt(x, y, z + 1);
Block z2 = world.getBlockAt(x, y, z - 1);
player.sendBlockChange(x1.getLocation(), x1.getBlockData()); player.sendBlockChange(x1.getLocation(), x1.getBlockData());
player.sendBlockChange(x2.getLocation(), x2.getBlockData()); player.sendBlockChange(x2.getLocation(), x2.getBlockData());
player.sendBlockChange(z1.getLocation(), z1.getBlockData()); player.sendBlockChange(z1.getLocation(), z1.getBlockData());
player.sendBlockChange(z2.getLocation(), z2.getBlockData()); player.sendBlockChange(z2.getLocation(), z2.getBlockData());
}
event.setCancelled(true); event.setCancelled(true);
} }
else if (event.getAction().equals(Action.RIGHT_CLICK_BLOCK)) { else if (event.getAction().equals(Action.RIGHT_CLICK_BLOCK)) {
@ -198,66 +140,7 @@ public final class PlayerInteractListener extends Queue implements Listener {
if (isSignBlock) { if (isSignBlock) {
Location location = clickedBlock.getLocation(); Location location = clickedBlock.getLocation();
signInspector.performSignLookup(player, location);
// sign messages
class BasicThread implements Runnable {
@Override
public void run() {
if (ConfigHandler.converterRunning) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.UPGRADE_IN_PROGRESS));
return;
}
if (ConfigHandler.purgeRunning) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.PURGE_IN_PROGRESS));
return;
}
if (ConfigHandler.lookupThrottle.get(player.getName()) != null) {
Object[] lookupThrottle = ConfigHandler.lookupThrottle.get(player.getName());
if ((boolean) lookupThrottle[0] || (System.currentTimeMillis() - (long) lookupThrottle[1]) < 100) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
return;
}
}
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { true, System.currentTimeMillis() });
try (Connection connection = Database.getConnection(true)) {
if (connection != null) {
Statement statement = connection.createStatement();
List<String> signData = SignMessageLookup.performLookup(null, statement, location, player, 1, 7);
for (String signMessage : signData) {
String bypass = null;
if (signMessage.contains("\n")) {
String[] split = signMessage.split("\n");
signMessage = split[0];
bypass = split[1];
}
if (signMessage.length() > 0) {
Chat.sendComponent(player, signMessage, bypass);
}
}
statement.close();
}
else {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
}
catch (Exception e) {
e.printStackTrace();
}
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { false, System.currentTimeMillis() });
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
event.setCancelled(true); event.setCancelled(true);
} }
else if (isContainerBlock && Config.getConfig(world).ITEM_TRANSACTIONS) { else if (isContainerBlock && Config.getConfig(world).ITEM_TRANSACTIONS) {
@ -279,57 +162,7 @@ public final class PlayerInteractListener extends Queue implements Listener {
location = clickedBlock.getLocation(); location = clickedBlock.getLocation();
} }
Location finalLocation = location; containerInspector.performContainerLookup(player, location);
// logged chest items
class BasicThread implements Runnable {
@Override
public void run() {
if (ConfigHandler.converterRunning) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.UPGRADE_IN_PROGRESS));
return;
}
if (ConfigHandler.purgeRunning) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.PURGE_IN_PROGRESS));
return;
}
if (ConfigHandler.lookupThrottle.get(player.getName()) != null) {
Object[] lookupThrottle = ConfigHandler.lookupThrottle.get(player.getName());
if ((boolean) lookupThrottle[0] || (System.currentTimeMillis() - (long) lookupThrottle[1]) < 100) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
return;
}
}
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { true, System.currentTimeMillis() });
try (Connection connection = Database.getConnection(true)) {
if (connection != null) {
Statement statement = connection.createStatement();
List<String> blockData = ChestTransactionLookup.performLookup(null, statement, finalLocation, player, 1, 7, false);
for (String data : blockData) {
Chat.sendComponent(player, data);
}
statement.close();
}
else {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
}
catch (Exception e) {
e.printStackTrace();
}
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { false, System.currentTimeMillis() });
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
event.setCancelled(true); event.setCancelled(true);
} }
else if (isInteractBlock) { else if (isInteractBlock) {
@ -344,59 +177,7 @@ public final class PlayerInteractListener extends Queue implements Listener {
} }
} }
final Block finalInteractBlock = interactBlock; interactionInspector.performInteractionLookup(player, interactBlock);
class BasicThread implements Runnable {
@Override
public void run() {
if (ConfigHandler.converterRunning) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.UPGRADE_IN_PROGRESS));
return;
}
if (ConfigHandler.purgeRunning) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.PURGE_IN_PROGRESS));
return;
}
if (ConfigHandler.lookupThrottle.get(player.getName()) != null) {
Object[] lookupThrottle = ConfigHandler.lookupThrottle.get(player.getName());
if ((boolean) lookupThrottle[0] || (System.currentTimeMillis() - (long) lookupThrottle[1]) < 100) {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
return;
}
}
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { true, System.currentTimeMillis() });
try (Connection connection = Database.getConnection(true)) {
if (connection != null) {
Statement statement = connection.createStatement();
String blockData = InteractionLookup.performLookup(null, statement, finalInteractBlock, player, 0, 1, 7);
if (blockData.contains("\n")) {
for (String splitData : blockData.split("\n")) {
Chat.sendComponent(player, splitData);
}
}
else {
Chat.sendComponent(player, blockData);
}
statement.close();
}
else {
Chat.sendMessage(player, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
}
catch (Exception e) {
e.printStackTrace();
}
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { false, System.currentTimeMillis() });
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
if (!BlockGroup.SAFE_INTERACT_BLOCKS.contains(type) || player.isSneaking()) { if (!BlockGroup.SAFE_INTERACT_BLOCKS.contains(type) || player.isSneaking()) {
event.setCancelled(true); event.setCancelled(true);
@ -421,76 +202,8 @@ public final class PlayerInteractListener extends Queue implements Listener {
} }
if (performLookup) { if (performLookup) {
final Player finalPlayer = player;
final BlockState finalBlock = event.getClickedBlock().getRelative(event.getBlockFace()).getState(); final BlockState finalBlock = event.getClickedBlock().getRelative(event.getBlockFace()).getState();
blockInspector.performAirBlockLookup(player, finalBlock);
class BasicThread implements Runnable {
@Override
public void run() {
if (ConfigHandler.converterRunning) {
Chat.sendMessage(finalPlayer, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.UPGRADE_IN_PROGRESS));
return;
}
if (ConfigHandler.purgeRunning) {
Chat.sendMessage(finalPlayer, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.PURGE_IN_PROGRESS));
return;
}
if (ConfigHandler.lookupThrottle.get(finalPlayer.getName()) != null) {
Object[] lookupThrottle = ConfigHandler.lookupThrottle.get(finalPlayer.getName());
if ((boolean) lookupThrottle[0] || (System.currentTimeMillis() - (long) lookupThrottle[1]) < 100) {
Chat.sendMessage(finalPlayer, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
return;
}
}
ConfigHandler.lookupThrottle.put(finalPlayer.getName(), new Object[] { true, System.currentTimeMillis() });
try (Connection connection = Database.getConnection(true)) {
if (connection != null) {
Statement statement = connection.createStatement();
if (finalBlock.getType().equals(Material.AIR) || finalBlock.getType().equals(Material.CAVE_AIR)) {
String blockData = BlockLookup.performLookup(null, statement, finalBlock, finalPlayer, 0, 1, 7);
if (blockData.contains("\n")) {
for (String b : blockData.split("\n")) {
Chat.sendComponent(finalPlayer, b);
}
}
else if (blockData.length() > 0) {
Chat.sendComponent(finalPlayer, blockData);
}
}
else {
String blockData = BlockLookup.performLookup(null, statement, finalBlock, finalPlayer, 0, 1, 7);
if (blockData.contains("\n")) {
for (String splitData : blockData.split("\n")) {
Chat.sendComponent(finalPlayer, splitData);
}
}
else if (blockData.length() > 0) {
Chat.sendComponent(finalPlayer, blockData);
}
}
statement.close();
}
else {
Chat.sendMessage(finalPlayer, Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
}
catch (Exception e) {
e.printStackTrace();
}
ConfigHandler.lookupThrottle.put(finalPlayer.getName(), new Object[] { false, System.currentTimeMillis() });
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
ItemUtils.updateInventory(event.getPlayer()); ItemUtils.updateInventory(event.getPlayer());
lastInspectorEvent.put(uuid, new Object[] { systemTime, eventHand }); lastInspectorEvent.put(uuid, new Object[] { systemTime, eventHand });
@ -529,7 +242,7 @@ public final class PlayerInteractListener extends Queue implements Listener {
if (event.useInteractedBlock() != Event.Result.DENY) { if (event.useInteractedBlock() != Event.Result.DENY) {
Block block = event.getClickedBlock(); Block block = event.getClickedBlock();
if (block.getType() == Material.DRAGON_EGG) { if (block.getType() == Material.DRAGON_EGG) {
clickedDragonEgg(event.getPlayer(), block); PlayerInteractUtils.clickedDragonEgg(event.getPlayer(), block);
} }
if (Config.getConfig(world).BLOCK_BREAK) { if (Config.getConfig(world).BLOCK_BREAK) {
@ -797,7 +510,7 @@ public final class PlayerInteractListener extends Queue implements Listener {
} }
} }
else if (type == Material.DRAGON_EGG) { else if (type == Material.DRAGON_EGG) {
clickedDragonEgg(player, block); PlayerInteractUtils.clickedDragonEgg(player, block);
} }
if (isCake || type == Material.CAKE) { if (isCake || type == Material.CAKE) {
@ -944,16 +657,4 @@ public final class PlayerInteractListener extends Queue implements Listener {
} }
} }
} }
private void clickedDragonEgg(Player player, Block block) {
Location location = block.getLocation();
long time = System.currentTimeMillis();
int wid = WorldUtils.getWorldId(location.getWorld().getName());
int x = location.getBlockX();
int y = location.getBlockY();
int z = location.getBlockZ();
String coordinates = x + "." + y + "." + z + "." + wid + "." + Material.DRAGON_EGG.name();
CacheHandler.interactCache.put(coordinates, new Object[] { time, Material.DRAGON_EGG, player.getName() });
}
} }

55
src/main/java/net/coreprotect/listener/player/PlayerInteractUtils.java Normal file
View file

@ -0,0 +1,55 @@
package net.coreprotect.listener.player;
import org.bukkit.Location;
import org.bukkit.Material;
import org.bukkit.World;
import org.bukkit.block.Block;
import org.bukkit.entity.Player;
import net.coreprotect.thread.CacheHandler;
import net.coreprotect.utility.WorldUtils;
public final class PlayerInteractUtils {
private PlayerInteractUtils() {
// Utility class, prevent instantiation
}
public static void clickedDragonEgg(Player player, Block block) {
Location location = block.getLocation();
long time = System.currentTimeMillis();
int wid = WorldUtils.getWorldId(location.getWorld().getName());
int x = location.getBlockX();
int y = location.getBlockY();
int z = location.getBlockZ();
String coordinates = x + "." + y + "." + z + "." + wid + "." + Material.DRAGON_EGG.name();
CacheHandler.interactCache.put(coordinates, new Object[] { time, Material.DRAGON_EGG, player.getName() });
}
public static void handleBisectedBlockVisualization(Player player, Block block, World world) {
int x = block.getX();
int y = block.getY();
int z = block.getZ();
int worldMaxHeight = world.getMaxHeight();
if (y < (worldMaxHeight - 1)) {
Block y1 = world.getBlockAt(x, y + 1, z);
player.sendBlockChange(y1.getLocation(), y1.getBlockData());
}
int worldMinHeight = net.coreprotect.bukkit.BukkitAdapter.ADAPTER.getMinHeight(world);
if (y > worldMinHeight) {
Block y2 = world.getBlockAt(x, y - 1, z);
player.sendBlockChange(y2.getLocation(), y2.getBlockData());
}
Block x1 = world.getBlockAt(x + 1, y, z);
Block x2 = world.getBlockAt(x - 1, y, z);
Block z1 = world.getBlockAt(x, y, z + 1);
Block z2 = world.getBlockAt(x, y, z - 1);
player.sendBlockChange(x1.getLocation(), x1.getBlockData());
player.sendBlockChange(x2.getLocation(), x2.getBlockData());
player.sendBlockChange(z1.getLocation(), z1.getBlockData());
player.sendBlockChange(z2.getLocation(), z2.getBlockData());
}
}

53
src/main/java/net/coreprotect/listener/player/inspector/BaseInspector.java Normal file
View file

@ -0,0 +1,53 @@
package net.coreprotect.listener.player.inspector;
import java.sql.Connection;
import org.bukkit.entity.Player;
import net.coreprotect.config.ConfigHandler;
import net.coreprotect.database.Database;
import net.coreprotect.language.Phrase;
import net.coreprotect.utility.Color;
public abstract class BaseInspector {
protected void checkPreconditions(Player player) throws InspectionException {
if (ConfigHandler.converterRunning) {
throw new InspectionException(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.UPGRADE_IN_PROGRESS));
}
if (ConfigHandler.purgeRunning) {
throw new InspectionException(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.PURGE_IN_PROGRESS));
}
if (ConfigHandler.lookupThrottle.get(player.getName()) != null) {
Object[] lookupThrottle = ConfigHandler.lookupThrottle.get(player.getName());
if ((boolean) lookupThrottle[0] || (System.currentTimeMillis() - (long) lookupThrottle[1]) < 100) {
throw new InspectionException(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
}
}
protected Connection getDatabaseConnection(Player player) throws Exception {
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { true, System.currentTimeMillis() });
Connection connection = Database.getConnection(true);
if (connection == null) {
throw new InspectionException(Color.DARK_AQUA + "CoreProtect " + Color.WHITE + "- " + Phrase.build(Phrase.DATABASE_BUSY));
}
return connection;
}
protected void finishInspection(Player player) {
ConfigHandler.lookupThrottle.put(player.getName(), new Object[] { false, System.currentTimeMillis() });
}
public static class InspectionException extends Exception {
private static final long serialVersionUID = 1L;
public InspectionException(String message) {
super(message);
}
}
}

114
src/main/java/net/coreprotect/listener/player/inspector/BlockInspector.java Normal file
View file

@ -0,0 +1,114 @@
package net.coreprotect.listener.player.inspector;
import java.sql.Connection;
import java.sql.Statement;
import org.bukkit.GameMode;
import org.bukkit.block.BlockState;
import org.bukkit.block.Sign;
import org.bukkit.entity.Player;
import net.coreprotect.database.lookup.BlockLookup;
import net.coreprotect.utility.Chat;
public class BlockInspector extends BaseInspector {
public void performBlockLookup(final Player player, final BlockState blockState) {
class BasicThread implements Runnable {
@Override
public void run() {
try {
checkPreconditions(player);
try (Connection connection = getDatabaseConnection(player)) {
Statement statement = connection.createStatement();
String resultData = BlockLookup.performLookup(null, statement, blockState, player, 0, 1, 7);
if (resultData.contains("\n")) {
for (String b : resultData.split("\n")) {
Chat.sendComponent(player, b);
}
}
else if (resultData.length() > 0) {
Chat.sendComponent(player, resultData);
}
statement.close();
if (blockState instanceof Sign && player.getGameMode() != GameMode.CREATIVE) {
Thread.sleep(1500);
Sign sign = (Sign) blockState;
player.sendSignChange(sign.getLocation(), sign.getLines(), sign.getColor());
}
}
}
catch (InspectionException e) {
Chat.sendMessage(player, e.getMessage());
}
catch (Exception e) {
e.printStackTrace();
}
finally {
finishInspection(player);
}
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
}
public void performAirBlockLookup(final Player player, final BlockState finalBlock) {
class BasicThread implements Runnable {
@Override
public void run() {
try {
checkPreconditions(player);
try (Connection connection = getDatabaseConnection(player)) {
Statement statement = connection.createStatement();
if (finalBlock.getType().name().endsWith("AIR")) {
String blockData = BlockLookup.performLookup(null, statement, finalBlock, player, 0, 1, 7);
if (blockData.contains("\n")) {
for (String b : blockData.split("\n")) {
Chat.sendComponent(player, b);
}
}
else if (blockData.length() > 0) {
Chat.sendComponent(player, blockData);
}
}
else {
String blockData = BlockLookup.performLookup(null, statement, finalBlock, player, 0, 1, 7);
if (blockData.contains("\n")) {
for (String splitData : blockData.split("\n")) {
Chat.sendComponent(player, splitData);
}
}
else if (blockData.length() > 0) {
Chat.sendComponent(player, blockData);
}
}
statement.close();
}
}
catch (InspectionException e) {
Chat.sendMessage(player, e.getMessage());
}
catch (Exception e) {
e.printStackTrace();
}
finally {
finishInspection(player);
}
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
}
}

48
src/main/java/net/coreprotect/listener/player/inspector/ContainerInspector.java Normal file
View file

@ -0,0 +1,48 @@
package net.coreprotect.listener.player.inspector;
import java.sql.Connection;
import java.sql.Statement;
import java.util.List;
import org.bukkit.Location;
import org.bukkit.entity.Player;
import net.coreprotect.database.lookup.ChestTransactionLookup;
import net.coreprotect.utility.Chat;
public class ContainerInspector extends BaseInspector {
public void performContainerLookup(final Player player, final Location finalLocation) {
class BasicThread implements Runnable {
@Override
public void run() {
try {
checkPreconditions(player);
try (Connection connection = getDatabaseConnection(player)) {
Statement statement = connection.createStatement();
List<String> blockData = ChestTransactionLookup.performLookup(null, statement, finalLocation, player, 1, 7, false);
for (String data : blockData) {
Chat.sendComponent(player, data);
}
statement.close();
}
}
catch (InspectionException e) {
Chat.sendMessage(player, e.getMessage());
}
catch (Exception e) {
e.printStackTrace();
}
finally {
finishInspection(player);
}
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
}
}

53
src/main/java/net/coreprotect/listener/player/inspector/InteractionInspector.java Normal file
View file

@ -0,0 +1,53 @@
package net.coreprotect.listener.player.inspector;
import java.sql.Connection;
import java.sql.Statement;
import org.bukkit.block.Block;
import org.bukkit.entity.Player;
import net.coreprotect.database.lookup.InteractionLookup;
import net.coreprotect.utility.Chat;
public class InteractionInspector extends BaseInspector {
public void performInteractionLookup(final Player player, final Block finalInteractBlock) {
class BasicThread implements Runnable {
@Override
public void run() {
try {
checkPreconditions(player);
try (Connection connection = getDatabaseConnection(player)) {
Statement statement = connection.createStatement();
String blockData = InteractionLookup.performLookup(null, statement, finalInteractBlock, player, 0, 1, 7);
if (blockData.contains("\n")) {
for (String splitData : blockData.split("\n")) {
Chat.sendComponent(player, splitData);
}
}
else {
Chat.sendComponent(player, blockData);
}
statement.close();
}
}
catch (InspectionException e) {
Chat.sendMessage(player, e.getMessage());
}
catch (Exception e) {
e.printStackTrace();
}
finally {
finishInspection(player);
}
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
}
}

58
src/main/java/net/coreprotect/listener/player/inspector/SignInspector.java Normal file
View file

@ -0,0 +1,58 @@
package net.coreprotect.listener.player.inspector;
import java.sql.Connection;
import java.sql.Statement;
import java.util.List;
import org.bukkit.Location;
import org.bukkit.entity.Player;
import net.coreprotect.database.lookup.SignMessageLookup;
import net.coreprotect.utility.Chat;
public class SignInspector extends BaseInspector {
public void performSignLookup(final Player player, final Location location) {
class BasicThread implements Runnable {
@Override
public void run() {
try {
checkPreconditions(player);
try (Connection connection = getDatabaseConnection(player)) {
Statement statement = connection.createStatement();
List<String> signData = SignMessageLookup.performLookup(null, statement, location, player, 1, 7);
for (String signMessage : signData) {
String bypass = null;
if (signMessage.contains("\n")) {
String[] split = signMessage.split("\n");
signMessage = split[0];
bypass = split[1];
}
if (signMessage.length() > 0) {
Chat.sendComponent(player, signMessage, bypass);
}
}
statement.close();
}
}
catch (InspectionException e) {
Chat.sendMessage(player, e.getMessage());
}
catch (Exception e) {
e.printStackTrace();
}
finally {
finishInspection(player);
}
}
}
Runnable runnable = new BasicThread();
Thread thread = new Thread(runnable);
thread.start();
}
}