package com.epicsmp.core.managers; import com.epicsmp.core.EpicSMPCore; import com.epicsmp.core.data.*; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.reflect.TypeToken; import org.bukkit.Bukkit; import java.io.*; import java.lang.reflect.Type; import java.nio.file.Files; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentHashMap; import java.util.logging.Level; /** * Thread-safe JSON-based data persistence manager. * Handles Economy, Homes, Bans, Stats with async save/load. */ public class DataManager { private static DataManager instance; private final EpicSMPCore plugin; private final Gson gson; private final File dataFolder; // Thread-safe data stores private final Map economyData; private final Map homesData; private final Map banData; private final Map statsData; private final List adminLogs; // File paths private File economyFile; private File homesFile; private File banFile; private File statsFile; private File logsFile; private DataManager(EpicSMPCore plugin) { this.plugin = plugin; this.gson = new GsonBuilder().setPrettyPrinting().create(); this.dataFolder = plugin.getDataFolder(); // Initialize concurrent maps this.economyData = new ConcurrentHashMap<>(); this.homesData = new ConcurrentHashMap<>(); this.banData = new ConcurrentHashMap<>(); this.statsData = new ConcurrentHashMap<>(); this.adminLogs = Collections.synchronizedList(new ArrayList<>()); initializeFiles(); loadAllData(); } public static DataManager getInstance(EpicSMPCore plugin) { if (instance == null) { instance = new DataManager(plugin); } return instance; } public static DataManager getInstance() { return instance; } /** * Initialize data folder and JSON files */ private void initializeFiles() { if (!dataFolder.exists()) { dataFolder.mkdirs(); } economyFile = new File(dataFolder, "economy.json"); homesFile = new File(dataFolder, "homes.json"); banFile = new File(dataFolder, "bans.json"); statsFile = new File(dataFolder, "stats.json"); logsFile = new File(dataFolder, "logs.txt"); try { if (!economyFile.exists()) economyFile.createNewFile(); if (!homesFile.exists()) homesFile.createNewFile(); if (!banFile.exists()) banFile.createNewFile(); if (!statsFile.exists()) statsFile.createNewFile(); if (!logsFile.exists()) logsFile.createNewFile(); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to create data files", e); } } /** * Load all data from JSON files (synchronous on startup) */ private void loadAllData() { loadEconomyData(); loadHomesData(); loadBanData(); loadStatsData(); loadAdminLogs(); StyleManager.logSuccess("Loaded all player data successfully"); } /** * ECONOMY DATA */ private void loadEconomyData() { try (Reader reader = new FileReader(economyFile)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { economyData.putAll(loaded); StyleManager.logInfo("Loaded " + loaded.size() + " economy records"); } } catch (Exception e) { StyleManager.logWarning("No existing economy data found, starting fresh"); } } public PlayerEconomyData getEconomyData(UUID uuid) { return economyData.computeIfAbsent(uuid, k -> new PlayerEconomyData(uuid)); } public void saveEconomyDataAsync() { CompletableFuture.runAsync(() -> { try (Writer writer = new FileWriter(economyFile)) { gson.toJson(economyData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save economy data", e); } }); } /** * HOMES DATA */ private void loadHomesData() { try (Reader reader = new FileReader(homesFile)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { homesData.putAll(loaded); StyleManager.logInfo("Loaded " + loaded.size() + " homes records"); } } catch (Exception e) { StyleManager.logWarning("No existing homes data found, starting fresh"); } } public PlayerHomesData getHomesData(UUID uuid) { return homesData.computeIfAbsent(uuid, k -> new PlayerHomesData(uuid)); } public void saveHomesDataAsync() { CompletableFuture.runAsync(() -> { try (Writer writer = new FileWriter(homesFile)) { gson.toJson(homesData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save homes data", e); } }); } /** * BAN DATA */ private void loadBanData() { try (Reader reader = new FileReader(banFile)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { banData.putAll(loaded); StyleManager.logInfo("Loaded " + loaded.size() + " ban records"); } } catch (Exception e) { StyleManager.logWarning("No existing ban data found, starting fresh"); } } public PlayerBanData getBanData(UUID uuid) { return banData.get(uuid); } public void setBanData(UUID uuid, PlayerBanData data) { if (data == null) { banData.remove(uuid); } else { banData.put(uuid, data); } saveBanDataAsync(); } public boolean isBanned(UUID uuid) { PlayerBanData data = banData.get(uuid); if (data == null) return false; // Check if temp ban expired if (data.isTemporary() && System.currentTimeMillis() > data.getExpiresAt()) { banData.remove(uuid); saveBanDataAsync(); return false; } return true; } public void saveBanDataAsync() { CompletableFuture.runAsync(() -> { try (Writer writer = new FileWriter(banFile)) { gson.toJson(banData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save ban data", e); } }); } /** * STATS DATA */ private void loadStatsData() { try (Reader reader = new FileReader(statsFile)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { statsData.putAll(loaded); StyleManager.logInfo("Loaded " + loaded.size() + " stats records"); } } catch (Exception e) { StyleManager.logWarning("No existing stats data found, starting fresh"); } } public PlayerStatsData getStatsData(UUID uuid) { return statsData.computeIfAbsent(uuid, k -> new PlayerStatsData(uuid)); } public void saveStatsDataAsync() { CompletableFuture.runAsync(() -> { try (Writer writer = new FileWriter(statsFile)) { gson.toJson(statsData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save stats data", e); } }); } /** * ADMIN LOGS */ private void loadAdminLogs() { try { if (logsFile.exists()) { List lines = Files.readAllLines(logsFile.toPath()); adminLogs.addAll(lines); StyleManager.logInfo("Loaded " + lines.size() + " admin log entries"); } } catch (IOException e) { StyleManager.logWarning("Could not load admin logs"); } } public void logAdminAction(String action) { String timestamp = new Date().toString(); String logEntry = "[" + timestamp + "] " + action; adminLogs.add(logEntry); // Append to file asynchronously CompletableFuture.runAsync(() -> { try (FileWriter fw = new FileWriter(logsFile, true); BufferedWriter bw = new BufferedWriter(fw); PrintWriter out = new PrintWriter(bw)) { out.println(logEntry); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to write admin log", e); } }); } /** * Save all data (called on shutdown) */ public void saveAllData() { StyleManager.logInfo("Saving all player data..."); try (Writer writer = new FileWriter(economyFile)) { gson.toJson(economyData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save economy data", e); } try (Writer writer = new FileWriter(homesFile)) { gson.toJson(homesData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save homes data", e); } try (Writer writer = new FileWriter(banFile)) { gson.toJson(banData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save ban data", e); } try (Writer writer = new FileWriter(statsFile)) { gson.toJson(statsData, writer); } catch (IOException e) { plugin.getLogger().log(Level.SEVERE, "Failed to save stats data", e); } StyleManager.logSuccess("All data saved successfully"); } /** * Get all economy data (for leaderboards) */ public Map getAllEconomyData() { return new HashMap<>(economyData); } /** * Get all stats data (for leaderboards) */ public Map getAllStatsData() { return new HashMap<>(statsData); } }