package com.kucris.optimiser.monitoring; import com.kucris.optimiser.KucrisOptimiser; import lombok.Getter; import org.bukkit.Bukkit; import org.bukkit.World; import org.bukkit.entity.Entity; import org.bukkit.scheduler.BukkitTask; import java.lang.management.ManagementFactory; import java.lang.management.MemoryMXBean; import java.util.LinkedList; import java.util.Queue; @Getter public class MonitoringService { private final KucrisOptimiser plugin; private final MemoryMXBean memoryBean; private final Queue tpsHistory; private final Queue msptHistory; private final Queue memoryHistory; private final Queue entityHistory; private double currentTPS; private double currentMSPT; private long currentMemoryUsed; private long currentMemoryMax; private int currentEntityCount; private int currentChunkCount; private BukkitTask monitoringTask; private long lastTickTime; public MonitoringService(KucrisOptimiser plugin) { this.plugin = plugin; this.memoryBean = ManagementFactory.getMemoryMXBean(); int historySize = plugin.getConfigManager().getInt("monitoring.history-size"); this.tpsHistory = new LinkedList<>(); this.msptHistory = new LinkedList<>(); this.memoryHistory = new LinkedList<>(); this.entityHistory = new LinkedList<>(); this.currentTPS = 20.0; this.lastTickTime = System.currentTimeMillis(); } public void start() { if (!plugin.getConfigManager().isModuleEnabled("monitoring")) { return; } int interval = plugin.getConfigManager().getInt("monitoring.update-interval"); this.monitoringTask = Bukkit.getScheduler().runTaskTimerAsynchronously(plugin, () -> { updateMetrics(); }, 0L, interval); plugin.getLogger().debug("Monitoring service started"); } public void stop() { if (monitoringTask != null) { monitoringTask.cancel(); monitoringTask = null; } } private void updateMetrics() { try { updateTPS(); updateMSPT(); updateMemory(); updateEntities(); updateChunks(); addToHistory(); } catch (Exception e) { plugin.getLogger().error("Error updating metrics: " + e.getMessage()); } } private void updateTPS() { try { this.currentTPS = Bukkit.getTPS()[0]; } catch (Exception e) { this.currentTPS = 20.0; } } private void updateMSPT() { if (!plugin.getConfigManager().getBoolean("monitoring.track-mspt")) { return; } try { double[] tps = Bukkit.getTPS(); if (tps[0] > 0) { this.currentMSPT = 1000.0 / tps[0]; } else { this.currentMSPT = 50.0; } } catch (Exception e) { this.currentMSPT = 50.0; } } private void updateMemory() { if (!plugin.getConfigManager().getBoolean("monitoring.track-memory")) { return; } Runtime runtime = Runtime.getRuntime(); this.currentMemoryUsed = (runtime.totalMemory() - runtime.freeMemory()) / 1048576; this.currentMemoryMax = runtime.maxMemory() / 1048576; } private void updateEntities() { if (!plugin.getConfigManager().getBoolean("monitoring.track-entities")) { return; } int count = 0; for (World world : Bukkit.getWorlds()) { count += world.getEntities().size(); } this.currentEntityCount = count; } private void updateChunks() { if (!plugin.getConfigManager().getBoolean("monitoring.track-chunks")) { return; } int count = 0; for (World world : Bukkit.getWorlds()) { count += world.getLoadedChunks().length; } this.currentChunkCount = count; } private void addToHistory() { int maxSize = plugin.getConfigManager().getInt("monitoring.history-size"); addToQueue(tpsHistory, currentTPS, maxSize); addToQueue(msptHistory, currentMSPT, maxSize); addToQueue(memoryHistory, currentMemoryUsed, maxSize); addToQueue(entityHistory, currentEntityCount, maxSize); } private void addToQueue(Queue queue, T value, int maxSize) { queue.offer(value); while (queue.size() > maxSize) { queue.poll(); } } public double getMemoryUsagePercent() { if (currentMemoryMax == 0) return 0; return (currentMemoryUsed * 100.0) / currentMemoryMax; } public double getAverageTPS() { if (tpsHistory.isEmpty()) return currentTPS; return tpsHistory.stream().mapToDouble(Double::doubleValue).average().orElse(20.0); } public double getAverageMSPT() { if (msptHistory.isEmpty()) return currentMSPT; return msptHistory.stream().mapToDouble(Double::doubleValue).average().orElse(50.0); } public int getEntityGrowthRate() { if (entityHistory.size() < 2) return 0; Integer[] history = entityHistory.toArray(new Integer[0]); int recent = history[history.length - 1]; int old = history[0]; return recent - old; } }