package com.alttd.altitudequests.objects.quests; import com.alttd.altitudequests.config.Config; import com.alttd.altitudequests.config.QuestsConfig; import com.alttd.altitudequests.database.Database; import com.alttd.altitudequests.objects.Variant; import com.alttd.altitudequests.objects.variants.MineQuestObject; import com.alttd.altitudequests.objects.Quest; import com.alttd.altitudequests.util.Logger; import com.alttd.altitudequests.util.Utilities; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.minimessage.MiniMessage; import net.kyori.adventure.text.minimessage.tag.resolver.Placeholder; import net.kyori.adventure.text.minimessage.tag.resolver.TagResolver; import org.bukkit.block.Block; import org.bukkit.block.data.BlockData; import org.bukkit.block.data.Ageable; import org.bukkit.entity.Player; import org.bukkit.inventory.PlayerInventory; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.*; import java.util.stream.Collectors; public class MineQuest extends Quest { private final MineQuestObject mineQuestObject; public MineQuest(UUID uuid) { super(uuid, 0, 0, QuestsConfig.MINE_QUESTS.get(Utilities.randomOr0(QuestsConfig.MINE_QUESTS.size() - 1)), -1, false); if (getVariant() instanceof MineQuestObject mineQuestObject) this.mineQuestObject = mineQuestObject; else mineQuestObject = null; if (mineQuestObject == null) { Logger.warning("Tried to create MineQuest but unable to find variant: %.", "unknown"); return; } } public MineQuest(UUID uuid, int mined, int turnedIn, String variant, int amount, boolean rewardReceived) { super(uuid, mined, turnedIn, QuestsConfig.MINE_QUESTS.stream() .filter(object -> variant.equals(object.getInternalName())) .findAny().orElse(null), amount, rewardReceived); if (getVariant() instanceof MineQuestObject mineQuestObject) this.mineQuestObject = mineQuestObject; else this.mineQuestObject = null; if (mineQuestObject == null) { Logger.warning("Tried to create MineQuest but unable to find variant: %.", variant); Logger.warning("Possible variants: %", QuestsConfig.MINE_QUESTS.stream().map(Variant::getInternalName).collect(Collectors.joining(", "))); return; } checkDone(); } @Override public void save() { String sql = "INSERT INTO generic_quest_progress " + "(year_day, uuid, quest, quest_variant, step_1_progress, step_2_progress, amount, reward_received) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE " + "quest = ?, quest_variant = ?, step_1_progress = ?, step_2_progress = ?, year_day = ?, amount = ?, reward_received = ?"; try { PreparedStatement statement = Database.getDatabase().getConnection().prepareStatement(sql); int yearDay = Utilities.getYearDay(); if (Config.DEBUG) Logger.info("Saving user for year day %.", String.valueOf(yearDay)); statement.setInt(1, yearDay); statement.setString(2, getUuid().toString()); statement.setString(3, this.getClass().getSimpleName()); statement.setString(4, mineQuestObject.getInternalName()); statement.setInt(5, getStep1()); statement.setInt(6, getStep2()); statement.setInt(7, getAmount()); statement.setInt(8, isRewardReceived() ? 1 : 0); statement.setString(9, this.getClass().getSimpleName()); statement.setString(10, mineQuestObject.getInternalName()); statement.setInt(11, getStep1()); statement.setInt(12, getStep2()); statement.setInt(13, yearDay); statement.setInt(14, getAmount()); statement.setInt(15, isRewardReceived() ? 1 : 0); statement.execute(); } catch (SQLException exception) { exception.printStackTrace(); } } @Override public TagResolver getTagResolvers() { TagResolver resolver = TagResolver.resolver( Placeholder.unparsed("block", Utilities.formatName(mineQuestObject.getTurnInMaterial().name())), Placeholder.parsed("step_1_progress", getStep1() == getAmount() ? "" + getStep1() + "" : "" + getStep1() + ""), Placeholder.parsed("step_1_total", String.valueOf(getAmount())), Placeholder.parsed("step_2_progress", getStep2() == getAmount() ? "" + getStep2() + "" : "" + getStep2() + ""), Placeholder.parsed("step_2_total", String.valueOf(getAmount())), Placeholder.unparsed("step_1", QuestsConfig.MINE_STEP_1), Placeholder.unparsed("step_2", QuestsConfig.MINE_STEP_2) ); Component turnInText = MiniMessage.miniMessage().deserialize(QuestsConfig.MINE_TURN_IN, resolver); return TagResolver.resolver( resolver, Placeholder.component("turn_in_text", turnInText) ); } @Override public int turnIn(Player player) { PlayerInventory inventory = player.getInventory(); int maxToTurnIn = getMaxToTurnIn(); if (maxToTurnIn == 0) return 0; var ref = new Object() { int tmpAmount = maxToTurnIn; }; Arrays.stream(inventory.getContents()) .filter(Objects::nonNull) .filter(itemStack -> itemStack.getType().equals(mineQuestObject.getTurnInMaterial())) .forEach(itemStack -> { if (ref.tmpAmount == 0) return; if (itemStack.getAmount() > ref.tmpAmount) { itemStack.setAmount(itemStack.getAmount() - ref.tmpAmount); ref.tmpAmount = 0; } else { ref.tmpAmount -= itemStack.getAmount(); itemStack.setAmount(0); } }); int totalTurnedIn = maxToTurnIn - ref.tmpAmount; addStep2(totalTurnedIn); checkDone(player); return totalTurnedIn; } @Override public Component getDisplayName() { return MiniMessage.miniMessage().deserialize(QuestsConfig.MINE_QUEST_NAME); } @Override public List getRewardCommand() { return QuestsConfig.MINE_COMMANDS; } public boolean checkBlock(Block block) { //this can probably be simplified but I didn't realy know how BlockData blockData = block.getBlockData(); if (!block.getType().equals(mineQuestObject.getMaterial())) { return true; } else if (blockData instanceof Ageable) { Ageable ageable = (Ageable) blockData; if (ageable.getAge() != ageable.getMaximumAge()) { return true; } } return false; } public void mine(Block block) { if (isDone() || checkBlock(block) || getAmount() == getStep1()) return; addStep1(1); checkDone(); } public static List getSubTypes() { return QuestsConfig.MINE_QUESTS.stream().map(Variant::getInternalName).collect(Collectors.toList()); } }