package com.rivaria.slotmachine.manager; import com.rivaria.slotmachine.SlotMachinePlugin; import com.cryptomorin.xseries.XSound; import net.milkbowl.vault.economy.Economy; import net.milkbowl.vault.economy.EconomyResponse; import org.bukkit.Location; import org.bukkit.block.Block; import org.bukkit.block.Sign; import org.bukkit.configuration.file.FileConfiguration; import org.bukkit.configuration.file.YamlConfiguration; import org.bukkit.entity.Player; import org.bukkit.scheduler.BukkitRunnable; import java.io.File; import java.io.IOException; import java.util.HashMap; import java.util.Map; import java.util.Random; import java.util.UUID; public class SlotMachineManager { // Each phase lasts PHASE_TICKS scheduler ticks between frames. // Phase 0 (steps 0-5): all three digits rolling // Phase 1 (steps 6-11): digit 1 locked, 2 & 3 still roll // Phase 2 (steps 12-16): digits 1 & 2 locked, 3 still rolls // Step 17: final reveal, payout, cancel static final int TICKS_PER_STEP = 4; static final int TOTAL_STEPS = 18; static final int COOLDOWN_MS = 2000; final SlotMachinePlugin plugin; final Map slotSigns = new HashMap<>(); final Map cooldowns = new HashMap<>(); final Map spinning = new HashMap<>(); final Random random = new Random(); File dataFile; FileConfiguration dataConfig; public SlotMachineManager(SlotMachinePlugin plugin) { this.plugin = plugin; } // ─── Persistence ───────────────────────────────────────────────────────────── public void loadSigns() { dataFile = new File(plugin.getDataFolder(), "data.yml"); if (!dataFile.exists()) { plugin.getDataFolder().mkdirs(); try { dataFile.createNewFile(); } catch (IOException ignored) {} } dataConfig = YamlConfiguration.loadConfiguration(dataFile); if (dataConfig.contains("slots")) { for (String key : dataConfig.getConfigurationSection("slots").getKeys(false)) { double bet = dataConfig.getDouble("slots." + key + ".bet"); slotSigns.put(key, bet); } } plugin.getLogger().info("Loaded " + slotSigns.size() + " slot machine sign(s)."); } public void saveSigns() { if (dataConfig == null) return; dataConfig.set("slots", null); for (Map.Entry entry : slotSigns.entrySet()) { dataConfig.set("slots." + entry.getKey() + ".bet", entry.getValue()); } try { dataConfig.save(dataFile); } catch (IOException e) { plugin.getLogger().warning("Could not save slot machine data: " + e.getMessage()); } } // ─── Registration ───────────────────────────────────────────────────────────── public void registerSign(Location loc, double betAmount) { slotSigns.put(locKey(loc), betAmount); saveSigns(); } public void unregisterSign(Location loc) { slotSigns.remove(locKey(loc)); saveSigns(); } public boolean isSlotSign(Location loc) { return slotSigns.containsKey(locKey(loc)); } // ─── Activation ─────────────────────────────────────────────────────────────── public void activateSlot(Player player, Location loc) { String key = locKey(loc); long now = System.currentTimeMillis(); Long last = cooldowns.get(player.getUniqueId()); if (last != null && now - last < COOLDOWN_MS) { long remaining = (COOLDOWN_MS - (now - last)) / 1000 + 1; player.sendMessage("§c§l[RIVARIA] §cPlease wait §e" + remaining + "s §cbefore spinning again."); return; } if (spinning.getOrDefault(key, false)) { player.sendMessage("§c§l[RIVARIA] §cThis slot machine is already spinning!"); return; } double bet = slotSigns.get(key); Economy economy = plugin.getEconomy(); if (!economy.has(player, bet)) { player.sendMessage("§c§l[RIVARIA] §cYou need §e" + formatAmount(bet) + " §cto spin this slot machine!"); return; } EconomyResponse response = economy.withdrawPlayer(player, bet); if (!response.transactionSuccess()) { player.sendMessage("§c§l[RIVARIA] §cTransaction failed. Please try again."); return; } cooldowns.put(player.getUniqueId(), now); spinning.put(key, true); final int finalD1 = random.nextInt(10); final int finalD2 = random.nextInt(10); final int finalD3 = random.nextInt(10); new SpinRunnable(player, loc, key, bet, finalD1, finalD2, finalD3) .runTaskTimer(plugin, 0L, TICKS_PER_STEP); } // ─── Named runnable (avoids anonymous inner-class access issues) ────────────── class SpinRunnable extends BukkitRunnable { private final Player player; private final Location loc; private final String key; private final double bet; private final int finalD1, finalD2, finalD3; private int step = 0; SpinRunnable(Player player, Location loc, String key, double bet, int d1, int d2, int d3) { this.player = player; this.loc = loc; this.key = key; this.bet = bet; this.finalD1 = d1; this.finalD2 = d2; this.finalD3 = d3; } @Override public void run() { // Safety guard: never exceed intended steps if (step >= TOTAL_STEPS) { spinning.put(key, false); cancel(); return; } Block block = loc.getBlock(); if (!(block.getState() instanceof Sign sign)) { spinning.put(key, false); cancel(); return; } if (step < TOTAL_STEPS - 1) { // Rolling animation frame String s1, s2, s3; if (step < 6) { s1 = String.valueOf(random.nextInt(10)); s2 = String.valueOf(random.nextInt(10)); s3 = String.valueOf(random.nextInt(10)); } else if (step < 12) { s1 = String.valueOf(finalD1); s2 = String.valueOf(random.nextInt(10)); s3 = String.valueOf(random.nextInt(10)); } else { s1 = String.valueOf(finalD1); s2 = String.valueOf(finalD2); s3 = String.valueOf(random.nextInt(10)); } sign.setLine(1, "§f§l" + s1 + " " + s2 + " " + s3); sign.setLine(3, "§6§l\u27F3 SPINNING..."); sign.update(); // Lever click with rising pitch (0.8 → 1.6 across 17 steps) float pitch = 0.8f + (step / (float)(TOTAL_STEPS - 2)) * 0.8f; playTickSound(pitch); step++; } else { // Final frame — individually color matching digits purple sign.setLine(1, buildColoredDisplay(finalD1, finalD2, finalD3)); sign.setLine(3, "§a§l§nCLICK TO PLAY"); sign.update(); spinning.put(key, false); handlePayout(player, bet, finalD1, finalD2, finalD3); cancel(); } } private void playTickSound(float pitch) { XSound.matchXSound("BLOCK_LEVER_CLICK").ifPresent(xs -> player.playSound(player.getLocation(), xs.parseSound(), 0.7f, pitch)); } } // ─── Display formatting ─────────────────────────────────────────────────────── /** * Colors each digit individually: purple (§5§l) if it is part of a matching * pair, white (§f§l) otherwise. §r resets between digits so colors don't bleed. * * Examples: * 606 → §5§l6 §r§f§l0 §r§5§l6 (the two 6s go purple, 0 stays white) * 770 → §5§l7 §r§5§l7 §r§f§l0 (both 7s purple, 0 white) * 777 → all three purple * 123 → all three white */ String buildColoredDisplay(int d1, int d2, int d3) { boolean matchD1 = (d1 == d2) || (d1 == d3); boolean matchD2 = (d1 == d2) || (d2 == d3); boolean matchD3 = (d1 == d3) || (d2 == d3); String c1 = matchD1 ? "§5§l" : "§f§l"; String c2 = matchD2 ? "§5§l" : "§f§l"; String c3 = matchD3 ? "§5§l" : "§f§l"; return c1 + d1 + " §r" + c2 + d2 + " §r" + c3 + d3; } // ─── Payout ─────────────────────────────────────────────────────────────────── void handlePayout(Player player, double bet, int d1, int d2, int d3) { double multiplier = calculateMultiplier(d1, d2, d3); if (multiplier > 0) { double winnings = bet * multiplier; plugin.getEconomy().depositPlayer(player, winnings); String reason = getWinReason(d1, d2, d3, multiplier); player.sendMessage("§a§l[RIVARIA] §aYou won §e" + formatAmount(winnings) + "§a! §7(" + reason + ")"); XSound.matchXSound("ENTITY_PLAYER_LEVELUP") .ifPresent(xs -> player.playSound(player.getLocation(), xs.parseSound(), 1.0f, 1.0f)); } else { player.sendMessage("§c§l[RIVARIA] §cBetter luck next time! You lost §e" + formatAmount(bet) + "§c."); XSound.matchXSound("BLOCK_NOTE_BLOCK_BASS") .ifPresent(xs -> player.playSound(player.getLocation(), xs.parseSound(), 1.0f, 0.5f)); } } double calculateMultiplier(int d1, int d2, int d3) { if (d1 == 7 && d2 == 7 && d3 == 7) return 50; if (d1 == d2 && d2 == d3) return 10; if ((d1 == d2 && (d1 == 7)) || (d1 == d3 && (d1 == 7)) || (d2 == d3 && (d2 == 7))) return 10; if (d1 == d2 || d1 == d3 || d2 == d3) return 3; return 0; } String getWinReason(int d1, int d2, int d3, double multiplier) { if (multiplier == 50) return "§6§lJACKPOT 777!"; if (multiplier == 10 && d1 == d2 && d2 == d3) return "Triple " + d1 + "!"; if (multiplier == 10) return "Pair of 7s!"; return "Pair!"; } // ─── Utilities ──────────────────────────────────────────────────────────────── String locKey(Location loc) { return loc.getWorld().getName() + "," + loc.getBlockX() + "," + loc.getBlockY() + "," + loc.getBlockZ(); } String formatAmount(double amount) { if (amount == Math.floor(amount)) return String.valueOf((long) amount); return String.valueOf(amount); } }