package com.hardcoresmp.data; import com.hardcoresmp.HardcoreSMPPlugin; import com.hardcoresmp.heart.HeartType; import org.bukkit.Bukkit; import org.bukkit.OfflinePlayer; import org.bukkit.configuration.ConfigurationSection; import org.bukkit.configuration.file.YamlConfiguration; import java.io.File; import java.io.IOException; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class DataManager { private final HardcoreSMPPlugin plugin; private final File dataFile; private YamlConfiguration data; private final Map players = new ConcurrentHashMap<>(); private final Map> teams = new HashMap<>(); private final Map pendingWeakens = new ConcurrentHashMap<>(); public DataManager(HardcoreSMPPlugin plugin) { this.plugin = plugin; this.dataFile = new File(plugin.getDataFolder(), "data.yml"); } public void loadAll() { if (!dataFile.exists()) { try { dataFile.getParentFile().mkdirs(); dataFile.createNewFile(); } catch (IOException e) { plugin.getLogger().severe("Could not create data.yml: " + e.getMessage()); } } data = YamlConfiguration.loadConfiguration(dataFile); loadPlayers(); loadPendingWeakens(); loadTeams(); plugin.getServer().getScheduler().runTaskTimer(plugin, this::saveAll, 600L, 600L); } private void loadPlayers() { ConfigurationSection playersSection = data.getConfigurationSection("players"); if (playersSection == null) return; for (String key : playersSection.getKeys(false)) { UUID uuid; try { uuid = UUID.fromString(key); } catch (IllegalArgumentException e) { continue; } String name = playersSection.getString(key + ".name", "Unknown"); long playtime = playersSection.getLong(key + ".playtime", plugin.getConfig().getInt("playtime.start-time", 3600)); String heartStr = playersSection.getString(key + ".heart-type", "BLUE"); boolean weakened = playersSection.getBoolean(key + ".weakened", false); HeartType heartType; try { heartType = HeartType.valueOf(heartStr); } catch (IllegalArgumentException e) { heartType = HeartType.BLUE; } PlayerData playerData = new PlayerData(uuid, name, playtime); playerData.setHeartType(heartType); playerData.setWeakened(weakened); players.put(uuid, playerData); } } private void loadPendingWeakens() { ConfigurationSection pendingSection = data.getConfigurationSection("pending-weakens"); if (pendingSection == null) return; for (String key : pendingSection.getKeys(false)) { pendingWeakens.put(key, pendingSection.getInt(key, 0)); } } private void loadTeams() { List> teamList = plugin.getConfig().getMapList("teams"); for (Map teamEntry : teamList) { String name = (String) teamEntry.get("name"); List memberNames = (List) teamEntry.get("members"); List memberUuids = new ArrayList<>(); if (memberNames != null) { for (String memberName : memberNames) { @SuppressWarnings("deprecation") OfflinePlayer offline = Bukkit.getOfflinePlayer(memberName); memberUuids.add(offline.getUniqueId()); } } teams.put(name, memberUuids); } } public PlayerData getOrCreatePlayerData(UUID uuid, String playerName) { PlayerData existing = players.get(uuid); if (existing != null) { existing.setPlayerName(playerName); return existing; } long startTime = plugin.getConfig().getInt("playtime.start-time", 3600); PlayerData newData = new PlayerData(uuid, playerName, startTime); players.put(uuid, newData); return newData; } public PlayerData getPlayerData(UUID uuid) { return players.get(uuid); } public void savePlayerData(PlayerData playerData) { String path = "players." + playerData.getUuid().toString(); data.set(path + ".name", playerData.getPlayerName()); data.set(path + ".playtime", playerData.getRemainingPlaytime()); data.set(path + ".heart-type", playerData.getHeartType().name()); data.set(path + ".weakened", playerData.isWeakened()); } public void saveAll() { try { data.save(dataFile); } catch (IOException e) { plugin.getLogger().severe("Could not save data.yml: " + e.getMessage()); } } public String getTeamForPlayer(UUID uuid) { for (Map.Entry> entry : teams.entrySet()) { if (entry.getValue().contains(uuid)) { return entry.getKey(); } } return null; } public List getTeammates(UUID uuid) { for (Map.Entry> entry : teams.entrySet()) { if (entry.getValue().contains(uuid)) { List teammates = new ArrayList<>(entry.getValue()); teammates.remove(uuid); return teammates; } } return Collections.emptyList(); } public void addPendingWeakening(String teamName) { int count = pendingWeakens.getOrDefault(teamName, 0); pendingWeakens.put(teamName, count + 1); data.set("pending-weakens." + teamName, count + 1); } public boolean consumePendingWeakening(String teamName) { int count = pendingWeakens.getOrDefault(teamName, 0); if (count <= 0) return false; pendingWeakens.put(teamName, count - 1); data.set("pending-weakens." + teamName, count - 1); return true; } public Set getTeamNames() { return teams.keySet(); } }