103 lines
4.7 KiB
Java
103 lines
4.7 KiB
Java
package net.coreprotect.listener.player;
|
|
|
|
import java.util.Arrays;
|
|
import java.util.HashSet;
|
|
import java.util.List;
|
|
import java.util.Set;
|
|
|
|
import org.bukkit.Location;
|
|
import org.bukkit.inventory.Inventory;
|
|
import org.bukkit.inventory.InventoryHolder;
|
|
import org.bukkit.inventory.ItemStack;
|
|
|
|
import net.coreprotect.CoreProtect;
|
|
import net.coreprotect.config.Config;
|
|
import net.coreprotect.config.ConfigHandler;
|
|
import net.coreprotect.thread.Scheduler;
|
|
import net.coreprotect.utility.Util;
|
|
|
|
public final class HopperPullListener {
|
|
|
|
static void processHopperPull(Location location, InventoryHolder sourceHolder, InventoryHolder destinationHolder, ItemStack item) {
|
|
String loggingChestId = "#hopper-pull." + location.getBlockX() + "." + location.getBlockY() + "." + location.getBlockZ();
|
|
Object[] lastAbort = ConfigHandler.hopperAbort.get(loggingChestId);
|
|
if (lastAbort != null) {
|
|
ItemStack[] destinationContents = destinationHolder.getInventory().getContents();
|
|
if (((Set<?>) lastAbort[0]).contains(item) && Arrays.equals(destinationContents, (ItemStack[]) lastAbort[1])) {
|
|
return;
|
|
}
|
|
}
|
|
|
|
ItemStack[] destinationContainer = Util.getContainerState(destinationHolder.getInventory().getContents());
|
|
ItemStack movedItem = item.clone();
|
|
|
|
final long taskStarted = InventoryChangeListener.tasksStarted.incrementAndGet();
|
|
Scheduler.runTaskAsynchronously(CoreProtect.getInstance(), () -> {
|
|
try {
|
|
if (sourceHolder == null || destinationHolder == null) {
|
|
return;
|
|
}
|
|
|
|
boolean abort = false;
|
|
boolean addedInventory = Util.canAddContainer(destinationContainer, movedItem, destinationHolder.getInventory().getMaxStackSize());
|
|
if (!addedInventory) {
|
|
abort = true;
|
|
}
|
|
|
|
if (abort) {
|
|
Set<ItemStack> movedItems = new HashSet<>();
|
|
ItemStack[] destinationContents = destinationHolder.getInventory().getContents();
|
|
if (lastAbort != null && Arrays.equals(destinationContents, (ItemStack[]) lastAbort[1])) {
|
|
((Set<?>) lastAbort[0]).forEach(itemStack -> movedItems.add((ItemStack) itemStack));
|
|
}
|
|
movedItems.add(movedItem);
|
|
|
|
ConfigHandler.hopperAbort.put(loggingChestId, new Object[] { movedItems, Util.getContainerState(destinationContents) });
|
|
return;
|
|
}
|
|
|
|
if (ConfigHandler.hopperAbort.get(loggingChestId) != null) {
|
|
ConfigHandler.hopperAbort.remove(loggingChestId);
|
|
}
|
|
|
|
boolean hopperTransactions = Config.getConfig(location.getWorld()).HOPPER_TRANSACTIONS;
|
|
if (!hopperTransactions) {
|
|
List<Object> list = ConfigHandler.transactingChest.get(location.getWorld().getUID().toString() + "." + location.getBlockX() + "." + location.getBlockY() + "." + location.getBlockZ());
|
|
if (list != null) {
|
|
list.add(movedItem);
|
|
}
|
|
return;
|
|
}
|
|
|
|
Location destinationLocation = destinationHolder.getInventory().getLocation();
|
|
List<Object> list = ConfigHandler.transactingChest.get(destinationLocation.getWorld().getUID().toString() + "." + destinationLocation.getBlockX() + "." + destinationLocation.getBlockY() + "." + destinationLocation.getBlockZ());
|
|
if (list != null) {
|
|
list.add(new ItemStack[] { null, movedItem });
|
|
}
|
|
|
|
if (Config.getConfig(location.getWorld()).HOPPER_FILTER_META && !movedItem.hasItemMeta()) {
|
|
return;
|
|
}
|
|
|
|
Inventory sourceInventory = sourceHolder.getInventory();
|
|
ItemStack[] inventoryContents = sourceInventory.getContents();
|
|
ItemStack[] originalSource = new ItemStack[inventoryContents.length + 1];
|
|
for (int i = 0; i < inventoryContents.length; i++) {
|
|
ItemStack itemStack = inventoryContents[i];
|
|
if (itemStack != null) {
|
|
originalSource[i] = itemStack.clone();
|
|
}
|
|
}
|
|
|
|
originalSource[inventoryContents.length] = movedItem;
|
|
InventoryChangeListener.checkTasks(taskStarted);
|
|
InventoryChangeListener.onInventoryInteract("#hopper", sourceInventory, originalSource, null, sourceInventory.getLocation(), true);
|
|
}
|
|
catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
});
|
|
}
|
|
|
|
}
|