package com.surge.exchanger.data; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.reflect.TypeToken; import com.surge.exchanger.SurgeExchanger; import com.surge.exchanger.data.model.Ticket; import com.surge.exchanger.data.model.Transaction; import com.surge.exchanger.data.model.UserData; import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.lang.reflect.Type; import java.util.HashMap; import java.util.Map; import java.util.UUID; public class DataManager { private final SurgeExchanger plugin; private final Gson gson; private final File dataFolder; private final Map users; private final Map transactions; private final Map tickets; public DataManager(SurgeExchanger plugin) { this.plugin = plugin; this.gson = new GsonBuilder().setPrettyPrinting().create(); this.dataFolder = new File(plugin.getDataFolder(), "data"); if (!dataFolder.exists()) { dataFolder.mkdirs(); } this.users = new HashMap<>(); this.transactions = new HashMap<>(); this.tickets = new HashMap<>(); loadAll(); } public void loadAll() { loadUsers(); loadTransactions(); loadTickets(); } public void saveAll() { saveUsers(); saveTransactions(); saveTickets(); } private void loadUsers() { File file = new File(dataFolder, "users.json"); if (file.exists()) { try (FileReader reader = new FileReader(file)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { users.putAll(loaded); } } catch (IOException e) { plugin.getLogger().warning("Failed to load users.json: " + e.getMessage()); } } } private void saveUsers() { File file = new File(dataFolder, "users.json"); try (FileWriter writer = new FileWriter(file)) { gson.toJson(users, writer); } catch (IOException e) { plugin.getLogger().warning("Failed to save users.json: " + e.getMessage()); } } private void loadTransactions() { File file = new File(dataFolder, "transactions.json"); if (file.exists()) { try (FileReader reader = new FileReader(file)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { transactions.putAll(loaded); } } catch (IOException e) { plugin.getLogger().warning("Failed to load transactions.json: " + e.getMessage()); } } } private void saveTransactions() { File file = new File(dataFolder, "transactions.json"); try (FileWriter writer = new FileWriter(file)) { gson.toJson(transactions, writer); } catch (IOException e) { plugin.getLogger().warning("Failed to save transactions.json: " + e.getMessage()); } } private void loadTickets() { File file = new File(dataFolder, "tickets.json"); if (file.exists()) { try (FileReader reader = new FileReader(file)) { Type type = new TypeToken>(){}.getType(); Map loaded = gson.fromJson(reader, type); if (loaded != null) { tickets.putAll(loaded); } } catch (IOException e) { plugin.getLogger().warning("Failed to load tickets.json: " + e.getMessage()); } } } private void saveTickets() { File file = new File(dataFolder, "tickets.json"); try (FileWriter writer = new FileWriter(file)) { gson.toJson(tickets, writer); } catch (IOException e) { plugin.getLogger().warning("Failed to save tickets.json: " + e.getMessage()); } } public UserData getUser(String userId) { return users.computeIfAbsent(userId, id -> new UserData(id)); } public Transaction getTransaction(String transactionId) { return transactions.get(transactionId); } public void saveTransaction(Transaction transaction) { transactions.put(transaction.getId(), transaction); saveTransactions(); } public Ticket getTicket(String ticketId) { return tickets.get(ticketId); } public void saveTicket(Ticket ticket) { tickets.put(ticket.getId(), ticket); saveTickets(); } public void removeTicket(String ticketId) { tickets.remove(ticketId); saveTickets(); } public void saveUser(UserData user) { users.put(user.getUserId(), user); saveUsers(); } public String generateTransactionId() { return "TXN-" + UUID.randomUUID().toString().substring(0, 8).toUpperCase(); } public Map getTickets() { return tickets; } public Map getTransactions() { return transactions; } public Map getUsers() { return users; } public String generateTicketId() { return UUID.randomUUID().toString().substring(0, 8).toUpperCase(); } public int getUserLevel(String userId) { return getUser(userId).getLevel(); } public int getUserCompletedExchanges(String userId) { return getUser(userId).getCompletedExchanges(); } public String getUserStatus(String userId) { UserData user = getUser(userId); if (user.isMuted()) return "🔇 Muted"; if (user.getWarnings() > 0) return "⚠️ " + user.getWarnings() + " Warning(s)"; return "✅ Good Standing"; } }